See
<https://builds.apache.org/job/kafka-trunk-jdk10/27/display/redirect?page=changes>
Changes:
[jason] KAFKA-6770; Add New Protocol Versions to 1.1.0 documentation (#4847)
[wangguoz] KAFKA-6376: preliminary cleanup (#4872)
------------------------------------------
[...truncated 1.53 MB...]
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldRespondWithInvalidRequestOnEndTxnWhenTransactionalIdIsNull PASSED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldRespondWithCoordinatorLoadInProgressOnEndTxnWhenCoordinatorIsLoading
STARTED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldRespondWithCoordinatorLoadInProgressOnEndTxnWhenCoordinatorIsLoading
PASSED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldRespondWithSuccessOnAddPartitionsWhenStateIsCompleteAbort STARTED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldRespondWithSuccessOnAddPartitionsWhenStateIsCompleteAbort PASSED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareAbortState
STARTED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldWaitForCommitToCompleteOnHandleInitPidAndExistingTransactionInPrepareAbortState
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 >
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 >
shouldAbortExpiredTransactionsInOngoingStateAndBumpEpoch STARTED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldAbortExpiredTransactionsInOngoingStateAndBumpEpoch 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 >
shouldGenerateNewProducerIdIfEpochsExhausted STARTED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldGenerateNewProducerIdIfEpochsExhausted PASSED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldRespondWithNotCoordinatorOnInitPidWhenNotCoordinator STARTED
kafka.coordinator.transaction.TransactionCoordinatorTest >
shouldRespondWithNotCoordinatorOnInitPidWhenNotCoordinator 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 > testExceedProducerIdLimit
STARTED
kafka.coordinator.transaction.ProducerIdManagerTest > testExceedProducerIdLimit
PASSED
kafka.coordinator.transaction.ProducerIdManagerTest > testGetProducerId STARTED
kafka.coordinator.transaction.ProducerIdManagerTest > testGetProducerId PASSED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldSaveForLaterWhenLeaderUnknownButNotAvailable STARTED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldSaveForLaterWhenLeaderUnknownButNotAvailable PASSED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldGenerateEmptyMapWhenNoRequestsOutstanding STARTED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldGenerateEmptyMapWhenNoRequestsOutstanding PASSED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldCreateMetricsOnStarting STARTED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldCreateMetricsOnStarting PASSED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldAbortAppendToLogOnEndTxnWhenNotCoordinatorError STARTED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldAbortAppendToLogOnEndTxnWhenNotCoordinatorError PASSED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldRetryAppendToLogOnEndTxnWhenCoordinatorNotAvailableError STARTED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldRetryAppendToLogOnEndTxnWhenCoordinatorNotAvailableError PASSED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldCompleteAppendToLogOnEndTxnWhenSendMarkersSucceed STARTED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldCompleteAppendToLogOnEndTxnWhenSendMarkersSucceed PASSED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldGenerateRequestPerPartitionPerBroker STARTED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldGenerateRequestPerPartitionPerBroker PASSED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldRemoveMarkersForTxnPartitionWhenPartitionEmigrated STARTED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldRemoveMarkersForTxnPartitionWhenPartitionEmigrated PASSED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldSkipSendMarkersWhenLeaderNotFound STARTED
kafka.coordinator.transaction.TransactionMarkerChannelManagerTest >
shouldSkipSendMarkersWhenLeaderNotFound 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 >
testCompleteTransitionWhenAppendSucceeded STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
testCompleteTransitionWhenAppendSucceeded PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendFailToCoordinatorNotAvailableError STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendFailToCoordinatorNotAvailableError PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendFailToUnknownError STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendFailToUnknownError PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldReturnNotCooridnatorErrorIfTransactionIdPartitionNotOwned STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldReturnNotCooridnatorErrorIfTransactionIdPartitionNotOwned 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 >
shouldOnlyConsiderTransactionsInTheOngoingStateToAbort STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldOnlyConsiderTransactionsInTheOngoingStateToAbort PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldRemoveCompleteAbortExpiredTransactionalIds STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldRemoveCompleteAbortExpiredTransactionalIds PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendTransactionToLogWhilePendingStateChanged STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendTransactionToLogWhilePendingStateChanged PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
testLoadAndRemoveTransactionsForPartition STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
testLoadAndRemoveTransactionsForPartition PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendFailToNotCoordinatorError STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendFailToNotCoordinatorError PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldNotRemovePrepareCommitTransactionalIds STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldNotRemovePrepareCommitTransactionalIds PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendFailToCoordinatorLoadingError STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
testAppendFailToCoordinatorLoadingError PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldNotRemoveOngoingTransactionalIds STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldNotRemoveOngoingTransactionalIds 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
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldRemoveEmptyExpiredTransactionalIds STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldRemoveEmptyExpiredTransactionalIds PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
testPendingStateNotResetOnRetryAppend STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
testPendingStateNotResetOnRetryAppend PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldNotRemoveExpiredTransactionalIdsIfLogAppendFails STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldNotRemoveExpiredTransactionalIdsIfLogAppendFails PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldNotRemovePrepareAbortTransactionalIds STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldNotRemovePrepareAbortTransactionalIds PASSED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldRemoveCompleteCommmitExpiredTransactionalIds STARTED
kafka.coordinator.transaction.TransactionStateManagerTest >
shouldRemoveCompleteCommmitExpiredTransactionalIds PASSED
unit.kafka.admin.DeleteConsumerGroupTest > classMethod STARTED
unit.kafka.admin.DeleteConsumerGroupTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @BeforeClass,
allThreads=Set(ThrottledRequestReaper-Produce, /0:0:0:0:0:0:0:1:58648 to
/0:0:0:0:0:0:0:1:37421 workers Thread 3, metrics-meter-tick-thread-2, Signal
Dispatcher, main, Reference Handler, scala-execution-context-global-133,
ExpirationReaper-0-Produce, ExpirationReaper-0-DeleteRecords,
ThrottledRequestReaper-Fetch, ThrottledRequestReaper-Request,
kafka-consumer-scheduler-0, group1_consumer1_watcher_executor, Test worker,
Test worker-SendThread(127.0.0.1:33145), Test worker-EventThread,
shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer,
ZkClient-EventThread-124-127.0.0.1:33145, /0:0:0:0:0:0:0:1:58648 to
/0:0:0:0:0:0:0:1:37421 workers Thread 2, group1_consumer1-leader-finder-thread,
metrics-meter-tick-thread-1)
unit.kafka.admin.DeleteConsumerGroupTest > classMethod STARTED
unit.kafka.admin.DeleteConsumerGroupTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @AfterClass,
allThreads=Set(ThrottledRequestReaper-Produce, /0:0:0:0:0:0:0:1:58648 to
/0:0:0:0:0:0:0:1:37421 workers Thread 3, metrics-meter-tick-thread-2, Signal
Dispatcher, main, Reference Handler, scala-execution-context-global-133,
ExpirationReaper-0-Produce, ExpirationReaper-0-DeleteRecords,
ThrottledRequestReaper-Fetch, ThrottledRequestReaper-Request,
kafka-consumer-scheduler-0, group1_consumer1_watcher_executor, Test worker,
Test worker-SendThread(127.0.0.1:33145), Test worker-EventThread,
shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer,
ZkClient-EventThread-124-127.0.0.1:33145, /0:0:0:0:0:0:0:1:58648 to
/0:0:0:0:0:0:0:1:37421 workers Thread 2, group1_consumer1-leader-finder-thread,
metrics-meter-tick-thread-1)
1302 tests completed, 228 failed, 1 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-jdk10/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. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
BUILD FAILED in 1h 5m 37s
35 actionable tasks: 17 executed, 18 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Setting GRADLE_4_4_HOME=/home/jenkins/tools/gradle/4.4
Setting GRADLE_4_4_HOME=/home/jenkins/tools/gradle/4.4
Not sending mail to unregistered user wangg...@gmail.com
