See <https://builds.apache.org/job/kafka-0.10.0-jdk7/199/changes>
Changes:
[me] KAFKA-4162: Fixed typo "rebalance"
------------------------------------------
[...truncated 5756 lines...]
org.apache.kafka.streams.kstream.internals.KTableMapValuesTest >
testValueGetter PASSED
org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest > testSelectKey
PASSED
org.apache.kafka.streams.kstream.internals.KTableKTableJoinTest > testJoin
PASSED
org.apache.kafka.streams.kstream.internals.KTableKTableJoinTest >
testNotSendingOldValues PASSED
org.apache.kafka.streams.kstream.internals.KTableKTableJoinTest >
testSendingOldValues PASSED
org.apache.kafka.streams.kstream.internals.WindowedStreamPartitionerTest >
testCopartitioning PASSED
org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest >
testOuterJoin PASSED
org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testJoin
PASSED
org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest >
testWindowing PASSED
org.apache.kafka.streams.kstream.internals.KeyValuePrinterProcessorTest >
testPrintKeyValueWithProvidedSerde PASSED
org.apache.kafka.streams.kstream.internals.KeyValuePrinterProcessorTest >
testPrintKeyValueDefaultSerde PASSED
org.apache.kafka.streams.kstream.internals.KStreamTransformValuesTest >
testTransform PASSED
org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest >
testGroupedCountOccurences PASSED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest >
testNotJoinable PASSED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > testJoin
PASSED
org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoinTest >
testSendingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoinTest > testJoin
PASSED
org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoinTest >
testNotSendingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest >
testSendingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testJoin
PASSED
org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest >
testNotSendingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableFilterTest >
testSendingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableFilterTest >
testNotSendingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableFilterTest >
testSkipNullOnMaterialization PASSED
org.apache.kafka.streams.kstream.internals.KTableFilterTest > testKTable PASSED
org.apache.kafka.streams.kstream.internals.KTableFilterTest > testValueGetter
PASSED
org.apache.kafka.streams.kstream.internals.KStreamImplTest >
testToWithNullValueSerdeDoesntNPE PASSED
org.apache.kafka.streams.kstream.internals.KStreamImplTest > testNumProcesses
PASSED
org.apache.kafka.streams.kstream.internals.KTableForeachTest > testForeach
PASSED
org.apache.kafka.streams.kstream.internals.KStreamKStreamLeftJoinTest >
testLeftJoin PASSED
org.apache.kafka.streams.kstream.internals.KStreamKStreamLeftJoinTest >
testWindowing PASSED
org.apache.kafka.streams.kstream.internals.KTableMapKeysTest >
testMapKeysConvertingToStream PASSED
org.apache.kafka.streams.kstream.internals.KStreamBranchTest >
testKStreamBranch PASSED
org.apache.kafka.streams.kstream.internals.KStreamMapValuesTest >
testFlatMapValues PASSED
org.apache.kafka.streams.kstream.internals.KTableSourceTest >
testNotSedingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableSourceTest >
testSedingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableSourceTest > testKTable PASSED
org.apache.kafka.streams.kstream.internals.KTableSourceTest > testValueGetter
PASSED
org.apache.kafka.streams.kstream.internals.KStreamFlatMapTest > testFlatMap
PASSED
org.apache.kafka.streams.kstream.internals.KStreamFlatMapValuesTest >
testFlatMapValues PASSED
org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testFilterNot
PASSED
org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testFilter PASSED
org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testAggBasic
PASSED
org.apache.kafka.streams.kstream.internals.KTableAggregateTest >
testAggRepartition PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testStateStore
PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testRepartition
PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest >
testStateStoreLazyEval PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testKTable PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testValueGetter
PASSED
org.apache.kafka.streams.kstream.KStreamBuilderTest > testMerge PASSED
org.apache.kafka.streams.kstream.KStreamBuilderTest > testFrom PASSED
org.apache.kafka.streams.kstream.KStreamBuilderTest > testNewName PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest > nameMustNotBeEmpty PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest > nameMustNotBeNull PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest >
shouldHaveSaneEqualsAndHashCode PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest > windowSizeMustNotBeZero
PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest > advanceIntervalMustNotBeZero
PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest > windowSizeMustNotBeNegative
PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest >
advanceIntervalMustNotBeNegative PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest >
advanceIntervalMustNotBeLargerThanWindowSize PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest > windowsForTumblingWindows
PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest > windowsForHoppingWindows
PASSED
org.apache.kafka.streams.kstream.TimeWindowsTest >
windowsForBarelyOverlappingHoppingWindows PASSED
org.apache.kafka.streams.integration.FanoutIntegrationTest >
shouldFanoutTheInput FAILED
java.lang.AssertionError: Expected 2 but received only 0 records before
timeout 30000 ms
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinValuesRecordsReceived(IntegrationTestUtils.java:240)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinValuesRecordsReceived(IntegrationTestUtils.java:214)
at
org.apache.kafka.streams.integration.FanoutIntegrationTest.shouldFanoutTheInput(FanoutIntegrationTest.java:148)
org.apache.kafka.streams.integration.JoinIntegrationTest >
shouldCountClicksPerRegion PASSED
org.apache.kafka.streams.integration.ResetIntegrationTest >
testReprocessingFromScratchAfterReset PASSED
org.apache.kafka.streams.integration.MapFunctionIntegrationTest >
shouldUppercaseTheInput PASSED
org.apache.kafka.streams.integration.InternalTopicIntegrationTest >
shouldCompactTopicsForStateChangelogs PASSED
org.apache.kafka.streams.integration.WordCountIntegrationTest >
shouldCountWords FAILED
java.lang.AssertionError: Expected 5 but received only 0 records before
timeout 30000 ms
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:203)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:177)
at
org.apache.kafka.streams.integration.WordCountIntegrationTest.shouldCountWords(WordCountIntegrationTest.java:143)
org.apache.kafka.streams.integration.PassThroughIntegrationTest >
shouldWriteTheInputDataAsIsToTheOutputTopic FAILED
java.lang.AssertionError: Expected 3 but received only 0 records before
timeout 30000 ms
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinValuesRecordsReceived(IntegrationTestUtils.java:240)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinValuesRecordsReceived(IntegrationTestUtils.java:214)
at
org.apache.kafka.streams.integration.PassThroughIntegrationTest.shouldWriteTheInputDataAsIsToTheOutputTopic(PassThroughIntegrationTest.java:106)
org.apache.kafka.streams.KeyValueTest > shouldHaveSaneEqualsAndHashCode PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCleanup PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCleanupIsolation PASSED
org.apache.kafka.streams.KafkaStreamsTest > testStartAndClose PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice PASSED
org.apache.kafka.streams.state.internals.StoreChangeLoggerTest > testAddRemove
PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testPutIfAbsent PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testRestoreWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testRestore
PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testPutGetRange PASSED
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >
testPutGetRangeWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testEvict
PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testPutIfAbsent PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testRestoreWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testRestore PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testPutGetRange PASSED
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >
testPutGetRangeWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.OffsetCheckpointTest > testReadWrite
PASSED
org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest >
testPutAndFetch PASSED
org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest >
testPutAndFetchBefore PASSED
org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest >
testInitialLoading PASSED
org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testRestore
PASSED
org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testRolling
PASSED
org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest >
testSegmentMaintenance PASSED
org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest >
testPutSameKeyTimestamp PASSED
org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest >
testPutAndFetchAfter PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testPutIfAbsent PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testRestoreWithDefaultSerdes PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testRestore PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testPutGetRange PASSED
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest >
testPutGetRangeWithDefaultSerdes PASSED
org.apache.kafka.streams.StreamsConfigTest > testGetConsumerConfigs PASSED
org.apache.kafka.streams.StreamsConfigTest > defaultSerdeShouldBeConfigured
PASSED
org.apache.kafka.streams.StreamsConfigTest > testGetProducerConfigs PASSED
org.apache.kafka.streams.StreamsConfigTest >
shouldSupportMultipleBootstrapServers PASSED
org.apache.kafka.streams.StreamsConfigTest > testGetRestoreConsumerConfigs
PASSED
194 tests completed, 3 failed
:streams:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/kafka-0.10.0-jdk7/ws/streams/build/reports/tests/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output.
BUILD FAILED
Total time: 2 hrs 20 mins 8.34 secs
Build step 'Execute shell' marked build as failure
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
