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
