See 
<https://builds.apache.org/job/kafka-trunk-jdk7/2124/display/redirect?page=changes>

Changes:

[jason] KAFKA-4818; Exactly once transactional clients

------------------------------------------
[...truncated 835.78 KB...]

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldAddRequestToBrokerQueue PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldRetryGettingLeaderWhenNotFound STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldRetryGettingLeaderWhenNotFound PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldClearPurgatoryForPartitionWhenPartitionEmigrated STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldClearPurgatoryForPartitionWhenPartitionEmigrated PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldDrainBrokerQueueWhenGeneratingRequests STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldDrainBrokerQueueWhenGeneratingRequests PASSED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldThrowIllegalStateExceptionWhenErrorNotHandled STARTED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldThrowIllegalStateExceptionWhenErrorNotHandled PASSED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRetryPartitionWhenNotLeaderForPartitionError STARTED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRetryPartitionWhenNotLeaderForPartitionError PASSED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldReEnqueuePartitionsWhenBrokerDisconnected STARTED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldReEnqueuePartitionsWhenBrokerDisconnected PASSED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRetryPartitionWhenNotEnoughReplicasError STARTED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRetryPartitionWhenNotEnoughReplicasError PASSED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldThrowIllegalStateExceptionIfErrorsNullForPid STARTED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldThrowIllegalStateExceptionIfErrorsNullForPid PASSED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRemoveCompletedPartitionsFromMetadataWhenNoErrors STARTED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRemoveCompletedPartitionsFromMetadataWhenNoErrors PASSED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRetryPartitionWhenUnknownTopicOrPartitionError STARTED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRetryPartitionWhenUnknownTopicOrPartitionError PASSED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRetryPartitionWhenNotEnoughReplicasAfterAppendError STARTED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldRetryPartitionWhenNotEnoughReplicasAfterAppendError PASSED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldTryCompleteDelayedTxnOperation STARTED

kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest > 
shouldTryCompleteDelayedTxnOperation PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldUpdateDestinationBrokerNodeWhenUpdatingBroker STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldUpdateDestinationBrokerNodeWhenUpdatingBroker PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldRemoveBrokerRequestsForPartitionWhenPartitionEmigrated STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldRemoveBrokerRequestsForPartitionWhenPartitionEmigrated PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldGetPendingTxnMetadataByPid STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldGetPendingTxnMetadataByPid PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldAddRequestsToCorrectBrokerQueues STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldAddRequestsToCorrectBrokerQueues PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldRemovePendingRequestsForPartitionWhenPartitionEmigrated STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldRemovePendingRequestsForPartitionWhenPartitionEmigrated PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldWakeupNetworkClientWhenRequestsQueued STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldWakeupNetworkClientWhenRequestsQueued PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldAddNewBrokerQueueIfDoesntAlreadyExistWhenAddingRequest STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldAddNewBrokerQueueIfDoesntAlreadyExistWhenAddingRequest PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldAddEmptyBrokerQueueWhenAddingNewBroker STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldAddEmptyBrokerQueueWhenAddingNewBroker PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldQueueRequestsByBrokerId STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldQueueRequestsByBrokerId PASSED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldNotAddPendingTxnIfOneAlreadyExistsForPid STARTED

kafka.coordinator.transaction.TransactionMarkerChannelTest > 
shouldNotAddPendingTxnIfOneAlreadyExistsForPid PASSED

kafka.coordinator.transaction.ProducerIdManagerTest > testExceedPIDLimit STARTED

kafka.coordinator.transaction.ProducerIdManagerTest > testExceedPIDLimit PASSED

kafka.coordinator.transaction.ProducerIdManagerTest > testGetPID STARTED

kafka.coordinator.transaction.ProducerIdManagerTest > testGetPID PASSED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testAppendTransactionToLogWhileProducerFenced STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testAppendTransactionToLogWhileProducerFenced PASSED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testValidateTransactionTimeout STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testValidateTransactionTimeout PASSED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testAppendTransactionToLog STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testAppendTransactionToLog PASSED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testAppendTransactionToLogWhilePendingStateChanged STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testAppendTransactionToLogWhilePendingStateChanged PASSED

kafka.coordinator.transaction.TransactionStateManagerTest > 
shouldReturnEpochForTransactionId STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > 
shouldReturnEpochForTransactionId PASSED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testLoadAndRemoveTransactionsForPartition STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > 
testLoadAndRemoveTransactionsForPartition PASSED

kafka.coordinator.transaction.TransactionStateManagerTest > 
shouldReturnNoneIfTransactionIdPartitionNotOwned STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > 
shouldReturnNoneIfTransactionIdPartitionNotOwned PASSED

