See <https://builds.apache.org/job/kafka-trunk-jdk8/895/changes>
Changes:
[wangguoz] HOTFIX: logic in
QuerybaleStateIntegrationTest.shouldBeAbleToQueryState
[wangguoz] KAFKA-4175: Can't have StandbyTasks in KafkaStreams where
[wangguoz] KAFKA-4163: NPE in StreamsMetadataState during re-balance operations
------------------------------------------
[...truncated 13351 lines...]
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testRestore PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testPutGetRange STARTED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testPutGetRange PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testPutGetRangeWithDefaultSerdes STARTED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testPutGetRangeWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest
> shouldPeekNext STARTED
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest
> shouldPeekNext PASSED
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest
> shouldPeekAndIterate STARTED
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest
> shouldPeekAndIterate PASSED
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest
> shouldThrowNoSuchElementWhenNoMoreItemsLeftAndPeekNextCalled STARTED
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest
> shouldThrowNoSuchElementWhenNoMoreItemsLeftAndPeekNextCalled PASSED
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest
> shouldThrowNoSuchElementWhenNoMoreItemsLeftAndNextCalled STARTED
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest
> shouldThrowNoSuchElementWhenNoMoreItemsLeftAndNextCalled PASSED
org.apache.kafka.streams.state.internals.MergedSortedCacheWindowStoreIteratorTest
> shouldIterateOverValueFromBothIterators STARTED
org.apache.kafka.streams.state.internals.MergedSortedCacheWindowStoreIteratorTest
> shouldIterateOverValueFromBothIterators PASSED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldReturnEmptyListIfNoStoresFoundWithName STARTED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldReturnEmptyListIfNoStoresFoundWithName PASSED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldThrowInvalidStoreExceptionIfKVStoreClosed STARTED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldThrowInvalidStoreExceptionIfKVStoreClosed PASSED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldThrowInvalidStoreExceptionIfNotAllStoresAvailable STARTED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldThrowInvalidStoreExceptionIfNotAllStoresAvailable PASSED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldFindWindowStores STARTED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldFindWindowStores PASSED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldReturnEmptyListIfStoreExistsButIsNotOfTypeValueStore STARTED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldReturnEmptyListIfStoreExistsButIsNotOfTypeValueStore PASSED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldFindKeyValueStores STARTED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldFindKeyValueStores PASSED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldThrowInvalidStoreExceptionIfWindowStoreClosed STARTED
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest >
shouldThrowInvalidStoreExceptionIfWindowStoreClosed PASSED
org.apache.kafka.streams.state.StoresTest >
shouldCreateInMemoryStoreSupplierWithLoggedConfig STARTED
org.apache.kafka.streams.state.StoresTest >
shouldCreateInMemoryStoreSupplierWithLoggedConfig PASSED
org.apache.kafka.streams.state.StoresTest >
shouldCreatePersistenStoreSupplierNotLogged STARTED
org.apache.kafka.streams.state.StoresTest >
shouldCreatePersistenStoreSupplierNotLogged PASSED
org.apache.kafka.streams.state.StoresTest >
shouldCreatePersistenStoreSupplierWithLoggedConfig STARTED
org.apache.kafka.streams.state.StoresTest >
shouldCreatePersistenStoreSupplierWithLoggedConfig PASSED
org.apache.kafka.streams.state.StoresTest >
shouldCreateInMemoryStoreSupplierNotLogged STARTED
org.apache.kafka.streams.state.StoresTest >
shouldCreateInMemoryStoreSupplierNotLogged PASSED
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldReduce STARTED
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldReduce PASSED
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldReduceWindowed STARTED
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldReduceWindowed PASSED
org.apache.kafka.streams.integration.InternalTopicIntegrationTest >
shouldCompactTopicsForStateChangelogs STARTED
org.apache.kafka.streams.integration.InternalTopicIntegrationTest >
shouldCompactTopicsForStateChangelogs PASSED
org.apache.kafka.streams.integration.InternalTopicIntegrationTest >
shouldUseCompactAndDeleteForWindowStoreChangelogs STARTED
org.apache.kafka.streams.integration.InternalTopicIntegrationTest >
shouldUseCompactAndDeleteForWindowStoreChangelogs PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduce[0] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduce[0] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregate[0] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregate[0] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCount[0] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCount[0] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldGroupByKey[0] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldGroupByKey[0] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduceWindowed[0] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduceWindowed[0] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregateWindowed[0] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregateWindowed[0] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduce[1] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduce[1] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregate[1] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregate[1] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCount[1] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCount[1] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldGroupByKey[1] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldGroupByKey[1] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduceWindowed[1] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduceWindowed[1] PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregateWindowed[1] STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregateWindowed[1] PASSED
org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest >
shouldCountClicksPerRegion[0] STARTED
org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest >
shouldCountClicksPerRegion[0] PASSED
org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest >
shouldCountClicksPerRegion[1] STARTED
org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest >
shouldCountClicksPerRegion[1] PASSED
org.apache.kafka.streams.integration.FanoutIntegrationTest >
shouldFanoutTheInput[0] STARTED
org.apache.kafka.streams.integration.FanoutIntegrationTest >
shouldFanoutTheInput[0] PASSED
org.apache.kafka.streams.integration.FanoutIntegrationTest >
shouldFanoutTheInput[1] STARTED
org.apache.kafka.streams.integration.FanoutIntegrationTest >
shouldFanoutTheInput[1] PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryState[0] STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryState[0] PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldNotMakeStoreAvailableUntilAllStoresAvailable[0] STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldNotMakeStoreAvailableUntilAllStoresAvailable[0] PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
queryOnRebalance[0] STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
queryOnRebalance[0] FAILED
java.lang.AssertionError: Condition not met within timeout 30000. waiting
for metadata, store and value to be non null
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276)
at
org.apache.kafka.streams.integration.QueryableStateIntegrationTest.verifyAllKVKeys(QueryableStateIntegrationTest.java:263)
at
org.apache.kafka.streams.integration.QueryableStateIntegrationTest.queryOnRebalance(QueryableStateIntegrationTest.java:342)
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
concurrentAccesses[0] STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
concurrentAccesses[0] PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryState[1] STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryState[1] PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldNotMakeStoreAvailableUntilAllStoresAvailable[1] STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldNotMakeStoreAvailableUntilAllStoresAvailable[1] PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
queryOnRebalance[1] STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
queryOnRebalance[1] PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
concurrentAccesses[1] STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
concurrentAccesses[1] PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterReset STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterReset FAILED
java.lang.AssertionError: Condition not met within timeout 30000. Did not
receive 10 number of records
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:211)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:180)
at
org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset(ResetIntegrationTest.java:120)
org.apache.kafka.streams.integration.KStreamRepartitionJoinTest >
shouldCorrectlyRepartitionOnJoinOperations[0] STARTED
ERROR: Could not install GRADLE_2_4_RC_2_HOME
java.lang.NullPointerException
org.apache.kafka.streams.integration.KStreamRepartitionJoinTest >
shouldCorrectlyRepartitionOnJoinOperations[0] PASSED
org.apache.kafka.streams.integration.KStreamRepartitionJoinTest >
shouldCorrectlyRepartitionOnJoinOperations[1] STARTED
org.apache.kafka.streams.integration.KStreamRepartitionJoinTest >
shouldCorrectlyRepartitionOnJoinOperations[1] PASSED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testShouldReadFromRegexAndNamedTopics STARTED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testShouldReadFromRegexAndNamedTopics PASSED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testRegexMatchesTopicsAWhenCreated STARTED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testRegexMatchesTopicsAWhenCreated PASSED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testMultipleConsumersCanReadFromPartitionedTopic STARTED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testMultipleConsumersCanReadFromPartitionedTopic PASSED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testRegexMatchesTopicsAWhenDeleted STARTED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testRegexMatchesTopicsAWhenDeleted PASSED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testNoMessagesSentExceptionFromOverlappingPatterns STARTED
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
testNoMessagesSentExceptionFromOverlappingPatterns PASSED
460 tests completed, 2 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.
BUILD FAILED
Total time: 2 hrs 49 mins 54.904 secs
Build step 'Execute shell' marked build as failure
Recording test results
Setting
GRADLE_2_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_2.4-rc-2
Setting
GRADLE_2_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_2.4-rc-2
