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/11/11 02:56:36 UTC
Build failed in Jenkins: kafka-trunk-jdk7 #1683
See <https://builds.apache.org/job/kafka-trunk-jdk7/1683/changes>
Changes:
[wangguoz] MINOR: improve exception message for incompatible Serdes to actual
------------------------------------------
[...truncated 14337 lines...]
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowWhenKeyIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyWithMergedStreams STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyWithMergedStreams PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldNotThrowNPEWhenOnChangeNotCalled STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldNotThrowNPEWhenOnChangeNotCalled PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNotAvailableWhenClusterIsEmpty STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNotAvailableWhenClusterIsEmpty PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNullOnGetWithKeyWhenStoreDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNullOnGetWithKeyWhenStoreDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStreamPartitionerIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStreamPartitionerIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyAndCustomPartitioner STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyAndCustomPartitioner PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore PASSED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenAuthorizationException STARTED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenAuthorizationException PASSED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenKafkaException STARTED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenKafkaException PASSED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowWakeupExceptionOnInitializeOffsetsWhenWakeupException STARTED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowWakeupExceptionOnInitializeOffsetsWhenWakeupException PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHaveCompactionPropSetIfSupplied STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHaveCompactionPropSetIfSupplied PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldThrowIfNameIsNull STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldThrowIfNameIsNull PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldConfigureRetentionMsWithAdditionalRetentionWhenCompactAndDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldConfigureRetentionMsWithAdditionalRetentionWhenCompactAndDelete PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldBeCompactedIfCleanupPolicyCompactOrCompactAndDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldBeCompactedIfCleanupPolicyCompactOrCompactAndDelete PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotBeCompactedWhenCleanupPolicyIsDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotBeCompactedWhenCleanupPolicyIsDelete PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHavePropertiesSuppliedByUser STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHavePropertiesSuppliedByUser PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldUseCleanupPolicyFromConfigIfSupplied STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldUseCleanupPolicyFromConfigIfSupplied PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenCompact STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenCompact PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenDelete PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testStorePartitions STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testStorePartitions PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateKTable STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateKTable PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateNonPersistentStore STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateNonPersistentStore PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdate STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdate PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpecificPartition STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpecificPartition PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionAfterMaxAttempts STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionAfterMaxAttempts PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldRetryWhenTimeoutExceptionOccursOnSend STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldRetryWhenTimeoutExceptionOccursOnSend PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testStreamPartitioner STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testStreamPartitioner PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testStickiness STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testStickiness PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithStandby STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithoutStandby STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithoutStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeDecodeWithUserEndPoint STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeDecodeWithUserEndPoint PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldBeBackwardCompatible STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldBeBackwardCompatible PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > testEncodeDecode STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldDecodePreviousVersion STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldDecodePreviousVersion PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCleanUpTaskStateDirectoriesThatAreNotCurrentlyLocked STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCleanUpTaskStateDirectoriesThatAreNotCurrentlyLocked PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateBaseDirectory STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateBaseDirectory PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockMulitpleTaskDirectories STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockMulitpleTaskDirectories PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateDirectoriesIfParentDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateDirectoriesIfParentDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldListAllTaskDirectories STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldListAllTaskDirectories PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockTaskStateDirectory STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockTaskStateDirectory PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateTaskStateDirectory STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateTaskStateDirectory PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldNotRemoveNonTaskDirectoriesAndFiles STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldNotRemoveNonTaskDirectoriesAndFiles PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldBeTrueIfAlreadyHoldsLock STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldBeTrueIfAlreadyHoldsLock PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldReleaseTaskStateDirectoryLock STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldReleaseTaskStateDirectoryLock PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndSerializerWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndSerializerWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWithStoreWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWithStoreWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCleanup STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCleanup PASSED
org.apache.kafka.streams.KafkaStreamsTest > testStartAndClose STARTED
org.apache.kafka.streams.KafkaStreamsTest > testStartAndClose PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice PASSED
519 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-trunk-jdk7/ws/streams/build/reports/tests/test/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 17 mins 30.126 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
Jenkins build is back to normal : kafka-trunk-jdk7 #1686
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk7/1686/changes>
Build failed in Jenkins: kafka-trunk-jdk7 #1685
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk7/1685/changes>
Changes:
[me] MINOR: Extend mirror maker test to include interceptors
------------------------------------------
[...truncated 14337 lines...]
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowWhenKeyIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyWithMergedStreams STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyWithMergedStreams PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldNotThrowNPEWhenOnChangeNotCalled STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldNotThrowNPEWhenOnChangeNotCalled PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNotAvailableWhenClusterIsEmpty STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNotAvailableWhenClusterIsEmpty PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNullOnGetWithKeyWhenStoreDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNullOnGetWithKeyWhenStoreDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStreamPartitionerIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStreamPartitionerIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyAndCustomPartitioner STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyAndCustomPartitioner PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore PASSED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenAuthorizationException STARTED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenAuthorizationException PASSED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenKafkaException STARTED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenKafkaException PASSED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowWakeupExceptionOnInitializeOffsetsWhenWakeupException STARTED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowWakeupExceptionOnInitializeOffsetsWhenWakeupException PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHaveCompactionPropSetIfSupplied STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHaveCompactionPropSetIfSupplied PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldThrowIfNameIsNull STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldThrowIfNameIsNull PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldConfigureRetentionMsWithAdditionalRetentionWhenCompactAndDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldConfigureRetentionMsWithAdditionalRetentionWhenCompactAndDelete PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldBeCompactedIfCleanupPolicyCompactOrCompactAndDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldBeCompactedIfCleanupPolicyCompactOrCompactAndDelete PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotBeCompactedWhenCleanupPolicyIsDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotBeCompactedWhenCleanupPolicyIsDelete PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHavePropertiesSuppliedByUser STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHavePropertiesSuppliedByUser PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldUseCleanupPolicyFromConfigIfSupplied STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldUseCleanupPolicyFromConfigIfSupplied PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenCompact STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenCompact PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenDelete PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testStorePartitions STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testStorePartitions PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateKTable STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateKTable PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateNonPersistentStore STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateNonPersistentStore PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdate STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdate PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpecificPartition STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpecificPartition PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionAfterMaxAttempts STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionAfterMaxAttempts PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldRetryWhenTimeoutExceptionOccursOnSend STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldRetryWhenTimeoutExceptionOccursOnSend PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testStreamPartitioner STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testStreamPartitioner PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testStickiness STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testStickiness PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithStandby STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithoutStandby STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithoutStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeDecodeWithUserEndPoint STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeDecodeWithUserEndPoint PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldBeBackwardCompatible STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldBeBackwardCompatible PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > testEncodeDecode STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldDecodePreviousVersion STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldDecodePreviousVersion PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCleanUpTaskStateDirectoriesThatAreNotCurrentlyLocked STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCleanUpTaskStateDirectoriesThatAreNotCurrentlyLocked PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateBaseDirectory STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateBaseDirectory PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockMulitpleTaskDirectories STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockMulitpleTaskDirectories PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateDirectoriesIfParentDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateDirectoriesIfParentDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldListAllTaskDirectories STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldListAllTaskDirectories PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockTaskStateDirectory STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockTaskStateDirectory PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateTaskStateDirectory STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateTaskStateDirectory PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldNotRemoveNonTaskDirectoriesAndFiles STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldNotRemoveNonTaskDirectoriesAndFiles PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldBeTrueIfAlreadyHoldsLock STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldBeTrueIfAlreadyHoldsLock PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldReleaseTaskStateDirectoryLock STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldReleaseTaskStateDirectoryLock PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndSerializerWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndSerializerWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWithStoreWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWithStoreWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCleanup STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCleanup PASSED
org.apache.kafka.streams.KafkaStreamsTest > testStartAndClose STARTED
org.apache.kafka.streams.KafkaStreamsTest > testStartAndClose PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice PASSED
519 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-trunk-jdk7/ws/streams/build/reports/tests/test/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 19 mins 34.433 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-trunk-jdk7 #1684
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk7/1684/changes>
Changes:
[wangguoz] HOTFIX: failing to close this iterator causes leaks in rocksdb
------------------------------------------
[...truncated 14337 lines...]
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowWhenKeyIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyWithMergedStreams STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyWithMergedStreams PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldNotThrowNPEWhenOnChangeNotCalled STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldNotThrowNPEWhenOnChangeNotCalled PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNotAvailableWhenClusterIsEmpty STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNotAvailableWhenClusterIsEmpty PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNullOnGetWithKeyWhenStoreDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNullOnGetWithKeyWhenStoreDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStreamPartitionerIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStreamPartitionerIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyAndCustomPartitioner STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyAndCustomPartitioner PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore PASSED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenAuthorizationException STARTED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenAuthorizationException PASSED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenKafkaException STARTED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenKafkaException PASSED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowWakeupExceptionOnInitializeOffsetsWhenWakeupException STARTED
org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowWakeupExceptionOnInitializeOffsetsWhenWakeupException PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHaveCompactionPropSetIfSupplied STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHaveCompactionPropSetIfSupplied PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldThrowIfNameIsNull STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldThrowIfNameIsNull PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldConfigureRetentionMsWithAdditionalRetentionWhenCompactAndDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldConfigureRetentionMsWithAdditionalRetentionWhenCompactAndDelete PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldBeCompactedIfCleanupPolicyCompactOrCompactAndDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldBeCompactedIfCleanupPolicyCompactOrCompactAndDelete PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotBeCompactedWhenCleanupPolicyIsDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotBeCompactedWhenCleanupPolicyIsDelete PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHavePropertiesSuppliedByUser STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHavePropertiesSuppliedByUser PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldUseCleanupPolicyFromConfigIfSupplied STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldUseCleanupPolicyFromConfigIfSupplied PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenCompact STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenCompact PASSED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenDelete STARTED
org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenDelete PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testStorePartitions STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testStorePartitions PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateKTable STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateKTable PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateNonPersistentStore STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateNonPersistentStore PASSED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdate STARTED
org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdate PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpecificPartition STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpecificPartition PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionAfterMaxAttempts STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionAfterMaxAttempts PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldRetryWhenTimeoutExceptionOccursOnSend STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldRetryWhenTimeoutExceptionOccursOnSend PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testStreamPartitioner STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest > testStreamPartitioner PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testStickiness STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testStickiness PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithStandby STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithoutStandby STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest > testAssignWithoutStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeDecodeWithUserEndPoint STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeDecodeWithUserEndPoint PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldBeBackwardCompatible STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldBeBackwardCompatible PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > testEncodeDecode STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldDecodePreviousVersion STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldDecodePreviousVersion PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCleanUpTaskStateDirectoriesThatAreNotCurrentlyLocked STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCleanUpTaskStateDirectoriesThatAreNotCurrentlyLocked PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateBaseDirectory STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateBaseDirectory PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockMulitpleTaskDirectories STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockMulitpleTaskDirectories PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateDirectoriesIfParentDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateDirectoriesIfParentDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldListAllTaskDirectories STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldListAllTaskDirectories PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockTaskStateDirectory STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockTaskStateDirectory PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateTaskStateDirectory STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateTaskStateDirectory PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldNotRemoveNonTaskDirectoriesAndFiles STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldNotRemoveNonTaskDirectoriesAndFiles PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldBeTrueIfAlreadyHoldsLock STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldBeTrueIfAlreadyHoldsLock PASSED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldReleaseTaskStateDirectoryLock STARTED
org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldReleaseTaskStateDirectoryLock PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndSerializerWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndSerializerWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWithStoreWhenNotRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWithStoreWhenNotRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCleanup STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCleanup PASSED
org.apache.kafka.streams.KafkaStreamsTest > testStartAndClose STARTED
org.apache.kafka.streams.KafkaStreamsTest > testStartAndClose PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning PASSED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice STARTED
org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice PASSED
519 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-trunk-jdk7/ws/streams/build/reports/tests/test/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 30 mins 10.65 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