See <https://builds.apache.org/job/kafka-0.10.1-jdk7/17/changes>
Changes:
[jason] MINOR: Remove no longer required --new-consumer switch in docs
[wangguoz] HOTFIX: fix npe in StreamsMetadataState when onChange has not been
[wangguoz] MINOR: fixes a few error logging formats
[wangguoz] MINOR: add test to make sure ProcessorStateManager can handle State
------------------------------------------
[...truncated 12923 lines...]
org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldPeekNextKey
STARTED
org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldPeekNextKey
PASSED
org.apache.kafka.streams.state.internals.ThreadCacheTest >
shouldNotFlushCleanEntriesForNamespace STARTED
org.apache.kafka.streams.state.internals.ThreadCacheTest >
shouldNotFlushCleanEntriesForNamespace PASSED
org.apache.kafka.streams.state.internals.ThreadCacheTest >
shouldEvictImmediatelyIfCacheSizeIsVerySmall STARTED
org.apache.kafka.streams.state.internals.ThreadCacheTest >
shouldEvictImmediatelyIfCacheSizeIsVerySmall PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > testSize
STARTED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > testSize
PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testPutIfAbsent STARTED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testPutIfAbsent PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testRestoreWithDefaultSerdes STARTED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testRestoreWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testRestore STARTED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testRestore PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testPutGetRange STARTED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testPutGetRange PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testPutGetRangeWithDefaultSerdes STARTED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testPutGetRangeWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.WrappingStoreProviderTest >
shouldThrowInvalidStoreExceptionIfNoStoreOfTypeFound STARTED
org.apache.kafka.streams.state.internals.WrappingStoreProviderTest >
shouldThrowInvalidStoreExceptionIfNoStoreOfTypeFound PASSED
org.apache.kafka.streams.state.internals.WrappingStoreProviderTest >
shouldFindWindowStores STARTED
org.apache.kafka.streams.state.internals.WrappingStoreProviderTest >
shouldFindWindowStores PASSED
org.apache.kafka.streams.state.internals.WrappingStoreProviderTest >
shouldFindKeyValueStores STARTED
org.apache.kafka.streams.state.internals.WrappingStoreProviderTest >
shouldFindKeyValueStores PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldThrowExceptionIfWindowStoreDoesntExist STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldThrowExceptionIfWindowStoreDoesntExist PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldThrowExceptionWhenLookingForWindowStoreWithDifferentType STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldThrowExceptionWhenLookingForWindowStoreWithDifferentType PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldReturnKVStoreWhenItExists STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldReturnKVStoreWhenItExists PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldThrowExceptionWhenLookingForKVStoreWithDifferentType STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldThrowExceptionWhenLookingForKVStoreWithDifferentType PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldReturnWindowStoreWhenItExists STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldReturnWindowStoreWhenItExists PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldThrowExceptionIfKVStoreDoesntExist STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldThrowExceptionIfKVStoreDoesntExist PASSED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldIterateAllStoredItems STARTED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldIterateAllStoredItems PASSED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldIterateOverRange STARTED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldIterateOverRange PASSED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldForwardDirtyItemsWhenFlushCalled STARTED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldForwardDirtyItemsWhenFlushCalled PASSED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldFlushEvictedItemsIntoUnderlyingStore STARTED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldFlushEvictedItemsIntoUnderlyingStore PASSED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldPutGetToFromCache STARTED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldPutGetToFromCache PASSED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldForwardOldValuesWhenEnabled STARTED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldForwardOldValuesWhenEnabled PASSED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldForwardDirtyItemToListenerWhenEvicted STARTED
org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest >
shouldForwardDirtyItemToListenerWhenEvicted PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldEvictEldestEntry STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldEvictEldestEntry PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldDeleteAndUpdateSize STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldDeleteAndUpdateSize PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldPutAll STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldPutAll PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldPutGet STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldPutGet PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldGetIteratorOverAllKeys STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldGetIteratorOverAllKeys PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldKeepTrackOfMostRecentlyAndLeastRecentlyUsed STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldKeepTrackOfMostRecentlyAndLeastRecentlyUsed PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldGetRangeIteratorOverKeys STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldGetRangeIteratorOverKeys PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldFlushDirtEntriesOnEviction STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest >
shouldFlushDirtEntriesOnEviction PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldPutIfAbsent
STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldPutIfAbsent
PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldOverwriteAll
STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldOverwriteAll
PASSED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldKeepTrackOfSize
STARTED
org.apache.kafka.streams.state.internals.NamedCacheTest > shouldKeepTrackOfSize
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.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.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.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.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.KStreamRepartitionJoinTest >
shouldCorrectlyRepartitionOnJoinOperations[0] STARTED
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.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] PASSED
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] 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[1] STARTED
ERROR: Could not install GRADLE_2_4_RC_2_HOME
java.lang.NullPointerException
Build timed out (after 180 minutes). Marking the build as failed.
Build was aborted
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
