See
<https://builds.apache.org/job/kafka-2.0-jdk8/83/display/redirect?page=changes>
Changes:
[jason] KAFKA-6897; Prevent KafkaProducer.send from blocking when producer is
------------------------------------------
[...truncated 2.48 MB...]
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testInner[caching enabled = false] STARTED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testOuter[caching enabled = false] STARTED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testOuter[caching enabled = false] PASSED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testMultiInner[caching enabled = false] STARTED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testMultiInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testLeftRepartitioned[caching enabled = false] STARTED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testLeftRepartitioned[caching enabled = false] PASSED
org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest >
shouldRestoreAndProgressWhenTopicNotWrittenToDuringRestoration STARTED
org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest >
shouldRestoreAndProgressWhenTopicNotWrittenToDuringRestoration PASSED
org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest >
shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled
STARTED
org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest >
shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled PASSED
org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest >
shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosDisabled
STARTED
org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest >
shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosDisabled
PASSED
org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest >
testInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest >
testInner[caching enabled = true] PASSED
org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest >
testLeft[caching enabled = true] STARTED
org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest >
testLeft[caching enabled = true] PASSED
org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest >
testInner[caching enabled = false] STARTED
org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest >
testInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest >
testLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest >
testLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
shouldNotAllowToResetWhenInputTopicAbsent STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
shouldNotAllowToResetWhenInputTopicAbsent PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
shouldNotAllowToResetWhenIntermediateTopicAbsent STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
shouldNotAllowToResetWhenIntermediateTopicAbsent PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingByDurationAfterResetWithoutIntermediateUserTopic STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingByDurationAfterResetWithoutIntermediateUserTopic PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterResetWithIntermediateUserTopic STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterResetWithIntermediateUserTopic PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromFileAfterResetWithoutIntermediateUserTopic STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromFileAfterResetWithoutIntermediateUserTopic PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromDateTimeAfterResetWithoutIntermediateUserTopic STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromDateTimeAfterResetWithoutIntermediateUserTopic PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
shouldNotAllowToResetWhileStreamsRunning STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
shouldNotAllowToResetWhileStreamsRunning PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftInner[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftOuter[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftOuter[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftLeft[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftLeft[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterLeft[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterLeft[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInner[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuter[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuter[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeft[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeft[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerInner[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerOuter[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerOuter[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerLeft[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerLeft[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterInner[caching enabled = true] FAILED
kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for
connection while in state: CONNECTING
at
kafka.zookeeper.ZooKeeperClient$$anonfun$kafka$zookeeper$ZooKeeperClient$$waitUntilConnected$1.apply$mcV$sp(ZooKeeperClient.scala:225)
at
kafka.zookeeper.ZooKeeperClient$$anonfun$kafka$zookeeper$ZooKeeperClient$$waitUntilConnected$1.apply(ZooKeeperClient.scala:221)
at
kafka.zookeeper.ZooKeeperClient$$anonfun$kafka$zookeeper$ZooKeeperClient$$waitUntilConnected$1.apply(ZooKeeperClient.scala:221)
at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251)
at
kafka.zookeeper.ZooKeeperClient.kafka$zookeeper$ZooKeeperClient$$waitUntilConnected(ZooKeeperClient.scala:221)
at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:95)
at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1580)
at kafka.zk.KafkaZkClient.apply(KafkaZkClient.scala)
at
org.apache.kafka.streams.integration.utils.KafkaEmbedded.createZkClient(KafkaEmbedded.java:181)
at
org.apache.kafka.streams.integration.utils.KafkaEmbedded.createTopic(KafkaEmbedded.java:174)
at
org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.createTopic(EmbeddedKafkaCluster.java:205)
at
org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.createTopics(EmbeddedKafkaCluster.java:169)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.prepareEnvironment(AbstractJoinIntegrationTest.java:154)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.prepareTopology(TableTableJoinIntegrationTest.java:53)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterOuter[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterOuter[caching enabled = true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftInner[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftOuter[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftOuter[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInner[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuter[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuter[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerInner[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerOuter[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerOuter[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterInner[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterOuter[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterOuter[caching enabled = false] PASSED
org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest >
shouldKStreamGlobalKTableLeftJoin STARTED
org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest >
shouldKStreamGlobalKTableLeftJoin PASSED
org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest >
shouldNotRestoreAbortedMessages STARTED
org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest >
shouldNotRestoreAbortedMessages PASSED
org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest >
shouldRestoreTransactionalMessages STARTED
org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest >
shouldRestoreTransactionalMessages PASSED
org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest >
shouldKStreamGlobalKTableJoin STARTED
org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest >
shouldKStreamGlobalKTableJoin PASSED
1884 tests completed, 8 failed
> Task :streams:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
BUILD FAILED in 2h 37m 24s
68 actionable tasks: 28 executed, 40 up-to-date
Build step 'Execute shell' marked build as failure
[FINDBUGS] Collecting findbugs analysis files...
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
[FINDBUGS] Searching for all files in
<https://builds.apache.org/job/kafka-2.0-jdk8/ws/> that match the pattern
**/build/reports/findbugs/*.xml
[FINDBUGS] Parsing 6 files in <https://builds.apache.org/job/kafka-2.0-jdk8/ws/>
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-2.0-jdk8/ws/clients/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-2.0-jdk8/ws/core/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-2.0-jdk8/ws/examples/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-2.0-jdk8/ws/log4j-appender/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/streams-scala/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
<Git Blamer> Using GitBlamer to create author and commit information for all
warnings.
<Git Blamer> GIT_COMMIT=1b16888d462d91a81e130182c8c93552c65d7385,
workspace=<https://builds.apache.org/job/kafka-2.0-jdk8/ws/>
[FINDBUGS] Computing warning deltas based on reference build #72
Recording test results
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Not sending mail to unregistered user lindon...@gmail.com
Not sending mail to unregistered user wangg...@apache.org
Not sending mail to unregistered user nore...@github.com
Not sending mail to unregistered user ism...@juma.me.uk
Not sending mail to unregistered user rajinisiva...@apache.org