kafka.coordinator.transaction.TransactionStateManagerTest > testAddGetPids 
STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > testAddGetPids 
PASSED

kafka.coordinator.transaction.TransactionLogTest > shouldReadWriteMessages 
STARTED

kafka.coordinator.transaction.TransactionLogTest > shouldReadWriteMessages 
PASSED

kafka.coordinator.transaction.TransactionLogTest > 
shouldThrowExceptionWriteInvalidTxn STARTED

kafka.coordinator.transaction.TransactionLogTest > 
shouldThrowExceptionWriteInvalidTxn PASSED

kafka.message.MessageCompressionTest > testCompressSize STARTED

kafka.message.MessageCompressionTest > testCompressSize PASSED

kafka.message.MessageCompressionTest > testSimpleCompressDecompress STARTED

kafka.message.MessageCompressionTest > testSimpleCompressDecompress PASSED

kafka.message.MessageTest > testChecksum STARTED

kafka.message.MessageTest > testChecksum PASSED

kafka.message.MessageTest > testInvalidTimestamp STARTED

kafka.message.MessageTest > testInvalidTimestamp PASSED

kafka.message.MessageTest > testIsHashable STARTED

kafka.message.MessageTest > testIsHashable PASSED

kafka.message.MessageTest > testInvalidTimestampAndMagicValueCombination STARTED

kafka.message.MessageTest > testInvalidTimestampAndMagicValueCombination PASSED

kafka.message.MessageTest > testExceptionMapping STARTED

kafka.message.MessageTest > testExceptionMapping PASSED

kafka.message.MessageTest > testFieldValues STARTED

kafka.message.MessageTest > testFieldValues PASSED

kafka.message.MessageTest > testInvalidMagicByte STARTED

kafka.message.MessageTest > testInvalidMagicByte PASSED

kafka.message.MessageTest > testEquality STARTED

kafka.message.MessageTest > testEquality PASSED

kafka.message.ByteBufferMessageSetTest > testMessageWithProvidedOffsetSeq 
STARTED

kafka.message.ByteBufferMessageSetTest > testMessageWithProvidedOffsetSeq PASSED

kafka.message.ByteBufferMessageSetTest > testValidBytes STARTED

kafka.message.ByteBufferMessageSetTest > testValidBytes PASSED

kafka.message.ByteBufferMessageSetTest > testValidBytesWithCompression STARTED

kafka.message.ByteBufferMessageSetTest > testValidBytesWithCompression PASSED

kafka.message.ByteBufferMessageSetTest > 
testWriteToChannelThatConsumesPartially STARTED

kafka.message.ByteBufferMessageSetTest > 
testWriteToChannelThatConsumesPartially PASSED

kafka.message.ByteBufferMessageSetTest > testIteratorIsConsistent STARTED

kafka.message.ByteBufferMessageSetTest > testIteratorIsConsistent PASSED

kafka.message.ByteBufferMessageSetTest > testWrittenEqualsRead STARTED

kafka.message.ByteBufferMessageSetTest > testWrittenEqualsRead PASSED

kafka.message.ByteBufferMessageSetTest > testWriteTo STARTED

kafka.message.ByteBufferMessageSetTest > testWriteTo PASSED

kafka.message.ByteBufferMessageSetTest > testEquals STARTED

kafka.message.ByteBufferMessageSetTest > testEquals PASSED

kafka.message.ByteBufferMessageSetTest > testSizeInBytes STARTED

kafka.message.ByteBufferMessageSetTest > testSizeInBytes PASSED

kafka.message.ByteBufferMessageSetTest > testIterator STARTED

kafka.message.ByteBufferMessageSetTest > testIterator PASSED

unit.kafka.coordinator.transaction.TransactionCoordinatorIntegrationTest > 
shouldCommitTransaction STARTED

unit.kafka.coordinator.transaction.TransactionCoordinatorIntegrationTest > 
shouldCommitTransaction PASSED

1279 tests completed, 1 failed
:kafka-trunk-jdk7:core:test FAILED
:test_core_2_10 FAILED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':kafka-trunk-jdk7:core:test'.
> There were failing tests. See the report at: 
> file://<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/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: 45 mins 48.904 secs
Build step 'Execute shell' marked build as failure
[FINDBUGS] Collecting findbugs analysis files...
Setting 
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
[FINDBUGS] Searching for all files in 
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/> that match the pattern 
**/build/reports/findbugs/*.xml
[FINDBUGS] Parsing 1 file in 
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/>
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Computing warning deltas based on reference build #2123
Recording test results
Setting 
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
Setting 
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2

Reply via email to