See
<https://builds.apache.org/job/kafka-trunk-jdk7/2081/display/redirect?page=changes>
Changes:
[ismael] KAFKA-4990; Request/response classes for transactions (KIP-98)
------------------------------------------
[...truncated 942.18 KB...]
org.apache.kafka.streams.state.internals.SessionKeySchemaTest >
shouldFetchExactKeysSkippingLongerKeys PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldWriteAllKeyValueToInnerStoreOnPutAll STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldWriteAllKeyValueToInnerStoreOnPutAll PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldLogChangeOnPut STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldLogChangeOnPut PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldWriteToChangelogOnPutIfAbsentWhenNoPreviousValue STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldWriteToChangelogOnPutIfAbsentWhenNoPreviousValue PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldPutNullOnDelete STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldPutNullOnDelete PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldWriteToInnerOnPutIfAbsentNoPreviousValue STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldWriteToInnerOnPutIfAbsentNoPreviousValue PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldQueryRange STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldQueryRange PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldWriteKeyValueBytesToInnerStoreOnPut STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldWriteKeyValueBytesToInnerStoreOnPut PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnCurrentValueOnPutIfAbsent STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnCurrentValueOnPutIfAbsent PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldLogChangesOnPutAll STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldLogChangesOnPutAll PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldNotWriteToChangeLogOnPutIfAbsentWhenValueForKeyExists STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldNotWriteToChangeLogOnPutIfAbsentWhenValueForKeyExists PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnNullOnPutIfAbsentWhenNoPreviousValue STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnNullOnPutIfAbsentWhenNoPreviousValue PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldLogKeyNullOnDelete STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldLogKeyNullOnDelete PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnNullOnDeleteIfNoOldValue STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnNullOnDeleteIfNoOldValue PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnNullOnGetWhenDoesntExist STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnNullOnGetWhenDoesntExist PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnOldValueOnDelete STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnOldValueOnDelete PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnInnerStoreName STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnInnerStoreName PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldNotWriteToInnerOnPutIfAbsentWhenValueForKeyExists STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldNotWriteToInnerOnPutIfAbsentWhenValueForKeyExists PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnValueOnGetWhenExists STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnValueOnGetWhenExists PASSED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnAllKeyValues STARTED
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest >
shouldReturnAllKeyValues 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.DelegatingPeekingKeyValueIteratorTest
> shouldPeekNextKey STARTED
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest
> shouldPeekNextKey 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.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.KafkaStreamsTest > testIllegalMetricsConfig STARTED
org.apache.kafka.streams.KafkaStreamsTest > testIllegalMetricsConfig PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning
STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning
PASSED
org.apache.kafka.streams.KafkaStreamsTest >
testInitializesAndDestroysMetricsReporters STARTED
org.apache.kafka.streams.KafkaStreamsTest >
testInitializesAndDestroysMetricsReporters PASSED
org.apache.kafka.streams.KafkaStreamsTest >
shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest >
shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testLegalMetricsConfig STARTED
org.apache.kafka.streams.KafkaStreamsTest > testLegalMetricsConfig PASSED
org.apache.kafka.streams.KafkaStreamsTest >
shouldNotGetTaskWithKeyAndSerializerWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest >
shouldNotGetTaskWithKeyAndSerializerWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest >
shouldReturnFalseOnCloseWhenThreadsHaventTerminated STARTED
org.apache.kafka.streams.KafkaStreamsTest >
shouldReturnFalseOnCloseWhenThreadsHaventTerminated PASSED
org.apache.kafka.streams.KafkaStreamsTest >
shouldNotGetAllTasksWithStoreWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest >
shouldNotGetAllTasksWithStoreWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCleanup STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCleanup PASSED
org.apache.kafka.streams.KafkaStreamsTest > testNumberDefaultMetrics STARTED
org.apache.kafka.streams.KafkaStreamsTest > testNumberDefaultMetrics PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning
STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterResetWithIntermediateUserTopic STARTED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterResetWithIntermediateUserTopic FAILED
java.lang.AssertionError:
Expected: <[KeyValue(2983140076135, 1), KeyValue(2983140076155, 1),
KeyValue(2983140076095, 1), KeyValue(2983140076115, 1), KeyValue(2983140076175,
1), KeyValue(2983140076135, 1), KeyValue(2983140076155, 1),
KeyValue(2983140076115, 1), KeyValue(2983140076135, 2), KeyValue(2983140076155,
2), KeyValue(2983140076195, 1), KeyValue(2983140076175, 1),
KeyValue(2983140076155, 2), KeyValue(2983140076175, 2), KeyValue(2983140076195,
1), KeyValue(2983140076215, 1), KeyValue(2983140076175, 2),
KeyValue(2983140076195, 2), KeyValue(2983140076235, 1), KeyValue(2983140076215,
1), KeyValue(2983140076195, 2), KeyValue(2983140076215, 2),
KeyValue(2983140076235, 1), KeyValue(2983140076255, 1), KeyValue(2983140076195,
3), KeyValue(2983140076215, 2), KeyValue(2983140076235, 2),
KeyValue(2983140076255, 1), KeyValue(2983140076215, 3), KeyValue(2983140076235,
2), KeyValue(2983140076255, 2), KeyValue(2983140076215, 3),
KeyValue(2983140076235, 3), KeyValue(2983140076255, 2)]>
but: was <[KeyValue(2983140076135, 1), KeyValue(2983140076155, 1),
KeyValue(2983140076095, 1), KeyValue(2983140076115, 1), KeyValue(2983140076175,
1), KeyValue(2983140076135, 1), KeyValue(2983140076155, 1),
KeyValue(2983140076115, 1), KeyValue(2983140076135, 2), KeyValue(2983140076155,
2), KeyValue(2983140076195, 1), KeyValue(2983140076175, 1),
KeyValue(2983140076155, 2), KeyValue(2983140076175, 2), KeyValue(2983140076195,
1), KeyValue(2983140076215, 1), KeyValue(2983140076175, 2),
KeyValue(2983140076195, 2), KeyValue(2983140076235, 1), KeyValue(2983140076215,
1), KeyValue(2983140076195, 2), KeyValue(2983140076215, 2),
KeyValue(2983140076235, 1), KeyValue(2983140076255, 1), KeyValue(2983140076195,
3), KeyValue(2983140076215, 2), KeyValue(2983140076235, 2),
KeyValue(2983140076255, 1), KeyValue(2983140076215, 3), KeyValue(2983140076235,
2), KeyValue(2983140076255, 2), KeyValue(2983140076215, 3),
KeyValue(2983140076235, 3), KeyValue(2983140076255, 2), KeyValue(2983140076215,
4), KeyValue(2983140076235, 3), KeyValue(2983140076255, 3)]>
at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8)
at
org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic(ResetIntegrationTest.java:190)
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic 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)
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 240 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
