API tools faq
paste
Guest User

Untitled

a guest
Sep 3rd, 2018
203
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 24.59 KB | None | 0 0
raw download clone embed print report
  1. [2018-09-02 23:07:54,315] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions (kafka.server.ReplicaFetcherManager)
  2. [2018-09-02 23:07:54,315] INFO [ReplicaAlterLogDirsManager on broker 0] Removed fetcher for partitions (kafka.server.ReplicaAlterLogDirsManager)
  3. [2018-09-02 23:07:54,315] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions test-1 (kafka.server.ReplicaFetcherManager)
  4. [2018-09-02 23:07:54,315] INFO [ReplicaAlterLogDirsManager on broker 0] Removed fetcher for partitions test-1 (kafka.server.ReplicaAlterLogDirsManager)
  5. [2018-09-02 23:07:54,315] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions test-0 (kafka.server.ReplicaFetcherManager)
  6. [2018-09-02 23:07:54,315] INFO [ReplicaAlterLogDirsManager on broker 0] Removed fetcher for partitions test-0 (kafka.server.ReplicaAlterLogDirsManager)
  7. [2018-09-02 23:07:54,331] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions test-2 (kafka.server.ReplicaFetcherManager)
  8. [2018-09-02 23:07:54,331] INFO [ReplicaAlterLogDirsManager on broker 0] Removed fetcher for partitions test-2 (kafka.server.ReplicaAlterLogDirsManager)
  9. [2018-09-02 23:07:54,331] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions (kafka.server.ReplicaFetcherManager)
  10. [2018-09-02 23:07:54,331] INFO [ReplicaAlterLogDirsManager on broker 0] Removed fetcher for partitions (kafka.server.ReplicaAlterLogDirsManager)
  11. [2018-09-02 23:07:54,331] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions test-1 (kafka.server.ReplicaFetcherManager)
  12. [2018-09-02 23:07:54,331] INFO [ReplicaAlterLogDirsManager on broker 0] Removed fetcher for partitions test-1 (kafka.server.ReplicaAlterLogDirsManager)
  13. [2018-09-02 23:07:54,347] INFO The cleaning for partition test-1 is aborted and paused (kafka.log.LogCleanerManager)
  14. [2018-09-02 23:07:54,347] INFO Compaction for partition test-1 is resumed (kafka.log.LogCleanerManager)
  15. [2018-09-02 23:07:54,347] INFO The cleaning for partition test-1 is aborted (kafka.log.LogCleanerManager)
  16. [2018-09-02 23:07:54,409] INFO Log for partition test-1 is renamed to C:\tmp\kafka-logs\test-1.a230d8c1d3f14e70b16f694ba2f46bd8-delete and is scheduled for deletion (kafka.log.LogManager)
  17. [2018-09-02 23:07:54,425] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions test-0 (kafka.server.ReplicaFetcherManager)
  18. [2018-09-02 23:07:54,425] INFO [ReplicaAlterLogDirsManager on broker 0] Removed fetcher for partitions test-0 (kafka.server.ReplicaAlterLogDirsManager)
  19. [2018-09-02 23:07:54,425] INFO The cleaning for partition test-0 is aborted and paused (kafka.log.LogCleanerManager)
  20. [2018-09-02 23:07:54,425] INFO Compaction for partition test-0 is resumed (kafka.log.LogCleanerManager)
  21. [2018-09-02 23:07:54,425] INFO The cleaning for partition test-0 is aborted (kafka.log.LogCleanerManager)
  22. [2018-09-02 23:07:54,457] INFO Log for partition test-0 is renamed to C:\tmp\kafka-logs\test-0.6941d675c6774980bb587b58357a6060-delete and is scheduled for deletion (kafka.log.LogManager)
  23. [2018-09-02 23:07:54,457] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions test-2 (kafka.server.ReplicaFetcherManager)
  24. [2018-09-02 23:07:54,457] INFO [ReplicaAlterLogDirsManager on broker 0] Removed fetcher for partitions test-2 (kafka.server.ReplicaAlterLogDirsManager)
  25. [2018-09-02 23:07:54,472] INFO The cleaning for partition test-2 is aborted and paused (kafka.log.LogCleanerManager)
  26. [2018-09-02 23:07:54,472] INFO Compaction for partition test-2 is resumed (kafka.log.LogCleanerManager)
  27. [2018-09-02 23:07:54,472] INFO The cleaning for partition test-2 is aborted (kafka.log.LogCleanerManager)
  28. [2018-09-02 23:07:54,488] INFO Log for partition test-2 is renamed to C:\tmp\kafka-logs\test-2.e400356e04ed41c2abc036d82819f778-delete and is scheduled for deletion (kafka.log.LogManager)
  29. [2018-09-02 23:08:16,059] INFO Deleted log C:\tmp\kafka-logs\test-1.a230d8c1d3f14e70b16f694ba2f46bd8-delete\00000000000000000000.log. (kafka.log.LogSegment)
  30. [2018-09-02 23:08:19,201] WARN (kafka.utils.CoreUtils$)
  31. java.lang.NullPointerException
  32. at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
  33. at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:290)
  34. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(AbstractIndex.scala:192)
  35. at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:85)
  36. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply$mcV$sp(AbstractIndex.scala:192)
  37. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  38. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  39. at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)
  40. at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:187)
  41. at kafka.log.LogSegment$$anonfun$deleteIfExists$2$$anonfun$apply$mcV$sp$2.apply$mcZ$sp(LogSegment.scala:523)
  42. at kafka.log.LogSegment.kafka$log$LogSegment$$delete$1(LogSegment.scala:511)
  43. at kafka.log.LogSegment$$anonfun$deleteIfExists$2.apply$mcV$sp(LogSegment.scala:523)
  44. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:114)
  45. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:113)
  46. at scala.collection.immutable.List.foreach(List.scala:392)
  47. at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:113)
  48. at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:521)
  49. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  50. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  51. at scala.collection.Iterator$class.foreach(Iterator.scala:891)
  52. at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
  53. at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
  54. at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
  55. at kafka.log.Log$$anonfun$delete$1.apply$mcV$sp(Log.scala:1429)
  56. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  57. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  58. at kafka.log.Log.maybeHandleIOException(Log.scala:1670)
  59. at kafka.log.Log.delete(Log.scala:1425)
  60. at kafka.log.LogManager.kafka$log$LogManager$$deleteLogs(LogManager.scala:705)
  61. at kafka.log.LogManager$$anonfun$startup$5.apply$mcV$sp(LogManager.scala:395)
  62. at kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:110)
  63. at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:62)
  64. at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
  65. at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
  66. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source)
  67. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
  68. at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
  69. at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
  70. at java.lang.Thread.run(Unknown Source)
  71. [2018-09-02 23:08:19,201] INFO Deleted offset index C:\tmp\kafka-logs\test-1.a230d8c1d3f14e70b16f694ba2f46bd8-delete\00000000000000000000.index. (kafka.log.LogSegment)
  72. [2018-09-02 23:08:19,201] WARN (kafka.utils.CoreUtils$)
  73. java.lang.NullPointerException
  74. at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
  75. at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:290)
  76. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(AbstractIndex.scala:192)
  77. at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:85)
  78. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply$mcV$sp(AbstractIndex.scala:192)
  79. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  80. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  81. at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)
  82. at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:187)
  83. at kafka.log.LogSegment$$anonfun$deleteIfExists$3$$anonfun$apply$mcV$sp$3.apply$mcZ$sp(LogSegment.scala:524)
  84. at kafka.log.LogSegment.kafka$log$LogSegment$$delete$1(LogSegment.scala:511)
  85. at kafka.log.LogSegment$$anonfun$deleteIfExists$3.apply$mcV$sp(LogSegment.scala:524)
  86. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:114)
  87. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:113)
  88. at scala.collection.immutable.List.foreach(List.scala:392)
  89. at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:113)
  90. at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:521)
  91. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  92. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  93. at scala.collection.Iterator$class.foreach(Iterator.scala:891)
  94. at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
  95. at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
  96. at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
  97. at kafka.log.Log$$anonfun$delete$1.apply$mcV$sp(Log.scala:1429)
  98. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  99. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  100. at kafka.log.Log.maybeHandleIOException(Log.scala:1670)
  101. at kafka.log.Log.delete(Log.scala:1425)
  102. at kafka.log.LogManager.kafka$log$LogManager$$deleteLogs(LogManager.scala:705)
  103. at kafka.log.LogManager$$anonfun$startup$5.apply$mcV$sp(LogManager.scala:395)
  104. at kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:110)
  105. at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:62)
  106. at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
  107. at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
  108. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source)
  109. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
  110. at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
  111. at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
  112. at java.lang.Thread.run(Unknown Source)
  113. [2018-09-02 23:08:19,201] INFO Deleted time index C:\tmp\kafka-logs\test-1.a230d8c1d3f14e70b16f694ba2f46bd8-delete\00000000000000000000.timeindex. (kafka.log.LogSegment)
  114. [2018-09-02 23:08:19,217] INFO Deleted log for partition test-1 in C:\tmp\kafka-logs\test-1.a230d8c1d3f14e70b16f694ba2f46bd8-delete. (kafka.log.LogManager)
  115. [2018-09-02 23:08:19,217] INFO Deleted log C:\tmp\kafka-logs\test-0.6941d675c6774980bb587b58357a6060-delete\00000000000000000000.log. (kafka.log.LogSegment)
  116. [2018-09-02 23:08:19,217] WARN (kafka.utils.CoreUtils$)
  117. java.lang.NullPointerException
  118. at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
  119. at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:290)
  120. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(AbstractIndex.scala:192)
  121. at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:85)
  122. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply$mcV$sp(AbstractIndex.scala:192)
  123. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  124. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  125. at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)
  126. at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:187)
  127. at kafka.log.LogSegment$$anonfun$deleteIfExists$2$$anonfun$apply$mcV$sp$2.apply$mcZ$sp(LogSegment.scala:523)
  128. at kafka.log.LogSegment.kafka$log$LogSegment$$delete$1(LogSegment.scala:511)
  129. at kafka.log.LogSegment$$anonfun$deleteIfExists$2.apply$mcV$sp(LogSegment.scala:523)
  130. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:114)
  131. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:113)
  132. at scala.collection.immutable.List.foreach(List.scala:392)
  133. at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:113)
  134. at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:521)
  135. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  136. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  137. at scala.collection.Iterator$class.foreach(Iterator.scala:891)
  138. at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
  139. at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
  140. at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
  141. at kafka.log.Log$$anonfun$delete$1.apply$mcV$sp(Log.scala:1429)
  142. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  143. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  144. at kafka.log.Log.maybeHandleIOException(Log.scala:1670)
  145. at kafka.log.Log.delete(Log.scala:1425)
  146. at kafka.log.LogManager.kafka$log$LogManager$$deleteLogs(LogManager.scala:705)
  147. at kafka.log.LogManager$$anonfun$startup$5.apply$mcV$sp(LogManager.scala:395)
  148. at kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:110)
  149. at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:62)
  150. at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
  151. at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
  152. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source)
  153. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
  154. at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
  155. at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
  156. at java.lang.Thread.run(Unknown Source)
  157. [2018-09-02 23:08:19,217] INFO Deleted offset index C:\tmp\kafka-logs\test-0.6941d675c6774980bb587b58357a6060-delete\00000000000000000000.index. (kafka.log.LogSegment)
  158. [2018-09-02 23:08:19,217] WARN (kafka.utils.CoreUtils$)
  159. java.lang.NullPointerException
  160. at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
  161. at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:290)
  162. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(AbstractIndex.scala:192)
  163. at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:85)
  164. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply$mcV$sp(AbstractIndex.scala:192)
  165. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  166. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  167. at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)
  168. at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:187)
  169. at kafka.log.LogSegment$$anonfun$deleteIfExists$3$$anonfun$apply$mcV$sp$3.apply$mcZ$sp(LogSegment.scala:524)
  170. at kafka.log.LogSegment.kafka$log$LogSegment$$delete$1(LogSegment.scala:511)
  171. at kafka.log.LogSegment$$anonfun$deleteIfExists$3.apply$mcV$sp(LogSegment.scala:524)
  172. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:114)
  173. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:113)
  174. at scala.collection.immutable.List.foreach(List.scala:392)
  175. at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:113)
  176. at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:521)
  177. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  178. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  179. at scala.collection.Iterator$class.foreach(Iterator.scala:891)
  180. at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
  181. at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
  182. at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
  183. at kafka.log.Log$$anonfun$delete$1.apply$mcV$sp(Log.scala:1429)
  184. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  185. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  186. at kafka.log.Log.maybeHandleIOException(Log.scala:1670)
  187. at kafka.log.Log.delete(Log.scala:1425)
  188. at kafka.log.LogManager.kafka$log$LogManager$$deleteLogs(LogManager.scala:705)
  189. at kafka.log.LogManager$$anonfun$startup$5.apply$mcV$sp(LogManager.scala:395)
  190. at kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:110)
  191. at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:62)
  192. at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
  193. at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
  194. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source)
  195. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
  196. at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
  197. at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
  198. at java.lang.Thread.run(Unknown Source)
  199. [2018-09-02 23:08:19,217] INFO Deleted time index C:\tmp\kafka-logs\test-0.6941d675c6774980bb587b58357a6060-delete\00000000000000000000.timeindex. (kafka.log.LogSegment)
  200. [2018-09-02 23:08:19,217] INFO Deleted log for partition test-0 in C:\tmp\kafka-logs\test-0.6941d675c6774980bb587b58357a6060-delete. (kafka.log.LogManager)
  201. [2018-09-02 23:08:19,232] INFO Deleted log C:\tmp\kafka-logs\test-2.e400356e04ed41c2abc036d82819f778-delete\00000000000000000000.log. (kafka.log.LogSegment)
  202. [2018-09-02 23:08:19,232] WARN (kafka.utils.CoreUtils$)
  203. java.lang.NullPointerException
  204. at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
  205. at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:290)
  206. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(AbstractIndex.scala:192)
  207. at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:85)
  208. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply$mcV$sp(AbstractIndex.scala:192)
  209. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  210. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  211. at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)
  212. at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:187)
  213. at kafka.log.LogSegment$$anonfun$deleteIfExists$2$$anonfun$apply$mcV$sp$2.apply$mcZ$sp(LogSegment.scala:523)
  214. at kafka.log.LogSegment.kafka$log$LogSegment$$delete$1(LogSegment.scala:511)
  215. at kafka.log.LogSegment$$anonfun$deleteIfExists$2.apply$mcV$sp(LogSegment.scala:523)
  216. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:114)
  217. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:113)
  218. at scala.collection.immutable.List.foreach(List.scala:392)
  219. at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:113)
  220. at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:521)
  221. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  222. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  223. at scala.collection.Iterator$class.foreach(Iterator.scala:891)
  224. at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
  225. at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
  226. at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
  227. at kafka.log.Log$$anonfun$delete$1.apply$mcV$sp(Log.scala:1429)
  228. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  229. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  230. at kafka.log.Log.maybeHandleIOException(Log.scala:1670)
  231. at kafka.log.Log.delete(Log.scala:1425)
  232. at kafka.log.LogManager.kafka$log$LogManager$$deleteLogs(LogManager.scala:705)
  233. at kafka.log.LogManager$$anonfun$startup$5.apply$mcV$sp(LogManager.scala:395)
  234. at kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:110)
  235. at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:62)
  236. at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
  237. at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
  238. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source)
  239. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
  240. at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
  241. at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
  242. at java.lang.Thread.run(Unknown Source)
  243. [2018-09-02 23:08:19,232] INFO Deleted offset index C:\tmp\kafka-logs\test-2.e400356e04ed41c2abc036d82819f778-delete\00000000000000000000.index. (kafka.log.LogSegment)
  244. [2018-09-02 23:08:19,232] WARN (kafka.utils.CoreUtils$)
  245. java.lang.NullPointerException
  246. at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
  247. at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:290)
  248. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(AbstractIndex.scala:192)
  249. at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:85)
  250. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply$mcV$sp(AbstractIndex.scala:192)
  251. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  252. at kafka.log.AbstractIndex$$anonfun$deleteIfExists$1.apply(AbstractIndex.scala:187)
  253. at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)
  254. at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:187)
  255. at kafka.log.LogSegment$$anonfun$deleteIfExists$3$$anonfun$apply$mcV$sp$3.apply$mcZ$sp(LogSegment.scala:524)
  256. at kafka.log.LogSegment.kafka$log$LogSegment$$delete$1(LogSegment.scala:511)
  257. at kafka.log.LogSegment$$anonfun$deleteIfExists$3.apply$mcV$sp(LogSegment.scala:524)
  258. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:114)
  259. at kafka.utils.CoreUtils$$anonfun$tryAll$1.apply(CoreUtils.scala:113)
  260. at scala.collection.immutable.List.foreach(List.scala:392)
  261. at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:113)
  262. at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:521)
  263. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  264. at kafka.log.Log$$anonfun$delete$1$$anonfun$apply$mcV$sp$6.apply(Log.scala:1429)
  265. at scala.collection.Iterator$class.foreach(Iterator.scala:891)
  266. at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
  267. at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
  268. at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
  269. at kafka.log.Log$$anonfun$delete$1.apply$mcV$sp(Log.scala:1429)
  270. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  271. at kafka.log.Log$$anonfun$delete$1.apply(Log.scala:1426)
  272. at kafka.log.Log.maybeHandleIOException(Log.scala:1670)
  273. at kafka.log.Log.delete(Log.scala:1425)
  274. at kafka.log.LogManager.kafka$log$LogManager$$deleteLogs(LogManager.scala:705)
  275. at kafka.log.LogManager$$anonfun$startup$5.apply$mcV$sp(LogManager.scala:395)
  276. at kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:110)
  277. at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:62)
  278. at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
  279. at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
  280. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source)
  281. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
  282. at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
  283. at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
  284. at java.lang.Thread.run(Unknown Source)
  285. [2018-09-02 23:08:19,232] INFO Deleted time index C:\tmp\kafka-logs\test-2.e400356e04ed41c2abc036d82819f778-delete\00000000000000000000.timeindex. (kafka.log.LogSegment)
  286. [2018-09-02 23:08:19,232] INFO Deleted log for partition test-2 in C:\tmp\kafka-logs\test-2.e400356e04ed41c2abc036d82819f778-delete. (kafka.log.LogManager)
Advertisement
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!