[
https://issues.apache.org/jira/browse/SAMZA-224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13967202#comment-13967202
]
Yan Fang commented on SAMZA-224:
--------------------------------
Would the connection refused exception be a concern in
TestKafkaCheckpointManager ? Though we still can pass this test.
{code:title=Bar.java|borderStyle=solid}
15:11:25.955 [DEBUG] [TestEventLogger]
org.apache.samza.checkpoint.kafka.TestKafkaCheckpointManager STANDARD_OUT
15:11:25.955 [DEBUG] [TestEventLogger] [2014-04-11 15:11:25,931] ERROR
[Controller-1-to-broker-1-send-thread], Controller 1's connection to broker
id:1,host:localhost,port:51957 was unsuccessful
(kafka.controller.RequestSendThread:103)
15:11:25.960 [DEBUG] [TestEventLogger] java.net.ConnectException:
Connection refused
15:11:25.962 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect0(Native Method)
15:11:25.977 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect(Net.java:465)
15:11:25.979 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect(Net.java:457)
15:11:25.991 [DEBUG] [TestEventLogger] at
sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:670)
15:11:26.008 [DEBUG] [TestEventLogger] at
kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
15:11:26.011 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
15:11:26.021 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.<init>(ControllerChannelManager.scala:118)
15:11:26.023 [DEBUG] [TestEventLogger] at
kafka.controller.ControllerChannelManager.kafka$controller$ControllerChannelManager$$addNewBroker(ControllerChannelManager.scala:87)
15:11:26.024 [DEBUG] [TestEventLogger] at
kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
15:11:26.032 [DEBUG] [TestEventLogger] at
kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
15:11:26.052 [DEBUG] [TestEventLogger] at
scala.collection.immutable.Set$Set2.foreach(Set.scala:94)
15:11:26.053 [DEBUG] [TestEventLogger] at
kafka.controller.ControllerChannelManager.<init>(ControllerChannelManager.scala:38)
15:11:26.067 [DEBUG] [TestEventLogger] at
kafka.controller.KafkaController.startChannelManager(KafkaController.scala:776)
15:11:26.068 [DEBUG] [TestEventLogger] at
kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:704)
15:11:26.077 [DEBUG] [TestEventLogger] at
kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:309)
15:11:26.087 [DEBUG] [TestEventLogger] at
kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:161)
15:11:26.098 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
15:11:26.099 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
15:11:26.115 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
15:11:26.122 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
15:11:26.123 [DEBUG] [TestEventLogger] at
kafka.utils.Utils$.inLock(Utils.scala:538)
15:11:26.136 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
15:11:26.137 [DEBUG] [TestEventLogger] at
org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
15:11:26.138 [DEBUG] [TestEventLogger] at
org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
15:11:26.156 [DEBUG] [TestEventLogger] [2014-04-11 15:11:26,043] ERROR
[Controller-1-to-broker-1-send-thread], Controller 1 epoch 2 failed to send
LeaderAndIsr request with correlation id 0 to broker
id:1,host:localhost,port:51957. Reconnecting to broker.
(kafka.controller.RequestSendThread:103)
15:11:26.157 [DEBUG] [TestEventLogger]
java.nio.channels.ClosedChannelException
15:11:26.170 [DEBUG] [TestEventLogger] at
kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
15:11:26.183 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
15:11:26.184 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
15:11:26.188 [DEBUG] [TestEventLogger] at
kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
15:11:26.199 [DEBUG] [TestEventLogger] [2014-04-11 15:11:26,061] ERROR
[Controller-1-to-broker-1-send-thread], Controller 1's connection to broker
id:1,host:localhost,port:51957 was unsuccessful
(kafka.controller.RequestSendThread:103)
15:11:26.200 [DEBUG] [TestEventLogger] java.net.ConnectException:
Connection refused
15:11:26.209 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect0(Native Method)
15:11:26.210 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect(Net.java:465)
15:11:26.215 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect(Net.java:457)
15:11:26.217 [DEBUG] [TestEventLogger] at
sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:670)
15:11:26.221 [DEBUG] [TestEventLogger] at
kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
15:11:26.233 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
15:11:26.234 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
15:11:26.235 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
15:11:26.242 [DEBUG] [TestEventLogger] at
kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
15:11:26.289 [DEBUG] [TestEventLogger] [2014-04-11 15:11:26,279] ERROR
[Controller-2-to-broker-2-send-thread], Controller 2's connection to broker
id:2,host:localhost,port:50290 was unsuccessful
(kafka.controller.RequestSendThread:103)
15:11:26.291 [DEBUG] [TestEventLogger] java.net.ConnectException:
Connection refused
15:11:26.296 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect0(Native Method)
15:11:26.310 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect(Net.java:465)
15:11:26.311 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect(Net.java:457)
15:11:26.315 [DEBUG] [TestEventLogger] at
sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:670)
15:11:26.328 [DEBUG] [TestEventLogger] at
kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
15:11:26.337 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
15:11:26.339 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.<init>(ControllerChannelManager.scala:118)
15:11:26.355 [DEBUG] [TestEventLogger] at
kafka.controller.ControllerChannelManager.kafka$controller$ControllerChannelManager$$addNewBroker(ControllerChannelManager.scala:87)
15:11:26.358 [DEBUG] [TestEventLogger] at
kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
15:11:26.373 [DEBUG] [TestEventLogger] at
kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
15:11:26.375 [DEBUG] [TestEventLogger] at
scala.collection.immutable.Set$Set1.foreach(Set.scala:74)
15:11:26.377 [DEBUG] [TestEventLogger] at
kafka.controller.ControllerChannelManager.<init>(ControllerChannelManager.scala:38)
15:11:26.392 [DEBUG] [TestEventLogger] at
kafka.controller.KafkaController.startChannelManager(KafkaController.scala:776)
15:11:26.393 [DEBUG] [TestEventLogger] at
kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:704)
15:11:26.409 [DEBUG] [TestEventLogger] at
kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:309)
15:11:26.411 [DEBUG] [TestEventLogger] at
kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:161)
15:11:26.417 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
15:11:26.422 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
15:11:26.428 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
15:11:26.430 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
15:11:26.432 [DEBUG] [TestEventLogger] at
kafka.utils.Utils$.inLock(Utils.scala:538)
15:11:26.440 [DEBUG] [TestEventLogger] at
kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
15:11:26.441 [DEBUG] [TestEventLogger] at
org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
15:11:26.450 [DEBUG] [TestEventLogger] at
org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
15:11:26.451 [DEBUG] [TestEventLogger] [2014-04-11 15:11:26,317] ERROR
[Controller-2-to-broker-2-send-thread], Controller 2 epoch 3 failed to send
LeaderAndIsr request with correlation id 0 to broker
id:2,host:localhost,port:50290. Reconnecting to broker.
(kafka.controller.RequestSendThread:103)
15:11:26.452 [DEBUG] [TestEventLogger]
java.nio.channels.ClosedChannelException
15:11:26.453 [DEBUG] [TestEventLogger] at
kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
15:11:26.455 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
15:11:26.455 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
15:11:26.458 [DEBUG] [TestEventLogger] at
kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
15:11:26.464 [DEBUG] [TestEventLogger] [2014-04-11 15:11:26,322] ERROR
[Controller-2-to-broker-2-send-thread], Controller 2's connection to broker
id:2,host:localhost,port:50290 was unsuccessful
(kafka.controller.RequestSendThread:103)
15:11:26.466 [DEBUG] [TestEventLogger] java.net.ConnectException:
Connection refused
15:11:26.467 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect0(Native Method)
15:11:26.473 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect(Net.java:465)
15:11:26.475 [DEBUG] [TestEventLogger] at
sun.nio.ch.Net.connect(Net.java:457)
15:11:26.478 [DEBUG] [TestEventLogger] at
sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:670)
15:11:26.479 [DEBUG] [TestEventLogger] at
kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
15:11:26.483 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
15:11:26.486 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
15:11:26.491 [DEBUG] [TestEventLogger] at
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
15:11:26.496 [DEBUG] [TestEventLogger] at
kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
15:11:26.613 [DEBUG] [TestEventLogger]
15:11:26.613 [DEBUG] [TestEventLogger]
org.apache.samza.checkpoint.kafka.TestKafkaCheckpointManager PASSED
15:11:26.614 [QUIET] [system.out] 15:11:26.614 [DEBUG]
[org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor] Executing
test class org.apache.samza.serializers.TestKafkaSerde
15:11:26.617 [DEBUG] [TestEventLogger]
{code}
> TestStatefulTask.testShouldStartAndRestore fails intermittently
> ---------------------------------------------------------------
>
> Key: SAMZA-224
> URL: https://issues.apache.org/jira/browse/SAMZA-224
> Project: Samza
> Issue Type: Bug
> Components: test
> Affects Versions: 0.6.0
> Reporter: Martin Kleppmann
> Fix For: 0.7.0
>
>
> [~closeuris] reported the following issue on SAMZA-185. I'm now
> intermittently seeing this problem too, so I'm opening a new issue for it (as
> I'm not sure the issue has anything to do with the Kafka 0.8.1 upgrade).
> {noformat}
> org.apache.samza.test.integration.TestStatefulTask >
> testShouldStartAndRestore FAILED
> java.lang.AssertionError at TestStatefulTask.scala:356
> 2 tests completed, 1 failed
> :samza-test_2.10:test FAILED
> {noformat}
> Logs provided by Yan (mine look similar):
> Failed tests: http://pastebin.com/3nEDw9jC
> Standard output: http://pastebin.com/20vZbk7c
> Standard error: http://pastebin.com/gU6cTNAr
--
This message was sent by Atlassian JIRA
(v6.2#6252)
