See <https://builds.apache.org/job/kafka-trunk-jdk8/832/changes>
Changes:
[ismael] KAFKA-3916; Check for disconnects properly before sending from the
------------------------------------------
[...truncated 10986 lines...]
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.internals.CompositeReadOnlyWindowStoreTest >
shouldNotGetValuesFromOtherStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldNotGetValuesFromOtherStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldReturnEmptyIteratorIfNoData STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldReturnEmptyIteratorIfNoData PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFindValueForKeyWhenMultiStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFindValueForKeyWhenMultiStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchValuesFromWindowStore STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchValuesFromWindowStore PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldReturnValueIfExists STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldReturnValueIfExists PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldNotGetValuesFromOtherStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldNotGetValuesFromOtherStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldGetApproximateEntriesAcrossAllStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldGetApproximateEntriesAcrossAllStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldReturnLongMaxValueOnOverflow STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldReturnLongMaxValueOnOverflow PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldReturnNullIfKeyDoesntExist STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldReturnNullIfKeyDoesntExist PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldSupportRange STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldSupportRange PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldFindValueForKeyWhenMultiStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldFindValueForKeyWhenMultiStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldThrowInvalidStoreExceptionIfNoStoresExistOnAll STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldThrowInvalidStoreExceptionIfNoStoresExistOnAll PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldThrowInvalidStoreExceptionIfNoStoresExistOnGet STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldThrowInvalidStoreExceptionIfNoStoresExistOnGet PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldSupportRangeAcrossMultipleKVStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldSupportRangeAcrossMultipleKVStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldThrowInvalidStoreExceptionIfNoStoresExistOnRange STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldThrowInvalidStoreExceptionIfNoStoresExistOnRange PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldSupportAllAcrossMultipleStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest >
shouldSupportAllAcrossMultipleStores PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testEvict
STARTED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testEvict
PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testSize
STARTED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testSize
PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testPutIfAbsent STARTED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testPutIfAbsent PASSED
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.WindowStoreUtilsTest >
testSerialization STARTED
org.apache.kafka.streams.state.internals.WindowStoreUtilsTest >
testSerialization PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldNotReturnKVStoreWhenIsWindowStore STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldNotReturnKVStoreWhenIsWindowStore PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldReturnNullIfKVStoreDoesntExist STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldReturnNullIfKVStoreDoesntExist PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldReturnNullIfWindowStoreDoesntExist STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldReturnNullIfWindowStoreDoesntExist PASSED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldNotReturnWindowStoreWhenIsKVStore STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldNotReturnWindowStoreWhenIsKVStore 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 >
shouldReturnWindowStoreWhenItExists STARTED
org.apache.kafka.streams.state.internals.QueryableStoreProviderTest >
shouldReturnWindowStoreWhenItExists 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.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.RocksDBKeyValueStoreTest >
shouldUseCustomRocksDbConfigSetter STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
shouldUseCustomRocksDbConfigSetter PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testSize
STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testSize
PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testPutIfAbsent STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testPutIfAbsent PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testRestoreWithDefaultSerdes STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testRestoreWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testRestore
STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testRestore
PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testPutGetRange STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testPutGetRange PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testPutGetRangeWithDefaultSerdes STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testPutGetRangeWithDefaultSerdes PASSED
org.apache.kafka.streams.integration.FanoutIntegrationTest >
shouldFanoutTheInput STARTED
org.apache.kafka.streams.integration.FanoutIntegrationTest >
shouldFanoutTheInput PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduce STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduce PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregate 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:404)
at
hudson.plugins.git.GitSCM.compareRemoteRevisionWithImpl(GitSCM.java:609)
at hudson.plugins.git.GitSCM.compareRemoteRevisionWith(GitSCM.java:574)
at hudson.scm.SCM.compareRemoteRevisionWith(SCM.java:381)
at hudson.scm.SCM.poll(SCM.java:398)
at hudson.model.AbstractProject._poll(AbstractProject.java:1446)
at hudson.model.AbstractProject.poll(AbstractProject.java:1349)
at hudson.triggers.SCMTrigger$Runner.runPolling(SCMTrigger.java:528)
at hudson.triggers.SCMTrigger$Runner.run(SCMTrigger.java:557)
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)
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:404)
at
hudson.plugins.git.GitSCM.compareRemoteRevisionWithImpl(GitSCM.java:609)
at hudson.plugins.git.GitSCM.compareRemoteRevisionWith(GitSCM.java:574)
at hudson.scm.SCM.compareRemoteRevisionWith(SCM.java:381)
at hudson.scm.SCM.poll(SCM.java:398)
at hudson.model.AbstractProject._poll(AbstractProject.java:1446)
at hudson.model.AbstractProject.poll(AbstractProject.java:1349)
at hudson.triggers.SCMTrigger$Runner.runPolling(SCMTrigger.java:528)
at hudson.triggers.SCMTrigger$Runner.run(SCMTrigger.java:557)
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
