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