[
https://issues.apache.org/jira/browse/KAFKA-757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13576856#comment-13576856
]
John Fung commented on KAFKA-757:
---------------------------------
This is happening in all Hard-failure testcases in System Test:
testcase_015[1-9]
The following error is thrown when a hard-failed broker (kill -9) is re-started:
[2013-02-12 10:07:15,015] INFO Started Kafka CSV metrics reporter with polling
period 5 seconds (kafka.metrics.KafkaCSVMetricsReporter)
[2013-02-12 10:07:15,020] INFO [Kafka Server 3], starting
(kafka.server.KafkaServer)
[2013-02-12 10:07:15,046] INFO [Log Manager on Broker 3] Loading log 'test_1-2'
(kafka.log.LogManager)
[2013-02-12 10:07:15,062] INFO Creating or reloading log segment
/tmp/kafka_server_3_logs/test_1-2/00000000000000000000.log
(kafka.log.FileMessageSet)
[2013-02-12 10:07:15,066] INFO Loaded index file
/tmp/kafka_server_3_logs/test_1-2/00000000000000000000.index with maxEntries =
1310720, maxIndexSize = 10485760, entries = 1310720, lastOffset = 0, file
position = 10485760 (kafka.log.OffsetIndex)
[2013-02-12 10:07:15,068] FATAL Fatal error during KafkaServerStable startup.
Prepare to shutdown (kafka.server.KafkaServerStartable)
java.lang.IllegalArgumentException: requirement failed: Corrupt index found,
index file (/tmp/kafka_server_3_logs/test_1-2/00000000000000000000.index) has
non-zero size but last offset is 0.
at scala.Predef$.require(Predef.scala:145)
at kafka.log.OffsetIndex.<init>(OffsetIndex.scala:95)
at kafka.log.LogSegment.<init>(LogSegment.scala:36)
at kafka.log.Log$$anonfun$loadSegments$2.apply(Log.scala:163)
at kafka.log.Log$$anonfun$loadSegments$2.apply(Log.scala:147)
at
scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:827)
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
at scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:34)
at
scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:826)
at kafka.log.Log.loadSegments(Log.scala:147)
at kafka.log.Log.<init>(Log.scala:125)
at
kafka.log.LogManager$$anonfun$loadLogs$1$$anonfun$apply$3.apply(LogManager.scala:115)
at
kafka.log.LogManager$$anonfun$loadLogs$1$$anonfun$apply$3.apply(LogManager.scala:109)
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
at scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:34)
at kafka.log.LogManager$$anonfun$loadLogs$1.apply(LogManager.scala:109)
at kafka.log.LogManager$$anonfun$loadLogs$1.apply(LogManager.scala:101)
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:32)
at kafka.log.LogManager.loadLogs(LogManager.scala:101)
at kafka.log.LogManager.<init>(LogManager.scala:62)
at kafka.server.KafkaServer.startup(KafkaServer.scala:59)
at
kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:34)
at kafka.Kafka$.main(Kafka.scala:46)
at kafka.Kafka.main(Kafka.scala)
[2013-02-12 10:07:15,069] INFO [Kafka Server 3], shutting down
(kafka.server.KafkaServer)
> System Test Hard Failure cases : "Fatal error during KafkaServerStable
> startup" when hard-failed broker is re-started
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-757
> URL: https://issues.apache.org/jira/browse/KAFKA-757
> Project: Kafka
> Issue Type: Bug
> Reporter: John Fung
> Priority: Blocker
> Labels: replication-testing
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
