See <https://builds.apache.org/job/kafka-trunk-jdk8/2306/display/redirect?page=changes>
Changes: [wangguoz] KAFKA-6391 ensure topics are created with correct partitions BEFORE [wangguoz] KAFKA-6318: StreamsResetter should return non-zero return code on error [wangguoz] MINOR: refactored code duplicates in several files (Streams project) [wangguoz] Revert "KAFKA-6383: complete shutdown for CREATED StreamThreads (#4343)" ------------------------------------------ [...truncated 1.82 MB...] org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullStoreSupplierInLeftJoin STARTED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullStoreSupplierInLeftJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullActionOnForEach STARTED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullActionOnForEach PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnFilterWhenMaterializedIsNull STARTED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnFilterWhenMaterializedIsNull PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > testKTable STARTED org.apache.kafka.streams.kstream.internals.KTableImplTest > testKTable PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullPredicateOnFilterNot STARTED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullPredicateOnFilterNot PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldAllowNullStoreInThrough STARTED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldAllowNullStoreInThrough PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > testValueGetter STARTED org.apache.kafka.streams.kstream.internals.KTableImplTest > testValueGetter PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullFilePathOnWriteAsText STARTED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullFilePathOnWriteAsText PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldAllowNullTopicInThrough STARTED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldAllowNullTopicInThrough PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldRemoveMergedSessionsFromStateStore STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldRemoveMergedSessionsFromStateStore PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldMergeSessions STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldMergeSessions PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHandleMultipleSessionsAndMerging STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHandleMultipleSessionsAndMerging PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardNewSessionWhenNonCachedStore STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardNewSessionWhenNonCachedStore PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldGetAggregatedValuesFromValueGetter STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldGetAggregatedValuesFromValueGetter PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardRemovedSessionsWhenMerging STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardRemovedSessionsWhenMerging PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldUpdateSessionIfTheSameTime STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldUpdateSessionIfTheSameTime PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHaveMultipleSessionsForSameIdWhenTimestampApartBySessionGap STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHaveMultipleSessionsForSameIdWhenTimestampApartBySessionGap PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldCreateSingleSessionWhenWithinGap STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldCreateSingleSessionWhenWithinGap PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddRegexTopicToLatestAutoOffsetResetList STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddRegexTopicToLatestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldMapStateStoresToCorrectSourceTopics STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldMapStateStoresToCorrectSourceTopics PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddTableToEarliestAutoOffsetResetList STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddTableToEarliestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldHaveNullTimestampExtractorWhenNoneSupplied STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldHaveNullTimestampExtractorWhenNoneSupplied PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldBuildGlobalTopologyWithAllGlobalTables STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldBuildGlobalTopologyWithAllGlobalTables PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddRegexTopicToEarliestAutoOffsetResetList STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddRegexTopicToEarliestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddTopicToEarliestAutoOffsetResetList STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddTopicToEarliestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldHaveCorrectSourceTopicsForTableFromMergedStream STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldHaveCorrectSourceTopicsForTableFromMergedStream PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > testNewStoreName STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > testNewStoreName PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddTopicToLatestAutoOffsetResetList STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddTopicToLatestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldBuildSimpleGlobalTableTopology STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldBuildSimpleGlobalTableTopology PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddTableToLatestAutoOffsetResetList STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddTableToLatestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldNotAddTableToOffsetResetLists STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldNotAddTableToOffsetResetLists PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddGlobalTablesToEachGroup STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldAddGlobalTablesToEachGroup PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldNotAddRegexTopicsToOffsetResetLists STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldNotAddRegexTopicsToOffsetResetLists PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > ktableShouldHaveNullTimestampExtractorWhenNoneSupplied STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > ktableShouldHaveNullTimestampExtractorWhenNoneSupplied PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > testNewName STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > testNewName PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > ktableShouldUseProvidedTimestampExtractor STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > ktableShouldUseProvidedTimestampExtractor PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldStillMaterializeSourceKTableIfMaterializedIsntQueryable STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldStillMaterializeSourceKTableIfMaterializedIsntQueryable PASSED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldUseProvidedTimestampExtractor STARTED org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest > shouldUseProvidedTimestampExtractor PASSED org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testFilterNot STARTED org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testFilterNot PASSED org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testTypeVariance STARTED org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testTypeVariance PASSED org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testFilter STARTED org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testFilter PASSED org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest > testSelectKey STARTED org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest > testSelectKey PASSED org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest > testTypeVariance STARTED org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest > testTypeVariance PASSED org.apache.kafka.streams.StreamsBuilderTest > testMerge STARTED org.apache.kafka.streams.StreamsBuilderTest > testMerge PASSED org.apache.kafka.streams.StreamsBuilderTest > testFrom STARTED org.apache.kafka.streams.StreamsBuilderTest > testFrom PASSED org.apache.kafka.streams.StreamsBuilderTest > shouldUseSerdesDefinedInMaterializedToConsumeGlobalTable STARTED org.apache.kafka.streams.StreamsBuilderTest > shouldUseSerdesDefinedInMaterializedToConsumeGlobalTable PASSED org.apache.kafka.streams.StreamsBuilderTest > shouldUseSerdesDefinedInMaterializedToConsumeTable STARTED org.apache.kafka.streams.StreamsBuilderTest > shouldUseSerdesDefinedInMaterializedToConsumeTable PASSED org.apache.kafka.streams.StreamsBuilderTest > shouldThrowExceptionWhenTopicNamesAreNull STARTED org.apache.kafka.streams.StreamsBuilderTest > shouldThrowExceptionWhenTopicNamesAreNull PASSED org.apache.kafka.streams.StreamsBuilderTest > shouldThrowExceptionWhenNoTopicPresent STARTED org.apache.kafka.streams.StreamsBuilderTest > shouldThrowExceptionWhenNoTopicPresent PASSED org.apache.kafka.streams.StreamsBuilderTest > shouldUseDefaultNodeAndStoreNames STARTED org.apache.kafka.streams.StreamsBuilderTest > shouldUseDefaultNodeAndStoreNames PASSED org.apache.kafka.streams.StreamsBuilderTest > shouldProcessingFromSinkTopic STARTED org.apache.kafka.streams.StreamsBuilderTest > shouldProcessingFromSinkTopic PASSED org.apache.kafka.streams.StreamsBuilderTest > shouldProcessViaThroughTopic STARTED org.apache.kafka.streams.StreamsBuilderTest > shouldProcessViaThroughTopic PASSED 1812 tests completed, 1 failed :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-trunk-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 1h 18m 45s 52 actionable tasks: 32 executed, 20 up-to-date Build step 'Execute shell' marked build as failure [FINDBUGS] Collecting findbugs analysis files... ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 [FINDBUGS] Searching for all files in <https://builds.apache.org/job/kafka-trunk-jdk8/ws/> that match the pattern **/build/reports/findbugs/*.xml [FINDBUGS] Parsing 5 files in <https://builds.apache.org/job/kafka-trunk-jdk8/ws/> [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-trunk-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-trunk-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-trunk-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-trunk-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-trunk-jdk8/ws/streams/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 ERROR: No tool found matching GRADLE_3_4_RC_2_HOME 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=2119e9f26ed988746ee22d139d1eb1aca2bbb950, workspace=<https://builds.apache.org/job/kafka-trunk-jdk8/ws/> [FINDBUGS] Computing warning deltas based on reference build #2304 Recording test results ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 Not sending mail to unregistered user wangg...@gmail.com
