See
<https://builds.apache.org/job/kafka-trunk-jdk7/2160/display/redirect?page=changes>
Changes:
[wangguoz] KAFKA-4222: Adjust timeout in low resource environments
------------------------------------------
[...truncated 2.47 MB...]
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest >
shouldReturnMeteredStoreWhenCachingAndLoggingDisabled PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest >
shouldNotBeLoggingEnabledStoreWhenLoggingNotEnabled STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest >
shouldNotBeLoggingEnabledStoreWhenLoggingNotEnabled PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest >
shouldHaveMeteredStoreWhenCached STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest >
shouldHaveMeteredStoreWhenCached PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest >
shouldReturnMeteredStoreWhenCachingDisabled STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest >
shouldReturnMeteredStoreWhenCachingDisabled PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest >
shouldHaveMeteredStoreWhenLogged STARTED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest >
shouldHaveMeteredStoreWhenLogged PASSED
org.apache.kafka.streams.state.internals.SessionKeySchemaTest >
shouldFetchExactKeySkippingShorterKeys STARTED
org.apache.kafka.streams.state.internals.SessionKeySchemaTest >
shouldFetchExactKeySkippingShorterKeys PASSED
org.apache.kafka.streams.state.internals.SessionKeySchemaTest >
shouldFetchExactKeysSkippingLongerKeys STARTED
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(2988711492715, 1), KeyValue(2988711492755, 1),
KeyValue(2988711492695, 1), KeyValue(2988711492735, 1), KeyValue(2988711492775,
1), KeyValue(2988711492715, 1), KeyValue(2988711492755, 1),
KeyValue(2988711492735, 1), KeyValue(2988711492735, 2), KeyValue(2988711492755,
2), KeyValue(2988711492775, 1), KeyValue(2988711492795, 1),
KeyValue(2988711492755, 2), KeyValue(2988711492775, 2), KeyValue(2988711492815,
1), KeyValue(2988711492795, 1), KeyValue(2988711492775, 2),
KeyValue(2988711492795, 2)]>
but: was <[KeyValue(2988711492715, 1), KeyValue(2988711492755, 1),
KeyValue(2988711492695, 1), KeyValue(2988711492735, 1), KeyValue(2988711492775,
1), KeyValue(2988711492715, 1), KeyValue(2988711492755, 1),
KeyValue(2988711492735, 1), KeyValue(2988711492735, 2), KeyValue(2988711492755,
2), KeyValue(2988711492775, 1), KeyValue(2988711492795, 1),
KeyValue(2988711492755, 2), KeyValue(2988711492775, 2), KeyValue(2988711492815,
1), KeyValue(2988711492795, 1), KeyValue(2988711492775, 2),
KeyValue(2988711492795, 2), KeyValue(2988711492815, 1), KeyValue(2988711492835,
1), KeyValue(2988711492795, 2), KeyValue(2988711492815, 2),
KeyValue(2988711492835, 1), KeyValue(2988711492855, 1), KeyValue(2988711492795,
3), KeyValue(2988711492815, 2), KeyValue(2988711492835, 2),
KeyValue(2988711492855, 1), KeyValue(2988711492795, 3), KeyValue(2988711492815,
3), KeyValue(2988711492835, 2), KeyValue(2988711492855, 2),
KeyValue(2988711492795, 4), KeyValue(2988711492815, 3), KeyValue(2988711492835,
3), KeyValue(2988711492855, 2), KeyValue(2988711492795, 4),
KeyValue(2988711492815, 4), KeyValue(2988711492835, 3), KeyValue(2988711492855,
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_3_4_RC_2_HOME
java.lang.NullPointerException
Build timed out (after 240 minutes). Marking the build as failed.
Build was aborted
[FINDBUGS] Collecting findbugs analysis files...
Setting
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
[FINDBUGS] Searching for all files in
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/> that match the pattern
**/build/reports/findbugs/*.xml
[FINDBUGS] Parsing 5 files in
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/>
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/clients/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/examples/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/log4j-appender/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/streams/build/reports/findbugs/main.xml>
with 0 unique warnings and 0 duplicates.
[FINDBUGS] Computing warning deltas based on reference build #2156
Recording test results
Setting
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
Setting
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
Not sending mail to unregistered user ism...@juma.me.uk
Not sending mail to unregistered user wangg...@gmail.com
