Guest User

crash cause

a guest
Jan 6th, 2018
157
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.53 KB | None | 0 0
  1. [2018-01-05 13:40:32,138] FATAL [Replica Manager on Broker 3]: Halting due to unrecoverable I/O error while handling produce request: (kafka.server.ReplicaManager)
  2. kafka.common.KafkaStorageException: I/O exception in append to log '__consumer_offsets-53'
  3. at kafka.log.Log.append(Log.scala:349)
  4. at kafka.cluster.Partition$$anonfun$10.apply(Partition.scala:443)
  5. at kafka.cluster.Partition$$anonfun$10.apply(Partition.scala:429)
  6. at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:234)
  7. at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:240)
  8. at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:429)
  9. at kafka.server.ReplicaManager$$anonfun$appendToLocalLog$2.apply(ReplicaManager.scala:407)
  10. at kafka.server.ReplicaManager$$anonfun$appendToLocalLog$2.apply(ReplicaManager.scala:393)
  11. at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
  12. at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
  13. at scala.collection.immutable.Map$Map1.foreach(Map.scala:116)
  14. at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
  15. at scala.collection.AbstractTraversable.map(Traversable.scala:104)
  16. at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:393)
  17. at kafka.server.ReplicaManager.appendMessages(ReplicaManager.scala:330)
  18. at kafka.coordinator.GroupMetadataManager.store(GroupMetadataManager.scala:225)
  19. at kafka.coordinator.GroupCoordinator$$anonfun$onCompleteJoin$6.apply(GroupCoordinator.scala:726)
  20. at kafka.coordinator.GroupCoordinator$$anonfun$onCompleteJoin$6.apply(GroupCoordinator.scala:726)
  21. at scala.Option.foreach(Option.scala:257)
  22. at kafka.coordinator.GroupCoordinator.onCompleteJoin(GroupCoordinator.scala:726)
  23. at kafka.coordinator.DelayedJoin.onComplete(DelayedJoin.scala:43)
  24. at kafka.server.DelayedOperation.forceComplete(DelayedOperation.scala:66)
  25. at kafka.coordinator.DelayedJoin$$anonfun$tryComplete$1.apply$mcZ$sp(DelayedJoin.scala:41)
  26. at kafka.coordinator.GroupCoordinator.tryCompleteJoin(GroupCoordinator.scala:672)
  27. at kafka.coordinator.DelayedJoin.tryComplete(DelayedJoin.scala:41)
  28. at kafka.coordinator.DelayedJoin.safeTryComplete(DelayedJoin.scala:39)
  29. at kafka.server.DelayedOperationPurgatory$Watchers.tryCompleteWatched(DelayedOperation.scala:322)
  30. at kafka.server.DelayedOperationPurgatory.checkAndComplete(DelayedOperation.scala:240)
  31. at kafka.coordinator.GroupCoordinator.onMemberFailure(GroupCoordinator.scala:665)
  32. at kafka.coordinator.GroupCoordinator.onExpireHeartbeat(GroupCoordinator.scala:740)
  33. at kafka.coordinator.DelayedHeartbeat.onExpiration(DelayedHeartbeat.scala:38)
  34. at kafka.server.DelayedOperation.run(DelayedOperation.scala:113)
  35. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  36. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  37. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  38. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  39. at java.lang.Thread.run(Thread.java:748)
  40. Caused by: java.nio.channels.ClosedChannelException
  41. at sun.nio.ch.FileChannelImpl.ensureOpen(FileChannelImpl.java:110)
  42. at sun.nio.ch.FileChannelImpl.size(FileChannelImpl.java:300)
  43. at kafka.log.FileMessageSet.truncateTo(FileMessageSet.scala:405)
  44. at kafka.log.FileMessageSet.trim(FileMessageSet.scala:378)
  45. at kafka.log.Log.roll(Log.scala:775)
  46. at kafka.log.Log.maybeRoll(Log.scala:744)
  47. at kafka.log.Log.append(Log.scala:405)
  48. ... 36 more
Advertisement
Add Comment
Please, Sign In to add comment