[
https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14243423#comment-14243423
]
Joe Stein commented on KAFKA-1650:
----------------------------------
I am getting a local failure running ./gradlew test
kafka.server.ServerShutdownTest > testCleanShutdownAfterFailedStartup FAILED
java.lang.NullPointerException
at
kafka.server.ServerShutdownTest$$anonfun$verifyNonDaemonThreadsStatus$2.apply(ServerShutdownTest.scala:147)
at
kafka.server.ServerShutdownTest$$anonfun$verifyNonDaemonThreadsStatus$2.apply(ServerShutdownTest.scala:147)
at
scala.collection.TraversableOnce$$anonfun$count$1.apply(TraversableOnce.scala:114)
at
scala.collection.TraversableOnce$$anonfun$count$1.apply(TraversableOnce.scala:113)
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108)
at
scala.collection.TraversableOnce$class.count(TraversableOnce.scala:113)
at scala.collection.mutable.ArrayOps$ofRef.count(ArrayOps.scala:108)
at
kafka.server.ServerShutdownTest.verifyNonDaemonThreadsStatus(ServerShutdownTest.scala:147)
at
kafka.server.ServerShutdownTest.testCleanShutdownAfterFailedStartup(ServerShutdownTest.scala:141)
kafka.server.ServerShutdownTest > testCleanShutdownWithDeleteTopicEnabled FAILED
java.lang.NullPointerException
at
kafka.server.ServerShutdownTest$$anonfun$verifyNonDaemonThreadsStatus$2.apply(ServerShutdownTest.scala:147)
at
kafka.server.ServerShutdownTest$$anonfun$verifyNonDaemonThreadsStatus$2.apply(ServerShutdownTest.scala:147)
at
scala.collection.TraversableOnce$$anonfun$count$1.apply(TraversableOnce.scala:114)
at
scala.collection.TraversableOnce$$anonfun$count$1.apply(TraversableOnce.scala:113)
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108)
at
scala.collection.TraversableOnce$class.count(TraversableOnce.scala:113)
at scala.collection.mutable.ArrayOps$ofRef.count(ArrayOps.scala:108)
at
kafka.server.ServerShutdownTest.verifyNonDaemonThreadsStatus(ServerShutdownTest.scala:147)
at
kafka.server.ServerShutdownTest.testCleanShutdownWithDeleteTopicEnabled(ServerShutdownTest.scala:114)
kafka.server.ServerShutdownTest > testConsecutiveShutdown PASSED
kafka.server.ServerShutdownTest > testCleanShutdown FAILED
java.lang.NullPointerException
at
kafka.server.ServerShutdownTest$$anonfun$verifyNonDaemonThreadsStatus$2.apply(ServerShutdownTest.scala:147)
at
kafka.server.ServerShutdownTest$$anonfun$verifyNonDaemonThreadsStatus$2.apply(ServerShutdownTest.scala:147)
at
scala.collection.TraversableOnce$$anonfun$count$1.apply(TraversableOnce.scala:114)
at
scala.collection.TraversableOnce$$anonfun$count$1.apply(TraversableOnce.scala:113)
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108)
at
scala.collection.TraversableOnce$class.count(TraversableOnce.scala:113)
at scala.collection.mutable.ArrayOps$ofRef.count(ArrayOps.scala:108)
at
kafka.server.ServerShutdownTest.verifyNonDaemonThreadsStatus(ServerShutdownTest.scala:147)
at
kafka.server.ServerShutdownTest.testCleanShutdown(ServerShutdownTest.scala:101)
and the CI is broken too just ran another one just now to triple check
https://builds.apache.org/view/All/job/Kafka-trunk/352/
I am a bit lost on this ticket it looks like the code is committed to trunk
(commit 2801629964882015a9148e1c0ade22da46376faa) but this JIRA doesn't have
resolved or which fix version (and more patches after commit) and tests are
failing [~guozhang] can you take a look please (it looks like your commit)
> Mirror Maker could lose data on unclean shutdown.
> -------------------------------------------------
>
> Key: KAFKA-1650
> URL: https://issues.apache.org/jira/browse/KAFKA-1650
> Project: Kafka
> Issue Type: Improvement
> Reporter: Jiangjie Qin
> Assignee: Jiangjie Qin
> Attachments: KAFKA-1650.patch, KAFKA-1650_2014-10-06_10:17:46.patch,
> KAFKA-1650_2014-11-12_09:51:30.patch, KAFKA-1650_2014-11-17_18:44:37.patch,
> KAFKA-1650_2014-11-20_12:00:16.patch, KAFKA-1650_2014-11-24_08:15:17.patch,
> KAFKA-1650_2014-12-03_15:02:31.patch, KAFKA-1650_2014-12-03_19:02:13.patch,
> KAFKA-1650_2014-12-04_11:59:07.patch, KAFKA-1650_2014-12-06_18:58:57.patch,
> KAFKA-1650_2014-12-08_01:36:01.patch
>
>
> Currently if mirror maker got shutdown uncleanly, the data in the data
> channel and buffer could potentially be lost. With the new producer's
> callback, this issue could be solved.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
