See
<https://builds.apache.org/job/kafka-0.10.2-jdk7/124/display/redirect?page=changes>
Changes:
[ismael] MINOR: Improve topic management instructions for Kafka Streams examples
[ismael] MINOR: Clarify ReadOnlyWindowStore's time range behaviour
------------------------------------------
[...truncated 798.57 KB...]
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testRestoreWithDefaultSerdes STARTED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testRestoreWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testRestore STARTED
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.MergedSortedCacheSessionStoreIteratorTest
> shouldHaveNextFromCache STARTED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldHaveNextFromCache PASSED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldHaveNextFromStore STARTED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldHaveNextFromStore PASSED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldPeekNextKeyFromCache STARTED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldPeekNextKeyFromCache PASSED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldPeekNextKeyFromStore STARTED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldPeekNextKeyFromStore PASSED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldIterateBothStoreAndCache STARTED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldIterateBothStoreAndCache PASSED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldGetNextFromCache STARTED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldGetNextFromCache PASSED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldGetNextFromStore STARTED
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIteratorTest
> shouldGetNextFromStore 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.CachingSessionStoreTest >
shouldThrowIfTryingToFindMergeSessionFromClosedCachingStore STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldThrowIfTryingToFindMergeSessionFromClosedCachingStore PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldPutFetchFromCache STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldPutFetchFromCache PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldRemove
STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldRemove
PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldThrowIfTryingToPutIntoClosedCachingStore STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldThrowIfTryingToPutIntoClosedCachingStore PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldFlushItemsToStoreOnEviction STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldFlushItemsToStoreOnEviction PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldClearNamespaceCacheOnClose STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldClearNamespaceCacheOnClose PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldFetchAllSessionsWithSameRecordKey STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldFetchAllSessionsWithSameRecordKey PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldThrowIfTryingToFetchFromClosedCachingStore STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldThrowIfTryingToFetchFromClosedCachingStore PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldQueryItemsInCacheAndStore STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldQueryItemsInCacheAndStore PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldThrowIfTryingToRemoveFromClosedCachingStore STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldThrowIfTryingToRemoveFromClosedCachingStore PASSED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldFetchCorrectlyAcrossSegments STARTED
org.apache.kafka.streams.state.internals.CachingSessionStoreTest >
shouldFetchCorrectlyAcrossSegments PASSED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldReturnNextValueWhenItExists STARTED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldReturnNextValueWhenItExists PASSED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldThrowNoSuchElementOnNextWhenIteratorExhausted STARTED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldThrowNoSuchElementOnNextWhenIteratorExhausted PASSED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldReturnTrueOnHasNextWhenMoreResults STARTED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldReturnTrueOnHasNextWhenMoreResults PASSED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldThrowUnsupportedOperationOnRemove STARTED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldThrowUnsupportedOperationOnRemove PASSED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldPeekNextKey STARTED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldPeekNextKey PASSED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldReturnFalseOnHasNextWhenNoMoreResults STARTED
org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest >
shouldReturnFalseOnHasNextWhenNoMoreResults PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldNotGetValueFromOtherStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldNotGetValueFromOtherStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldReturnEmptyIteratorIfNoData STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldReturnEmptyIteratorIfNoData PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldThrowInvalidStateStoreExceptionIfFetchThrows STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldThrowInvalidStateStoreExceptionIfFetchThrows PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldFindValueForKeyWhenMultiStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldFindValueForKeyWhenMultiStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldFetchResulstFromUnderlyingSessionStore STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldFetchResulstFromUnderlyingSessionStore PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldThrowInvalidStateStoreExceptionOnRebalance STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest >
shouldThrowInvalidStateStoreExceptionOnRebalance PASSED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldFetchExactKeys STARTED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldFetchExactKeys PASSED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldRemove
STARTED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldRemove
PASSED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldFindValuesWithinMergingSessionWindowRange STARTED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldFindValuesWithinMergingSessionWindowRange PASSED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldFetchAllSessionsWithSameRecordKey STARTED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldFetchAllSessionsWithSameRecordKey PASSED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldFindSessionsToMerge STARTED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldFindSessionsToMerge PASSED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldPutAndFindSessionsInRange STARTED
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest >
shouldPutAndFindSessionsInRange PASSED
org.apache.kafka.streams.state.internals.WindowStoreUtilsTest >
testSerialization STARTED
org.apache.kafka.streams.state.internals.WindowStoreUtilsTest >
testSerialization 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.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
org.apache.kafka.streams.integration.RegexSourceIntegrationTest >
shouldAddStateStoreToRegexDefinedSource STARTED
ERROR: Could not install GRADLE_2_4_RC_2_HOME
java.lang.NullPointerException
at
hudson.plugins.toolenv.ToolEnvBuildWrapper$1.buildEnvVars(ToolEnvBuildWrapper.java:46)
at hudson.model.AbstractBuild.getEnvironment(AbstractBuild.java:931)
at hudson.plugins.git.GitSCM.getParamExpandedRepos(GitSCM.java:416)
at
hudson.plugins.git.GitSCM.compareRemoteRevisionWithImpl(GitSCM.java:622)
at hudson.plugins.git.GitSCM.compareRemoteRevisionWith(GitSCM.java:587)
at hudson.scm.SCM.compareRemoteRevisionWith(SCM.java:391)
at hudson.scm.SCM.poll(SCM.java:408)
at hudson.model.AbstractProject._poll(AbstractProject.java:1460)
at hudson.model.AbstractProject.poll(AbstractProject.java:1363)
at hudson.triggers.SCMTrigger$Runner.runPolling(SCMTrigger.java:563)
at hudson.triggers.SCMTrigger$Runner.run(SCMTrigger.java:609)
at
hudson.util.SequentialExecutionQueue$QueueEntry.run(SequentialExecutionQueue.java:119)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
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
