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

Changes:

[junrao] KAFKA-5099; Replica Deletion Regression from KIP-101

------------------------------------------
[...truncated 3.58 MB...]

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareAbortState
 STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareAbortState
 PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldNotRetryOnCommitWhenAppendToLogFailsWithNotCoordinator STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldNotRetryOnCommitWhenAppendToLogFailsWithNotCoordinator PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithErrorsNoneOnAddPartitionWhenNoErrorsAndPartitionsTheSame 
STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithErrorsNoneOnAddPartitionWhenNoErrorsAndPartitionsTheSame PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithInvalidRequestOnEndTxnWhenTransactionalIdIsEmpty STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithInvalidRequestOnEndTxnWhenTransactionalIdIsEmpty PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldAppendCompleteAbortToLogOnEndTxnWhenStatusIsOngoingAndResultIsAbort 
STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldAppendCompleteAbortToLogOnEndTxnWhenStatusIsOngoingAndResultIsAbort PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldAppendCompleteCommitToLogOnEndTxnWhenStatusIsOngoingAndResultIsCommit 
STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldAppendCompleteCommitToLogOnEndTxnWhenStatusIsOngoingAndResultIsCommit 
PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithInvalidRequestAddPartitionsToTransactionWhenTransactionalIdIsEmpty
 STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithInvalidRequestAddPartitionsToTransactionWhenTransactionalIdIsEmpty
 PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldAppendPrepareAbortToLogOnEndTxnWhenStatusIsOngoingAndResultIsAbort STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldAppendPrepareAbortToLogOnEndTxnWhenStatusIsOngoingAndResultIsAbort PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldAcceptInitPidAndReturnNextPidWhenTransactionalIdIsNull STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldAcceptInitPidAndReturnNextPidWhenTransactionalIdIsNull PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRemoveTransactionsForPartitionOnEmigration STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRemoveTransactionsForPartitionOnEmigration PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareCommitState
 STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareCommitState
 PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldReturnInvalidTxnRequestOnEndTxnRequestWhenStatusIsCompleteCommitAndResultIsNotCommit
 STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldReturnInvalidTxnRequestOnEndTxnRequestWhenStatusIsCompleteCommitAndResultIsNotCommit
 PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldReturnOkOnEndTxnWhenStatusIsCompleteCommitAndResultIsCommit STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldReturnOkOnEndTxnWhenStatusIsCompleteCommitAndResultIsCommit PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithConcurrentTransactionsOnAddPartitionsWhenStateIsPrepareCommit 
STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithConcurrentTransactionsOnAddPartitionsWhenStateIsPrepareCommit 
PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldIncrementEpochAndUpdateMetadataOnHandleInitPidWhenExistingCompleteTransaction
 STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldIncrementEpochAndUpdateMetadataOnHandleInitPidWhenExistingCompleteTransaction
 PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithConcurrentTransactionOnAddPartitionsWhenStateIsPrepareAbort 
STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldRespondWithConcurrentTransactionOnAddPartitionsWhenStateIsPrepareAbort 
PASSED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldInitPidWithEpochZeroForNewTransactionalId STARTED

kafka.coordinator.transaction.TransactionCoordinatorTest > 
shouldInitPidWithEpochZeroForNewTransactionalId 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.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.TransactionMarkerChannelManagerTest > 
shouldGenerateEmptyMapWhenNoRequestsOutstanding STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldGenerateEmptyMapWhenNoRequestsOutstanding PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldAddDelayedTxnMarkerToPurgatory STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldAddDelayedTxnMarkerToPurgatory PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldRetryGettingLeaderWhenLeaderDoesntExist STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldRetryGettingLeaderWhenLeaderDoesntExist PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldRetryGettingLeaderWhenBrokerEndPointNotAvailableException STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldRetryGettingLeaderWhenBrokerEndPointNotAvailableException PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldStartInterBrokerThreadOnStartup STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldStartInterBrokerThreadOnStartup PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldGenerateRequestPerPartitionPerBroker STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldGenerateRequestPerPartitionPerBroker PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldStopInterBrokerThreadOnShutdown STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldStopInterBrokerThreadOnShutdown PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldAddPendingTxnRequest STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldAddPendingTxnRequest PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldGenerateRequestPerBroker STARTED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldGenerateRequestPerBroker PASSED

kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > 
shouldAddRequestToBrokerQueue STARTED

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.TransactionLogTest > shouldReadWriteMessages 
STARTED

kafka.coordinator.transaction.TransactionLogTest > shouldReadWriteMessages 
PASSED

kafka.coordinator.transaction.TransactionLogTest > 
shouldThrowExceptionWriteInvalidTxn STARTED

kafka.coordinator.transaction.TransactionLogTest > 
shouldThrowExceptionWriteInvalidTxn 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 > 
shouldWriteTxnMarkersForTransactionInPreparedCommitState STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > 
shouldWriteTxnMarkersForTransactionInPreparedCommitState 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.TransactionStateManagerTest > 
shouldWriteTxnMarkersForTransactionInPreparedAbortState STARTED

kafka.coordinator.transaction.TransactionStateManagerTest > 
shouldWriteTxnMarkersForTransactionInPreparedAbortState PASSED

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

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

1342 tests completed, 1 failed, 3 skipped
:core:test FAILED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:test'.
> There were failing tests. See the report at: 
> file://<https://builds.apache.org/job/kafka-trunk-jdk8/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: 1 hrs 0 mins 6.4 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-jdk8/ws/> that match the pattern 
**/build/reports/findbugs/*.xml
[FINDBUGS] Parsing 2 files in 
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/>
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/clients/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Computing warning deltas based on reference build #1494
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
Not sending mail to unregistered user wangg...@gmail.com
Not sending mail to unregistered user csh...@gmail.com

Reply via email to