See <https://builds.apache.org/job/kafka-trunk-jdk7/1831/changes>
Changes: [me] MINOR: avoid closing over both pre & post-transform record in ------------------------------------------ [...truncated 18646 lines...] 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 > shouldUnlockGlobalStateDirectory STARTED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldUnlockGlobalStateDirectory 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 > shouldLockGlobalStateDirectory STARTED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockGlobalStateDirectory 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.processor.internals.GlobalStateManagerImplTest > shouldThrowStreamsExceptionIfNoPartitionsFoundForStore STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowStreamsExceptionIfNoPartitionsFoundForStore PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldNotCloseStoresIfCloseAlreadyCalled STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldNotCloseStoresIfCloseAlreadyCalled PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowProcessorStateStoreExceptionIfStoreFlushFailed STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowProcessorStateStoreExceptionIfStoreFlushFailed PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowStreamsExceptionIfCantGetLock STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowStreamsExceptionIfCantGetLock PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowStreamsExceptionIfFailedToReadCheckpointedOffsets STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowStreamsExceptionIfFailedToReadCheckpointedOffsets PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldWriteCheckpointsOnClose STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldWriteCheckpointsOnClose PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowProcessorStateStoreExceptionIfStoreCloseFailed STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowProcessorStateStoreExceptionIfStoreCloseFailed PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldRestoreRecordsUpToHighwatermark STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldRestoreRecordsUpToHighwatermark PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldInitializeStateStores STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldInitializeStateStores PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldReturnInitializedStoreNames STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldReturnInitializedStoreNames PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldUnlockGlobalStateDirectoryOnClose STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldUnlockGlobalStateDirectoryOnClose PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowIllegalArgumenExceptionIfAttemptingToRegisterStoreTwice STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowIllegalArgumenExceptionIfAttemptingToRegisterStoreTwice PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldAttemptToCloseAllStoresEvenWhenSomeException STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldAttemptToCloseAllStoresEvenWhenSomeException PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowIllegalArgumentExceptionIfCallbackIsNull STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowIllegalArgumentExceptionIfCallbackIsNull PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldReadCheckpointOffsets STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldReadCheckpointOffsets PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldCloseStateStores STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldCloseStateStores PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowIllegalArgumentIfTryingToRegisterStoreThatIsNotGlobal STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowIllegalArgumentIfTryingToRegisterStoreThatIsNotGlobal PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldFlushStateStores STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldFlushStateStores PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldLockGlobalStateDirectory STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldLockGlobalStateDirectory PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldRestoreRecordsFromCheckpointToHighwatermark STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldRestoreRecordsFromCheckpointToHighwatermark PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldDeleteCheckpointFileAfteLoaded STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldDeleteCheckpointFileAfteLoaded PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldReleaseLockIfExceptionWhenLoadingCheckpoints STARTED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldReleaseLockIfExceptionWhenLoadingCheckpoints PASSED org.apache.kafka.streams.processor.WallclockTimestampExtractorTest > extractSystemTimestamp STARTED org.apache.kafka.streams.processor.WallclockTimestampExtractorTest > extractSystemTimestamp PASSED org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp STARTED org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp PASSED org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp STARTED org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp PASSED org.apache.kafka.streams.KafkaStreamsTest > testIllegalMetricsConfig STARTED org.apache.kafka.streams.KafkaStreamsTest > testIllegalMetricsConfig PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning STARTED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > testInitializesAndDestroysMetricsReporters STARTED org.apache.kafka.streams.KafkaStreamsTest > testInitializesAndDestroysMetricsReporters PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning STARTED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > testLegalMetricsConfig STARTED org.apache.kafka.streams.KafkaStreamsTest > testLegalMetricsConfig PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndSerializerWhenNotRunning STARTED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndSerializerWhenNotRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldReturnFalseOnCloseWhenThreadsHaventTerminated STARTED org.apache.kafka.streams.KafkaStreamsTest > shouldReturnFalseOnCloseWhenThreadsHaventTerminated PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWithStoreWhenNotRunning STARTED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWithStoreWhenNotRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed STARTED org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed PASSED org.apache.kafka.streams.KafkaStreamsTest > testCleanup STARTED org.apache.kafka.streams.KafkaStreamsTest > testCleanup PASSED org.apache.kafka.streams.KafkaStreamsTest > testNumberDefaultMetrics STARTED org.apache.kafka.streams.KafkaStreamsTest > testNumberDefaultMetrics PASSED org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent STARTED org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent PASSED org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning STARTED org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice STARTED org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice PASSED 762 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 24 mins 23.705 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
