See <https://builds.apache.org/job/kafka-trunk-jdk7/3394/display/redirect?page=changes>
Changes: [wangguoz] KAFKA-6657: Add StreamsConfig prefix for different consumers (#4805) [wangguoz] HOTFIX: Simplify ConsoleConsumer stripWithPrefix function ------------------------------------------ [...truncated 426.76 KB...] java.lang.AssertionError: Found unexpected threads during @BeforeClass, allThreads=Set(ThrottledRequestReaper-Produce, Test worker-SendThread(127.0.0.1:36962), admin-client-network-thread, Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, kafka-request-handler-1, ThrottledRequestReaper-Request, group1_consumer1_watcher_executor, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 3, Test worker, /delegation_token/token_changes-event-process-thread, kafka-admin-client-thread | adminclient-56, group1_consumer1-leader-finder-thread, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Signal Dispatcher, main, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 2, ExpirationReaper-0-DeleteRecords, ThrottledRequestReaper-Fetch, kafka-consumer-scheduler-0, ZkClient-EventThread-67037-127.0.0.1:36962, /kafka-acl-changes-event-process-thread, ForkJoinPool-1-worker-5, Test worker-SendThread(127.0.0.1:45205), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Finalizer) kafka.controller.ControllerFailoverTest > classMethod STARTED kafka.controller.ControllerFailoverTest > classMethod FAILED java.lang.AssertionError: Found unexpected threads during @AfterClass, allThreads=Set(ThrottledRequestReaper-Produce, Test worker-SendThread(127.0.0.1:36962), admin-client-network-thread, Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, kafka-request-handler-1, ThrottledRequestReaper-Request, group1_consumer1_watcher_executor, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 3, Test worker, /delegation_token/token_changes-event-process-thread, kafka-admin-client-thread | adminclient-56, group1_consumer1-leader-finder-thread, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Signal Dispatcher, main, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 2, ExpirationReaper-0-DeleteRecords, ThrottledRequestReaper-Fetch, kafka-consumer-scheduler-0, ZkClient-EventThread-67037-127.0.0.1:36962, /kafka-acl-changes-event-process-thread, ForkJoinPool-1-worker-5, Test worker-SendThread(127.0.0.1:45205), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Finalizer) kafka.controller.PartitionStateMachineTest > testNonexistentPartitionToNewPartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testNonexistentPartitionToNewPartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransitionErrorCodeFromCreateStates STARTED kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransitionErrorCodeFromCreateStates PASSED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToNonexistentPartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToNonexistentPartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOfflineTransition STARTED kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOfflineTransition PASSED kafka.controller.PartitionStateMachineTest > testNewPartitionToOfflinePartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testNewPartitionToOfflinePartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testInvalidNonexistentPartitionToOnlinePartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testInvalidNonexistentPartitionToOnlinePartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testInvalidNonexistentPartitionToOfflinePartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testInvalidNonexistentPartitionToOfflinePartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransition STARTED kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransition PASSED kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransitionZkUtilsExceptionFromCreateStates STARTED kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransitionZkUtilsExceptionFromCreateStates PASSED kafka.controller.PartitionStateMachineTest > testInvalidNewPartitionToNonexistentPartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testInvalidNewPartitionToNonexistentPartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNewPartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNewPartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionErrorCodeFromStateLookup STARTED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionErrorCodeFromStateLookup PASSED kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransitionForControlledShutdown STARTED kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransitionForControlledShutdown PASSED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionZkUtilsExceptionFromStateLookup STARTED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionZkUtilsExceptionFromStateLookup PASSED kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNonexistentPartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNonexistentPartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testInvalidOfflinePartitionToNewPartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testInvalidOfflinePartitionToNewPartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransition PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrLive STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrLive PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionLastIsrShuttingDown STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionLastIsrShuttingDown PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElection STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElection PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaInIsrNotLive STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaInIsrNotLive PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithNoLiveIsr STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithNoLiveIsr PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElection STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElection PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElection STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElection PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElection STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElection PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithEmptyIsr STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithEmptyIsr PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionAllIsrSimultaneouslyShutdown STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionAllIsrSimultaneouslyShutdown PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionEnabled STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionEnabled PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrNotLive STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrNotLive PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionDisabled STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionDisabled PASSED kafka.producer.AsyncProducerTest > testFailedSendRetryLogic STARTED kafka.producer.AsyncProducerTest > testFailedSendRetryLogic PASSED kafka.producer.AsyncProducerTest > testQueueTimeExpired STARTED kafka.producer.AsyncProducerTest > testQueueTimeExpired PASSED kafka.producer.AsyncProducerTest > testPartitionAndCollateEvents STARTED kafka.producer.AsyncProducerTest > testPartitionAndCollateEvents PASSED kafka.producer.AsyncProducerTest > testBatchSize STARTED kafka.producer.AsyncProducerTest > testBatchSize PASSED kafka.producer.AsyncProducerTest > testSerializeEvents STARTED kafka.producer.AsyncProducerTest > testSerializeEvents PASSED kafka.producer.AsyncProducerTest > testProducerQueueSize STARTED kafka.producer.AsyncProducerTest > testProducerQueueSize PASSED kafka.producer.AsyncProducerTest > testRandomPartitioner STARTED kafka.producer.AsyncProducerTest > testRandomPartitioner PASSED kafka.producer.AsyncProducerTest > testInvalidConfiguration STARTED kafka.producer.AsyncProducerTest > testInvalidConfiguration PASSED kafka.producer.AsyncProducerTest > testInvalidPartition STARTED kafka.producer.AsyncProducerTest > testInvalidPartition PASSED kafka.producer.AsyncProducerTest > testNoBroker STARTED kafka.producer.AsyncProducerTest > testNoBroker PASSED kafka.producer.AsyncProducerTest > testProduceAfterClosed STARTED kafka.producer.AsyncProducerTest > testProduceAfterClosed PASSED kafka.producer.AsyncProducerTest > testJavaProducer STARTED kafka.producer.AsyncProducerTest > testJavaProducer PASSED kafka.producer.AsyncProducerTest > testIncompatibleEncoder STARTED kafka.producer.AsyncProducerTest > testIncompatibleEncoder PASSED kafka.producer.SyncProducerTest > classMethod STARTED kafka.producer.SyncProducerTest > classMethod FAILED java.lang.AssertionError: Found unexpected threads during @BeforeClass, allThreads=Set(ThrottledRequestReaper-Produce, Test worker-SendThread(127.0.0.1:36962), admin-client-network-thread, Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, kafka-request-handler-1, ThrottledRequestReaper-Request, group1_consumer1_watcher_executor, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 3, Test worker, /delegation_token/token_changes-event-process-thread, kafka-admin-client-thread | adminclient-56, group1_consumer1-leader-finder-thread, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Signal Dispatcher, main, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 2, ExpirationReaper-0-DeleteRecords, ThrottledRequestReaper-Fetch, kafka-consumer-scheduler-0, ZkClient-EventThread-67037-127.0.0.1:36962, /kafka-acl-changes-event-process-thread, ForkJoinPool-1-worker-5, Test worker-SendThread(127.0.0.1:45205), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Finalizer) kafka.producer.SyncProducerTest > classMethod STARTED kafka.producer.SyncProducerTest > classMethod FAILED java.lang.AssertionError: Found unexpected threads during @AfterClass, allThreads=Set(ThrottledRequestReaper-Produce, Test worker-SendThread(127.0.0.1:36962), admin-client-network-thread, Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, kafka-request-handler-1, ThrottledRequestReaper-Request, group1_consumer1_watcher_executor, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 3, Test worker, /delegation_token/token_changes-event-process-thread, kafka-admin-client-thread | adminclient-56, group1_consumer1-leader-finder-thread, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Signal Dispatcher, main, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 2, ExpirationReaper-0-DeleteRecords, ThrottledRequestReaper-Fetch, kafka-consumer-scheduler-0, ZkClient-EventThread-67037-127.0.0.1:36962, /kafka-acl-changes-event-process-thread, ForkJoinPool-1-worker-5, Test worker-SendThread(127.0.0.1:45205), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Finalizer) kafka.producer.ProducerTest > classMethod STARTED kafka.producer.ProducerTest > classMethod FAILED java.lang.AssertionError: Found unexpected threads during @BeforeClass, allThreads=Set(ThrottledRequestReaper-Produce, Test worker-SendThread(127.0.0.1:36962), admin-client-network-thread, Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, kafka-request-handler-1, ThrottledRequestReaper-Request, group1_consumer1_watcher_executor, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 3, Test worker, /delegation_token/token_changes-event-process-thread, kafka-admin-client-thread | adminclient-56, group1_consumer1-leader-finder-thread, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Signal Dispatcher, main, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 2, ExpirationReaper-0-DeleteRecords, ThrottledRequestReaper-Fetch, kafka-consumer-scheduler-0, ZkClient-EventThread-67037-127.0.0.1:36962, /kafka-acl-changes-event-process-thread, ForkJoinPool-1-worker-5, Test worker-SendThread(127.0.0.1:45205), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Finalizer) kafka.producer.ProducerTest > classMethod STARTED kafka.producer.ProducerTest > classMethod FAILED java.lang.AssertionError: Found unexpected threads during @AfterClass, allThreads=Set(ThrottledRequestReaper-Produce, Test worker-SendThread(127.0.0.1:36962), admin-client-network-thread, Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, kafka-request-handler-1, ThrottledRequestReaper-Request, group1_consumer1_watcher_executor, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 3, Test worker, /delegation_token/token_changes-event-process-thread, kafka-admin-client-thread | adminclient-56, group1_consumer1-leader-finder-thread, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Signal Dispatcher, main, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 2, ExpirationReaper-0-DeleteRecords, ThrottledRequestReaper-Fetch, kafka-consumer-scheduler-0, ZkClient-EventThread-67037-127.0.0.1:36962, /kafka-acl-changes-event-process-thread, ForkJoinPool-1-worker-5, Test worker-SendThread(127.0.0.1:45205), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Finalizer) unit.kafka.admin.DeleteConsumerGroupTest > classMethod STARTED unit.kafka.admin.DeleteConsumerGroupTest > classMethod FAILED java.lang.AssertionError: Found unexpected threads during @BeforeClass, allThreads=Set(ThrottledRequestReaper-Produce, Test worker-SendThread(127.0.0.1:36962), admin-client-network-thread, Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, kafka-request-handler-1, ThrottledRequestReaper-Request, group1_consumer1_watcher_executor, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 3, Test worker, /delegation_token/token_changes-event-process-thread, kafka-admin-client-thread | adminclient-56, group1_consumer1-leader-finder-thread, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Signal Dispatcher, main, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 2, ExpirationReaper-0-DeleteRecords, ThrottledRequestReaper-Fetch, kafka-consumer-scheduler-0, ZkClient-EventThread-67037-127.0.0.1:36962, /kafka-acl-changes-event-process-thread, ForkJoinPool-1-worker-5, Test worker-SendThread(127.0.0.1:45205), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Finalizer) unit.kafka.admin.DeleteConsumerGroupTest > classMethod STARTED unit.kafka.admin.DeleteConsumerGroupTest > classMethod FAILED java.lang.AssertionError: Found unexpected threads during @AfterClass, allThreads=Set(ThrottledRequestReaper-Produce, Test worker-SendThread(127.0.0.1:36962), admin-client-network-thread, Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, kafka-request-handler-1, ThrottledRequestReaper-Request, group1_consumer1_watcher_executor, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 3, Test worker, /delegation_token/token_changes-event-process-thread, kafka-admin-client-thread | adminclient-56, group1_consumer1-leader-finder-thread, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Signal Dispatcher, main, /0:0:0:0:0:0:0:1:40430 to /0:0:0:0:0:0:0:1:46482 workers Thread 2, ExpirationReaper-0-DeleteRecords, ThrottledRequestReaper-Fetch, kafka-consumer-scheduler-0, ZkClient-EventThread-67037-127.0.0.1:36962, /kafka-acl-changes-event-process-thread, ForkJoinPool-1-worker-5, Test worker-SendThread(127.0.0.1:45205), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Finalizer) 1763 tests completed, 47 failed, 5 skipped :kafka-trunk-jdk7:core:test FAILED :test_core_2_11 FAILED FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':kafka-trunk-jdk7:core:test'. > There were failing tests. See the report at: > file://<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/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 Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0. See https://docs.gradle.org/4.5.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 1h 36m 36s 24 actionable tasks: 2 executed, 22 up-to-date Build step 'Execute shell' marked build as failure [FINDBUGS] Collecting findbugs analysis files... Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 [FINDBUGS] Searching for all files in <https://builds.apache.org/job/kafka-trunk-jdk7/ws/> that match the pattern **/build/reports/findbugs/*.xml [FINDBUGS] Parsing 1 file in <https://builds.apache.org/job/kafka-trunk-jdk7/ws/> [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 <Git Blamer> Using GitBlamer to create author and commit information for all warnings. <Git Blamer> GIT_COMMIT=a7746dd5b4d1eb529433b33be65aa2decd99a737, workspace=<https://builds.apache.org/job/kafka-trunk-jdk7/ws/> [FINDBUGS] Computing warning deltas based on reference build #3392 Recording test results Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 Not sending mail to unregistered user git...@alasdairhodge.co.uk Not sending mail to unregistered user wangg...@gmail.com