See <https://builds.apache.org/job/kafka-1.0-jdk7/263/display/redirect?page=changes>
Changes: [bill] KAFKA-8011: Fix for race condition causing concurrent modification ------------------------------------------ [...truncated 1.86 MB...] org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullStateStoreNameWhenConnectingProcessorAndStateStores STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullStateStoreNameWhenConnectingProcessorAndStateStores PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddTimestampExtractorPerSource STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddTimestampExtractorPerSource PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testPatternSourceTopic STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testPatternSourceTopic PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAssociateStateStoreNameWhenStateStoreSupplierIsExternal STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAssociateStateStoreNameWhenStateStoreSupplierIsExternal PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkWithWrongParent STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkWithWrongParent PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testPatternMatchesAlreadyProvidedTopicSource STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testPatternMatchesAlreadyProvidedTopicSource PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkConnectedWithMultipleParent STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkConnectedWithMultipleParent PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testSubscribeTopicNameAndPattern STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testSubscribeTopicNameAndPattern PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddPatternSourceWithoutOffsetReset STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddPatternSourceWithoutOffsetReset PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAddNullInternalTopic STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAddNullInternalTopic PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddProcessorWithWrongParent STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddProcessorWithWrongParent PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullNameWhenAddingProcessor STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullNameWhenAddingProcessor PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddSourcePatternWithOffsetReset STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddSourcePatternWithOffsetReset PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStore STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStore PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkConnectedWithParent STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkConnectedWithParent PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStoreWithNonExistingProcessor STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStoreWithNonExistingProcessor PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddInternalTopicConfigWithCleanupPolicyDeleteForInternalTopics STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddInternalTopicConfigWithCleanupPolicyDeleteForInternalTopics PASSED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldCorrectlyMapStateStoreToInternalTopics STARTED org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldCorrectlyMapStateStoreToInternalTopics PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > testTimeTracking STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > testTimeTracking PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldNotFlushOffsetsWhenFlushIntervalHasNotLapsed STARTED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldNotFlushOffsetsWhenFlushIntervalHasNotLapsed PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldNotFlushWhenFlushIntervalIsZero STARTED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldNotFlushWhenFlushIntervalIsZero PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldUpdateStateWithReceivedRecordsForPartition STARTED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldUpdateStateWithReceivedRecordsForPartition PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldSeekToInitialOffsets STARTED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldSeekToInitialOffsets PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldCloseConsumer STARTED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldCloseConsumer PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldFlushStoreWhenFlushIntervalHasLapsed STARTED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldFlushStoreWhenFlushIntervalHasLapsed PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldUpdateStateWithReceivedRecordsForAllTopicPartition STARTED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldUpdateStateWithReceivedRecordsForAllTopicPartition PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldAssignPartitionsToConsumer STARTED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldAssignPartitionsToConsumer PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldCloseStateMaintainer STARTED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldCloseStateMaintainer PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseTaskAsZombieAndRemoveFromActiveTasksIfProducerGotFencedAtBeginTransactionWhenTaskIsResumed STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseTaskAsZombieAndRemoveFromActiveTasksIfProducerGotFencedAtBeginTransactionWhenTaskIsResumed PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldReturnStandbyTaskMetadataWhileRunningState STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldReturnStandbyTaskMetadataWhileRunningState PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotNullPointerWhenStandbyTasksAssignedAndNoStateStoresForTopology STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotNullPointerWhenStandbyTasksAssignedAndNoStateStoresForTopology PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldInjectSharedProducerForAllTasksUsingClientSupplierOnCreateIfEosDisabled STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldInjectSharedProducerForAllTasksUsingClientSupplierOnCreateIfEosDisabled PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCommitAfterTheCommitInterval STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCommitAfterTheCommitInterval PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldInjectProducerPerTaskUsingClientSupplierOnCreateIfEosEnable STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldInjectProducerPerTaskUsingClientSupplierOnCreateIfEosEnable PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testPartitionAssignmentChangeForMultipleGroups STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > testPartitionAssignmentChangeForMultipleGroups PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotCommitBeforeTheCommitInterval STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotCommitBeforeTheCommitInterval PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotCauseExceptionIfNothingCommited STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotCauseExceptionIfNothingCommited PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testHandingOverTaskFromOneToAnotherThread STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > testHandingOverTaskFromOneToAnotherThread PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testStateChangeStartClose STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > testStateChangeStartClose PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseAllTaskProducersOnCloseIfEosEnabled STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseAllTaskProducersOnCloseIfEosEnabled PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldReturnActiveTaskMetadataWhileRunningState STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldReturnActiveTaskMetadataWhileRunningState PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldShutdownTaskManagerOnClose STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldShutdownTaskManagerOnClose PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testMetrics STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > testMetrics PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseSuspendedTasksThatAreNoLongerAssignedToThisStreamThreadBeforeCreatingNewTasks STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseSuspendedTasksThatAreNoLongerAssignedToThisStreamThreadBeforeCreatingNewTasks PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testPartitionAssignmentChangeForSingleGroup STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > testPartitionAssignmentChangeForSingleGroup PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldAlwaysReturnEmptyTasksMetadataWhileRebalancingStateAndTasksNotRunning STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldAlwaysReturnEmptyTasksMetadataWhileRebalancingStateAndTasksNotRunning PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldAlwaysUpdateWithLatestTopicsFromStreamPartitionAssignor STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldAlwaysUpdateWithLatestTopicsFromStreamPartitionAssignor PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseTaskAsZombieAndRemoveFromActiveTasksIfProducerWasFencedWhileProcessing STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseTaskAsZombieAndRemoveFromActiveTasksIfProducerWasFencedWhileProcessing PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldAlwaysUpdateTasksMetadataAfterChangingState STARTED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldAlwaysUpdateTasksMetadataAfterChangingState PASSED org.apache.kafka.streams.processor.internals.WrappedBatchingStateRestoreCallbackTest > shouldRestoreSinglePutsFromArray STARTED org.apache.kafka.streams.processor.internals.WrappedBatchingStateRestoreCallbackTest > shouldRestoreSinglePutsFromArray PASSED org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > logAndSkipOnInvalidTimestamp STARTED org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > logAndSkipOnInvalidTimestamp PASSED org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > extractMetadataTimestamp STARTED org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > extractMetadataTimestamp PASSED 1818 tests completed, 1 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-1.0-jdk7/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 Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0. See https://docs.gradle.org/4.8.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 1h 45m 32s 56 actionable tasks: 31 executed, 25 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-1.0-jdk7/ws/> that match the pattern **/build/reports/findbugs/*.xml [FINDBUGS] Parsing 5 files in <https://builds.apache.org/job/kafka-1.0-jdk7/ws/> [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-1.0-jdk7/ws/clients/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-1.0-jdk7/ws/core/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-1.0-jdk7/ws/examples/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-1.0-jdk7/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-1.0-jdk7/ws/streams/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 No credentials specified 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=7ef21e7fab2ea8c93fce04ee6112655c561d3f71, workspace=<https://builds.apache.org/job/kafka-1.0-jdk7/ws/> [FINDBUGS] Computing warning deltas based on reference build #262 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 b...@confluent.io
