You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2016/08/26 21:19:37 UTC
Build failed in Jenkins: kafka-0.10.0-jdk7 #196
See <https://builds.apache.org/job/kafka-0.10.0-jdk7/196/changes>
Changes:
[wangguoz] MINOR: Include request header in exception when correlation of
------------------------------------------
[...truncated 5370 lines...]
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testRefreshOffsetNotCoordinatorForConsumer PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testCommitOffsetMetadataTooLarge PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testCommitOffsetAsyncDisconnected PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testAutoCommitDynamicAssignment PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testLeaveGroupOnClose PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testRejoinGroup PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testAutoCommitManualAssignment PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testNormalJoinGroupLeader PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testJoinGroupInvalidGroupId PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testCommitOffsetIllegalGeneration PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testCoordinatorNotAvailable PASSED
org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest > testNotCoordinator PASSED
org.apache.kafka.clients.consumer.internals.ConsumerProtocolTest > serializeDeserializeNullSubscriptionUserData PASSED
org.apache.kafka.clients.consumer.internals.ConsumerProtocolTest > deserializeNewSubscriptionVersion PASSED
org.apache.kafka.clients.consumer.internals.ConsumerProtocolTest > serializeDeserializeMetadata PASSED
org.apache.kafka.clients.consumer.internals.ConsumerProtocolTest > deserializeNullAssignmentUserData PASSED
org.apache.kafka.clients.consumer.internals.ConsumerProtocolTest > serializeDeserializeAssignment PASSED
org.apache.kafka.clients.consumer.internals.ConsumerProtocolTest > deserializeNewAssignmentVersion PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testUpdateFetchPositionResetToLatestOffset PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchUnknownTopicOrPartition PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchOffsetOutOfRange PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchedRecordsRaisesOnSerializationErrors PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testQuotaMetrics PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchMaxPollRecords PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testUpdateFetchPositionDisconnect PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchRecordTooLarge PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testGetTopicMetadataInvalidTopic PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testUpdateFetchPositionResetToDefaultOffset PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchNonContinuousRecords PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchNormal PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testGetAllTopicsTimeout PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testUnauthorizedTopic PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testGetAllTopicsUnauthorized PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchNotLeaderForPartition PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testParseInvalidRecord PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchedRecordsAfterSeek PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchOffsetOutOfRangeException PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchOnPausedPartition PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchDuringRebalance PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testGetAllTopics PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testUpdateFetchPositionResetToEarliestOffset PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testStaleOutOfRangeError PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testInFlightFetchOnPausedPartition PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testFetchDisconnected PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testGetAllTopicsDisconnect PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testGetTopicMetadataLeaderNotAvailable PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testUpdateFetchPositionToCommitted PASSED
org.apache.kafka.clients.consumer.internals.FetcherTest > testGetTopicMetadataUnknownTopic PASSED
org.apache.kafka.clients.consumer.internals.ConsumerInterceptorsTest > testOnCommitChain PASSED
org.apache.kafka.clients.consumer.internals.ConsumerInterceptorsTest > testOnConsumeChain PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > unsubscribeUserAssignment PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > cantSubscribePartitionAndPattern PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > partitionAssignment PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > topicSubscription PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > partitionPause PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > partitionReset PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > unsubscription PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > patternSubscription PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > cantSubscribeTopicAndPattern PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > invalidPositionUpdate PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > unsubscribeUserSubscribe PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > cantChangePositionForNonAssignedPartition PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > commitOffsetMetadata PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > cantSubscribePatternAndTopic PASSED
org.apache.kafka.clients.consumer.internals.SubscriptionStateTest > cantSubscribePatternAndPartition PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > testConstructorClose PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > testPause PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > verifyNoCoordinatorLookupForManualAssignmentWithSeek PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > testCommitsFetchedDuringAssign PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > testSeekNegative PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > testAutoCommitSentBeforePositionUpdate PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > verifyHeartbeatSent PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > verifyHeartbeatSentWhenFetchedDataReady PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > testSubscription PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > testInterceptorConstructorClose PASSED
org.apache.kafka.clients.consumer.KafkaConsumerTest > testWakeupWithFetchDataAvailable PASSED
org.apache.kafka.clients.consumer.ConsumerConfigTest > testDeserializerToPropertyConfig PASSED
org.apache.kafka.clients.consumer.ConsumerConfigTest > testDeserializerToMapConfig PASSED
org.apache.kafka.clients.consumer.RoundRobinAssignorTest > testOneConsumerNoTopic PASSED
org.apache.kafka.clients.consumer.RoundRobinAssignorTest > testTwoConsumersTwoTopicsSixPartitions PASSED
org.apache.kafka.clients.consumer.RoundRobinAssignorTest > testOneConsumerOneTopic PASSED
org.apache.kafka.clients.consumer.RoundRobinAssignorTest > testMultipleConsumersMixedTopics PASSED
org.apache.kafka.clients.consumer.RoundRobinAssignorTest > testTwoConsumersOneTopicOnePartition PASSED
org.apache.kafka.clients.consumer.RoundRobinAssignorTest > testOneConsumerMultipleTopics PASSED
org.apache.kafka.clients.consumer.RoundRobinAssignorTest > testOnlyAssignsPartitionsFromSubscribedTopics PASSED
org.apache.kafka.clients.consumer.RoundRobinAssignorTest > testTwoConsumersOneTopicTwoPartitions PASSED
org.apache.kafka.clients.consumer.RoundRobinAssignorTest > testOneConsumerNonexistentTopic PASSED
org.apache.kafka.clients.consumer.MockConsumerTest > testSimpleMock PASSED
org.apache.kafka.clients.consumer.SerializeCompatibilityOffsetAndMetadataTest > testSerializationRoundtrip PASSED
org.apache.kafka.clients.consumer.SerializeCompatibilityOffsetAndMetadataTest > testOffsetMetadataSerializationCompatibility PASSED
org.apache.kafka.clients.consumer.ConsumerRecordsTest > iterator PASSED
org.apache.kafka.clients.ClientUtilsTest > testOnlyBadHostname PASSED
org.apache.kafka.clients.ClientUtilsTest > testParseAndValidateAddresses PASSED
org.apache.kafka.clients.ClientUtilsTest > testNoPort PASSED
:examples:checkstyleMain
:examples:compileTestJava UP-TO-DATE
:examples:processTestResources UP-TO-DATE
:examples:testClasses UP-TO-DATE
:examples:checkstyleTest UP-TO-DATE
:examples:test UP-TO-DATE
:log4j-appender:checkstyleMain
:log4j-appender:compileTestJava
:log4j-appender:processTestResources UP-TO-DATE
:log4j-appender:testClasses
:log4j-appender:checkstyleTest
:log4j-appender:test
org.apache.kafka.log4jappender.KafkaLog4jAppenderTest > testLog4jAppends PASSED
org.apache.kafka.log4jappender.KafkaLog4jAppenderTest > testKafkaLog4jConfigs PASSED
:streams:checkstyleMain
:streams:compileTestJavaNote: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
:streams:processTestResources UP-TO-DATE
:streams:testClasses
:streams:checkstyleTest
:streams:test
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)
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)
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)
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
Jenkins build is back to normal : kafka-0.10.0-jdk7 #202
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-0.10.0-jdk7/202/changes>
Build failed in Jenkins: kafka-0.10.0-jdk7 #201
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-0.10.0-jdk7/201/changes>
Changes:
[ismael] HOTFIX: changed quickstart donwload from 0.10.0.0 to 0.10.0.1
[ismael] KAFKA-4157; Transient system test failure in
------------------------------------------
[...truncated 5760 lines...]
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 FAILED
java.lang.AssertionError: Expected 2 but received only 1 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.MapFunctionIntegrationTest.shouldUppercaseTheInput(MapFunctionIntegrationTest.java:119)
org.apache.kafka.streams.integration.InternalTopicIntegrationTest > shouldCompactTopicsForStateChangelogs PASSED
org.apache.kafka.streams.integration.WordCountIntegrationTest > shouldCountWords FAILED
java.lang.AssertionError: Expected 5 but received only 2 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, 4 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 21 mins 7.788 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
Build failed in Jenkins: kafka-0.10.0-jdk7 #200
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-0.10.0-jdk7/200/changes>
Changes:
[wangguoz] HOTFIX: set sourceNodes to null for selectKey
------------------------------------------
[...truncated 5757 lines...]
org.apache.kafka.streams.kstream.internals.KTableSourceTest > testKTable PASSED
org.apache.kafka.streams.kstream.internals.KTableSourceTest > testValueGetter 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.KStreamForeachTest > testForeach 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.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.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.KStreamFilterTest > testFilterNot PASSED
org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testFilter PASSED
org.apache.kafka.streams.kstream.internals.KStreamMapValuesTest > testFlatMapValues PASSED
org.apache.kafka.streams.kstream.internals.KStreamTransformTest > testTransform PASSED
org.apache.kafka.streams.kstream.internals.KTableForeachTest > testForeach PASSED
org.apache.kafka.streams.kstream.internals.KStreamFlatMapTest > testFlatMap 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.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.KStreamTransformValuesTest > testTransform 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.JoinWindowsTest > afterBelowLower PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > nameMustNotBeEmpty PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > beforeOverUpper PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > nameMustNotBeNull PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > shouldHaveSaneEqualsAndHashCode PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > validWindows PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > timeDifferenceMustNotBeNegative PASSED
org.apache.kafka.streams.kstream.UnlimitedWindowsTest > nameMustNotBeEmpty PASSED
org.apache.kafka.streams.kstream.UnlimitedWindowsTest > startTimeMustNotBeNegative PASSED
org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldIncludeRecordsThatHappenedOnWindowStart PASSED
org.apache.kafka.streams.kstream.UnlimitedWindowsTest > nameMustNotBeNull PASSED
org.apache.kafka.streams.kstream.UnlimitedWindowsTest > startTimeCanBeZero PASSED
org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldIncludeRecordsThatHappenedAfterWindowStart PASSED
org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldExcludeRecordsThatHappenedBeforeWindowStart 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.processor.DefaultPartitionGrouperTest > testGrouping PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testStorePartitions PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateKTable PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateNonPersistentStore PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdate PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > testTracking PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingMultiplexingTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingStatefulTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingSimpleTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testTopologyMetadata PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingMultiplexByNameTopology PASSED
org.apache.kafka.streams.processor.internals.PartitionGroupTest > testTimeTracking PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpecificPartition PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testStreamPartitioner PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithStandbyReplicas PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithNewTasks PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithStates PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignBasic PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testOnAssignment PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testSubscription PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithInternalTopics PASSED
org.apache.kafka.streams.processor.internals.assignment.AssginmentInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testStickiness PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithoutStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testInjectClients PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeCommit PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testPartitionAssignmentChange PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeClean PASSED
org.apache.kafka.streams.processor.internals.PunctuationQueueTest > testPunctuationInterval PASSED
org.apache.kafka.streams.processor.internals.RecordQueueTest > testTimeTracking PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testRegisterNonPersistentStore PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testLockStateDirectory PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testGetStore PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testClose PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testChangeLogOffsets PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testRegisterPersistentStore PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testNoTopic PASSED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testProcessOrder PASSED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testPauseResume PASSED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testMaybePunctuate PASSED
org.apache.kafka.streams.processor.internals.QuickUnionTest > testUnite PASSED
org.apache.kafka.streams.processor.internals.QuickUnionTest > testUniteMany PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testSourceTopics PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkWithSameName PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkWithSelfParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddProcessorWithSelfParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithSink PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testTopicGroups PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testBuild PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithSource PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSourceWithSameName PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddProcessorWithSameName PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSourceWithSameTopic PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testTopicGroupsByStateStore PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithDuplicates PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkWithWrongParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkConnectedWithMultipleParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddProcessorWithWrongParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStore PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkConnectedWithParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithNonExistingProcessor PASSED
194 tests completed, 2 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 10 mins 8.044 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
Build failed in Jenkins: kafka-0.10.0-jdk7 #199
Posted by Apache Jenkins Server <je...@builds.apache.org>.
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
Build failed in Jenkins: kafka-0.10.0-jdk7 #198
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-0.10.0-jdk7/198/changes>
Changes:
[wangguoz] KAFKA-4112: Remove alpha quality label from Kafka Streams in docs
------------------------------------------
[...truncated 5748 lines...]
org.apache.kafka.streams.kstream.internals.KStreamForeachTest > testForeach PASSED
org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testSendingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testNotSendingOldValue PASSED
org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testKTable PASSED
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 PASSED
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 PASSED
org.apache.kafka.streams.integration.PassThroughIntegrationTest > shouldWriteTheInputDataAsIsToTheOutputTopic FAILED
java.lang.AssertionError: Expected 3 but received only 1 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, 1 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 15 mins 7.475 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
Build failed in Jenkins: kafka-0.10.0-jdk7 #197
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-0.10.0-jdk7/197/changes>
Changes:
[wangguoz] KAFKA-4058: Failure in
------------------------------------------
[...truncated 5728 lines...]
org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldIncludeRecordsThatHappenedAfterWindowStart PASSED
org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldExcludeRecordsThatHappenedBeforeWindowStart PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > afterBelowLower PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > nameMustNotBeEmpty PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > beforeOverUpper PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > nameMustNotBeNull PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > shouldHaveSaneEqualsAndHashCode PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > validWindows PASSED
org.apache.kafka.streams.kstream.JoinWindowsTest > timeDifferenceMustNotBeNegative 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.kstream.KStreamBuilderTest > testMerge PASSED
org.apache.kafka.streams.kstream.KStreamBuilderTest > testFrom PASSED
org.apache.kafka.streams.kstream.KStreamBuilderTest > testNewName PASSED
org.apache.kafka.streams.KeyValueTest > shouldHaveSaneEqualsAndHashCode PASSED
org.apache.kafka.streams.KafkaStreamsTest > classMethod FAILED
java.lang.OutOfMemoryError: Java heap space
org.apache.kafka.streams.state.internals.OffsetCheckpointTest > testReadWrite 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.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.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.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.StoreChangeLoggerTest > testAddRemove PASSED
org.apache.kafka.streams.processor.DefaultPartitionGrouperTest > testGrouping PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingMultiplexingTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingStatefulTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingSimpleTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testTopologyMetadata PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingMultiplexByNameTopology PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpecificPartition PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testStreamPartitioner PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testStorePartitions PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateKTable PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateNonPersistentStore PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdate PASSED
org.apache.kafka.streams.processor.internals.PartitionGroupTest > testTimeTracking PASSED
org.apache.kafka.streams.processor.internals.assignment.AssginmentInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testStickiness PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithoutStandby PASSED
org.apache.kafka.streams.processor.internals.PunctuationQueueTest > testPunctuationInterval PASSED
org.apache.kafka.streams.processor.internals.QuickUnionTest > testUnite PASSED
org.apache.kafka.streams.processor.internals.QuickUnionTest > testUniteMany PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testRegisterNonPersistentStore PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testLockStateDirectory PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testGetStore PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testClose PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testChangeLogOffsets PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testRegisterPersistentStore PASSED
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testNoTopic PASSED
org.apache.kafka.streams.processor.internals.RecordQueueTest > testTimeTracking PASSED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testProcessOrder PASSED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testPauseResume PASSED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testMaybePunctuate PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testInjectClients PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeCommit PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testPartitionAssignmentChange PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeClean PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > testTracking PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithStandbyReplicas PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithNewTasks PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithStates PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignBasic PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testOnAssignment PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testSubscription PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithInternalTopics PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testSourceTopics PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkWithSameName PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkWithSelfParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddProcessorWithSelfParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithSink PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testTopicGroups PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testBuild PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithSource PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSourceWithSameName PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddProcessorWithSameName PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSourceWithSameTopic PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testTopicGroupsByStateStore PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithDuplicates PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkWithWrongParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkConnectedWithMultipleParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddProcessorWithWrongParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStore PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkConnectedWithParent PASSED
org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithNonExistingProcessor PASSED
188 tests completed, 1 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: 1 hrs 5 mins 33.767 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