You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2021/02/10 13:17:25 UTC
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #469
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/469/display/redirect?page=changes>
Changes:
[github] Fill in the 2.8 release note for Authorizer (#9865)
------------------------------------------
[...truncated 3.60 MB...]
TransactionsTest > testReadCommittedConsumerShouldNotSeeUndecidedData() STARTED
TransactionsTest > testReadCommittedConsumerShouldNotSeeUndecidedData() PASSED
TransactionsTest > testSendOffsetsToTransactionTimeout() STARTED
TransactionsTest > testSendOffsetsToTransactionTimeout() PASSED
TransactionsTest > testFailureToFenceEpoch() STARTED
TransactionsTest > testFailureToFenceEpoch() PASSED
TransactionsTest > testFencingOnSend() STARTED
TransactionsTest > testFencingOnSend() PASSED
TransactionsTest > testFencingOnCommit() STARTED
TransactionsTest > testFencingOnCommit() PASSED
TransactionsTest > testAbortTransactionTimeout() STARTED
TransactionsTest > testAbortTransactionTimeout() PASSED
TransactionsTest > testMultipleMarkersOneLeader() STARTED
TransactionsTest > testMultipleMarkersOneLeader() PASSED
TransactionsTest > testCommitTransactionTimeout() STARTED
TransactionsTest > testCommitTransactionTimeout() PASSED
SaslClientsWithInvalidCredentialsTest > testTransactionalProducerWithAuthenticationFailure() STARTED
SaslClientsWithInvalidCredentialsTest > testTransactionalProducerWithAuthenticationFailure() PASSED
SaslClientsWithInvalidCredentialsTest > testManualAssignmentConsumerWithAuthenticationFailure() STARTED
SaslClientsWithInvalidCredentialsTest > testManualAssignmentConsumerWithAuthenticationFailure() PASSED
SaslClientsWithInvalidCredentialsTest > testConsumerGroupServiceWithAuthenticationSuccess() STARTED
SaslClientsWithInvalidCredentialsTest > testConsumerGroupServiceWithAuthenticationSuccess() PASSED
SaslClientsWithInvalidCredentialsTest > testProducerWithAuthenticationFailure() STARTED
SaslClientsWithInvalidCredentialsTest > testProducerWithAuthenticationFailure() PASSED
SaslClientsWithInvalidCredentialsTest > testConsumerGroupServiceWithAuthenticationFailure() STARTED
SaslClientsWithInvalidCredentialsTest > testConsumerGroupServiceWithAuthenticationFailure() PASSED
SaslClientsWithInvalidCredentialsTest > testManualAssignmentConsumerWithAutoCommitDisabledWithAuthenticationFailure() STARTED
SaslClientsWithInvalidCredentialsTest > testManualAssignmentConsumerWithAutoCommitDisabledWithAuthenticationFailure() PASSED
SaslClientsWithInvalidCredentialsTest > testKafkaAdminClientWithAuthenticationFailure() STARTED
SaslClientsWithInvalidCredentialsTest > testKafkaAdminClientWithAuthenticationFailure() PASSED
SaslClientsWithInvalidCredentialsTest > testConsumerWithAuthenticationFailure() STARTED
SaslClientsWithInvalidCredentialsTest > testConsumerWithAuthenticationFailure() PASSED
UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() STARTED
UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED
UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() STARTED
UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED
UserClientIdQuotaTest > testThrottledProducerConsumer() STARTED
UserClientIdQuotaTest > testThrottledProducerConsumer() PASSED
UserClientIdQuotaTest > testQuotaOverrideDelete() STARTED
UserClientIdQuotaTest > testQuotaOverrideDelete() PASSED
UserClientIdQuotaTest > testThrottledRequest() STARTED
UserClientIdQuotaTest > testThrottledRequest() PASSED
ZooKeeperClientTest > testZNodeChangeHandlerForDataChange() STARTED
ZooKeeperClientTest > testZNodeChangeHandlerForDataChange() PASSED
ZooKeeperClientTest > testZooKeeperSessionStateMetric() STARTED
ZooKeeperClientTest > testZooKeeperSessionStateMetric() PASSED
ZooKeeperClientTest > testExceptionInBeforeInitializingSession() STARTED
ZooKeeperClientTest > testExceptionInBeforeInitializingSession() PASSED
ZooKeeperClientTest > testGetChildrenExistingZNode() STARTED
ZooKeeperClientTest > testGetChildrenExistingZNode() PASSED
ZooKeeperClientTest > testConnection() STARTED
ZooKeeperClientTest > testConnection() PASSED
ZooKeeperClientTest > testZNodeChangeHandlerForCreation() STARTED
ZooKeeperClientTest > testZNodeChangeHandlerForCreation() PASSED
ZooKeeperClientTest > testGetAclExistingZNode() STARTED
ZooKeeperClientTest > testGetAclExistingZNode() PASSED
ZooKeeperClientTest > testSessionExpiryDuringClose() STARTED
ZooKeeperClientTest > testSessionExpiryDuringClose() PASSED
ZooKeeperClientTest > testReinitializeAfterAuthFailure() STARTED
ZooKeeperClientTest > testReinitializeAfterAuthFailure() PASSED
ZooKeeperClientTest > testSetAclNonExistentZNode() STARTED
ZooKeeperClientTest > testSetAclNonExistentZNode() PASSED
ZooKeeperClientTest > testConnectionLossRequestTermination() STARTED
ZooKeeperClientTest > testConnectionLossRequestTermination() PASSED
ZooKeeperClientTest > testExistsNonExistentZNode() STARTED
ZooKeeperClientTest > testExistsNonExistentZNode() PASSED
ZooKeeperClientTest > testGetDataNonExistentZNode() STARTED
ZooKeeperClientTest > testGetDataNonExistentZNode() PASSED
ZooKeeperClientTest > testConnectionTimeout() STARTED
ZooKeeperClientTest > testConnectionTimeout() PASSED
ZooKeeperClientTest > testBlockOnRequestCompletionFromStateChangeHandler() STARTED
ZooKeeperClientTest > testBlockOnRequestCompletionFromStateChangeHandler() PASSED
ZooKeeperClientTest > testUnresolvableConnectString() STARTED
ZooKeeperClientTest > testUnresolvableConnectString() PASSED
ZooKeeperClientTest > testGetChildrenNonExistentZNode() STARTED
ZooKeeperClientTest > testGetChildrenNonExistentZNode() PASSED
ZooKeeperClientTest > testPipelinedGetData() STARTED
ZooKeeperClientTest > testPipelinedGetData() PASSED
ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChange() STARTED
ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChange() PASSED
ZooKeeperClientTest > testGetChildrenExistingZNodeWithChildren() STARTED
ZooKeeperClientTest > testGetChildrenExistingZNodeWithChildren() PASSED
ZooKeeperClientTest > testSetDataExistingZNode() STARTED
ZooKeeperClientTest > testSetDataExistingZNode() PASSED
ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChangeNotTriggered() STARTED
ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChangeNotTriggered() PASSED
ZooKeeperClientTest > testMixedPipeline() STARTED
ZooKeeperClientTest > testMixedPipeline() PASSED
ZooKeeperClientTest > testGetDataExistingZNode() STARTED
ZooKeeperClientTest > testGetDataExistingZNode() PASSED
ZooKeeperClientTest > testDeleteExistingZNode() STARTED
ZooKeeperClientTest > testDeleteExistingZNode() PASSED
ZooKeeperClientTest > testSessionExpiry() STARTED
ZooKeeperClientTest > testSessionExpiry() PASSED
ZooKeeperClientTest > testSetDataNonExistentZNode() STARTED
ZooKeeperClientTest > testSetDataNonExistentZNode() PASSED
ZooKeeperClientTest > testConnectionViaNettyClient() STARTED
ZooKeeperClientTest > testConnectionViaNettyClient() PASSED
ZooKeeperClientTest > testDeleteNonExistentZNode() STARTED
ZooKeeperClientTest > testDeleteNonExistentZNode() PASSED
ZooKeeperClientTest > testExistsExistingZNode() STARTED
ZooKeeperClientTest > testExistsExistingZNode() PASSED
ZooKeeperClientTest > testZooKeeperStateChangeRateMetrics() STARTED
ZooKeeperClientTest > testZooKeeperStateChangeRateMetrics() PASSED
ZooKeeperClientTest > testZNodeChangeHandlerForDeletion() STARTED
ZooKeeperClientTest > testZNodeChangeHandlerForDeletion() PASSED
ZooKeeperClientTest > testGetAclNonExistentZNode() STARTED
ZooKeeperClientTest > testGetAclNonExistentZNode() PASSED
ZooKeeperClientTest > testStateChangeHandlerForAuthFailure() STARTED
ZooKeeperClientTest > testStateChangeHandlerForAuthFailure() PASSED
KafkaTimerTest > testKafkaTimer() STARTED
KafkaTimerTest > testKafkaTimer() PASSED
3338 tests completed, 1 failed, 7 skipped
> Task :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://ci-builds.apache.org/job/Kafka/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. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 49m 33s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #481
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/481/display/redirect?page=changes>
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #480
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/480/display/redirect?page=changes>
Changes:
[github] MINOR: KIP-631 KafkaConfig fixes and improvements (#10114)
------------------------------------------
[...truncated 3.52 MB...]
LogTest > shouldDeleteTimeBasedSegmentsReadyToBeDeleted() PASSED
LogTest > testReadWithTooSmallMaxLength() STARTED
LogTest > testReadWithTooSmallMaxLength() PASSED
LogTest > testOverCompactedLogRecovery() STARTED
LogTest > testOverCompactedLogRecovery() PASSED
LogTest > testBogusIndexSegmentsAreRemoved() STARTED
LogTest > testBogusIndexSegmentsAreRemoved() PASSED
LogTest > testLeaderEpochCacheClearedAfterStaticMessageFormatDowngrade() STARTED
LogTest > testLeaderEpochCacheClearedAfterStaticMessageFormatDowngrade() PASSED
LogTest > testCompressedMessages() STARTED
LogTest > testCompressedMessages() PASSED
LogTest > testAppendMessageWithNullPayload() STARTED
LogTest > testAppendMessageWithNullPayload() PASSED
LogTest > testCorruptLog() STARTED
LogTest > testCorruptLog() PASSED
LogTest > testLogRecoversToCorrectOffset() STARTED
LogTest > testLogRecoversToCorrectOffset() PASSED
LogTest > testReopenThenTruncate() STARTED
LogTest > testReopenThenTruncate() PASSED
LogTest > testZombieCoordinatorFenced() STARTED
LogTest > testZombieCoordinatorFenced() PASSED
LogTest > testOldProducerEpoch() STARTED
LogTest > testOldProducerEpoch() PASSED
LogTest > testProducerSnapshotsRecoveryAfterUncleanShutdownV1() STARTED
LogTest > testProducerSnapshotsRecoveryAfterUncleanShutdownV1() PASSED
LogTest > testDegenerateSegmentSplit() STARTED
LogTest > testDegenerateSegmentSplit() PASSED
LogTest > testParseTopicPartitionNameForMissingPartition() STARTED
LogTest > testParseTopicPartitionNameForMissingPartition() PASSED
LogTest > testParseTopicPartitionNameForEmptyName() STARTED
LogTest > testParseTopicPartitionNameForEmptyName() PASSED
LogTest > testOffsetSnapshot() STARTED
LogTest > testOffsetSnapshot() PASSED
LogTest > testOpenDeletesObsoleteFiles() STARTED
LogTest > testOpenDeletesObsoleteFiles() PASSED
LogTest > shouldUpdateOffsetForLeaderEpochsWhenDeletingSegments() STARTED
LogTest > shouldUpdateOffsetForLeaderEpochsWhenDeletingSegments() PASSED
LogTest > testLogDeleteDirName() STARTED
LogTest > testLogDeleteDirName() PASSED
LogTest > testDeleteOldSegments() STARTED
LogTest > testDeleteOldSegments() PASSED
LogTest > testRebuildTimeIndexForOldMessages() STARTED
LogTest > testRebuildTimeIndexForOldMessages() PASSED
LogTest > testProducerIdMapTruncateTo() STARTED
LogTest > testProducerIdMapTruncateTo() PASSED
LogTest > testTakeSnapshotOnRollAndDeleteSnapshotOnRecoveryPointCheckpoint() STARTED
LogTest > testTakeSnapshotOnRollAndDeleteSnapshotOnRecoveryPointCheckpoint() PASSED
LogTest > testLogEndLessThanStartAfterReopen() STARTED
LogTest > testLogEndLessThanStartAfterReopen() PASSED
LogTest > testLogRecoversForLeaderEpoch() STARTED
LogTest > testLogRecoversForLeaderEpoch() PASSED
LogTest > testRetentionDeletesProducerStateSnapshots() STARTED
LogTest > testRetentionDeletesProducerStateSnapshots() PASSED
LogTest > testLoadingLogDeletesProducerStateSnapshotsPastLogEndOffset() STARTED
LogTest > testLoadingLogDeletesProducerStateSnapshotsPastLogEndOffset() PASSED
LogTest > testWriteLeaderEpochCheckpointAfterDirectoryRename() STARTED
LogTest > testWriteLeaderEpochCheckpointAfterDirectoryRename() PASSED
LogTest > testOverCompactedLogRecoveryMultiRecord() STARTED
LogTest > testOverCompactedLogRecoveryMultiRecord() PASSED
LogTest > testSizeBasedLogRoll() STARTED
LogTest > testSizeBasedLogRoll() PASSED
LogTest > testRebuildProducerIdMapWithCompactedData() STARTED
LogTest > testRebuildProducerIdMapWithCompactedData() PASSED
LogTest > shouldNotDeleteSizeBasedSegmentsWhenUnderRetentionSize() STARTED
LogTest > shouldNotDeleteSizeBasedSegmentsWhenUnderRetentionSize() PASSED
LogTest > testTransactionIndexUpdatedThroughReplication() STARTED
LogTest > testTransactionIndexUpdatedThroughReplication() PASSED
LogTest > testTimeBasedLogRollJitter() STARTED
LogTest > testTimeBasedLogRollJitter() PASSED
LogTest > testParseTopicPartitionName() STARTED
LogTest > testParseTopicPartitionName() PASSED
LogTest > testEndTxnWithFencedProducerEpoch() STARTED
LogTest > testEndTxnWithFencedProducerEpoch() PASSED
LogTest > testRecoveryOfSegmentWithOffsetOverflow() STARTED
LogTest > testRecoveryOfSegmentWithOffsetOverflow() PASSED
LogTest > testRecoverAfterNonMonotonicCoordinatorEpochWrite() STARTED
LogTest > testRecoverAfterNonMonotonicCoordinatorEpochWrite() PASSED
LogTest > testLoadProducersAfterDeleteRecordsMidSegment() STARTED
LogTest > testLoadProducersAfterDeleteRecordsMidSegment() PASSED
LogTest > testInitializationOfProducerSnapshotsUpgradePath() STARTED
LogTest > testInitializationOfProducerSnapshotsUpgradePath() PASSED
LogTest > shouldDeleteStartOffsetBreachedSegmentsWhenPolicyDoesNotIncludeDelete() STARTED
LogTest > shouldDeleteStartOffsetBreachedSegmentsWhenPolicyDoesNotIncludeDelete() PASSED
LogTest > testSkipLoadingIfEmptyProducerStateBeforeTruncation() STARTED
LogTest > testSkipLoadingIfEmptyProducerStateBeforeTruncation() PASSED
LogTest > testTruncateTo() STARTED
LogTest > testTruncateTo() PASSED
LogTest > testSkipTruncateAndReloadIfNewMessageFormatAndCleanShutdown() STARTED
LogTest > testSkipTruncateAndReloadIfNewMessageFormatAndCleanShutdown() PASSED
LogTest > shouldApplyEpochToMessageOnAppendIfLeader() STARTED
LogTest > shouldApplyEpochToMessageOnAppendIfLeader() PASSED
LogTest > testLogDeletionAfterClose() STARTED
LogTest > testLogDeletionAfterClose() PASSED
LogTest > testLoadProducersAfterDeleteRecordsOnSegment() STARTED
LogTest > testLoadProducersAfterDeleteRecordsOnSegment() PASSED
LogTest > testAppendToOrReadFromLogInFailedLogDir() STARTED
LogTest > testAppendToOrReadFromLogInFailedLogDir() PASSED
LogTest > testCleanShutdownFile() STARTED
LogTest > testCleanShutdownFile() PASSED
LogTest > testTransactionIndexUpdated() STARTED
LogTest > testTransactionIndexUpdated() PASSED
LogTest > testBuildTimeIndexWhenNotAssigningOffsets() STARTED
LogTest > testBuildTimeIndexWhenNotAssigningOffsets() PASSED
LogTest > testProducerExpireCheckAfterDelete() STARTED
LogTest > testProducerExpireCheckAfterDelete() PASSED
ControllerIntegrationTest > testControlledShutdown() SKIPPED
> Task :core:test FAILED
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/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. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':core:test'.
> Process 'Gradle Test Executor 74' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the User Manual at https://docs.gradle.org/6.8.1/userguide/java_testing.html#sec:test_execution
* 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
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 23m 37s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #479
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/479/display/redirect?page=changes>
Changes:
[github] KAFKA-12272: Fix commit-interval metrics (#10102)
------------------------------------------
[...truncated 3.60 MB...]
LogValidatorTest > testUncompressedBatchWithoutRecordsNotAllowed() STARTED
LogValidatorTest > testUncompressedBatchWithoutRecordsNotAllowed() PASSED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0NonCompressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0NonCompressed() PASSED
LogValidatorTest > testAbsoluteOffsetAssignmentNonCompressed() STARTED
LogValidatorTest > testAbsoluteOffsetAssignmentNonCompressed() PASSED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1Compressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1Compressed() PASSED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0Compressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0Compressed() PASSED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV0ToV2Compressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV0ToV2Compressed() PASSED
LogValidatorTest > testNonCompressedV1() STARTED
LogValidatorTest > testNonCompressedV1() PASSED
LogValidatorTest > testNonCompressedV2() STARTED
LogValidatorTest > testNonCompressedV2() PASSED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() PASSED
LogValidatorTest > testInvalidCreateTimeCompressedV1() STARTED
LogValidatorTest > testInvalidCreateTimeCompressedV1() PASSED
LogValidatorTest > testInvalidCreateTimeCompressedV2() STARTED
LogValidatorTest > testInvalidCreateTimeCompressedV2() PASSED
LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() STARTED
LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() PASSED
LogValidatorTest > testRecompressionV1() STARTED
LogValidatorTest > testRecompressionV1() PASSED
LogValidatorTest > testRecompressionV2() STARTED
LogValidatorTest > testRecompressionV2() PASSED
ProducerStateManagerTest > testSkipEmptyTransactions() STARTED
ProducerStateManagerTest > testSkipEmptyTransactions() PASSED
ProducerStateManagerTest > testControlRecordBumpsProducerEpoch() STARTED
ProducerStateManagerTest > testControlRecordBumpsProducerEpoch() PASSED
ProducerStateManagerTest > testProducerSequenceWithWrapAroundBatchRecord() STARTED
ProducerStateManagerTest > testProducerSequenceWithWrapAroundBatchRecord() PASSED
ProducerStateManagerTest > testCoordinatorFencing() STARTED
ProducerStateManagerTest > testCoordinatorFencing() PASSED
ProducerStateManagerTest > testLoadFromTruncatedSnapshotFile() STARTED
ProducerStateManagerTest > testLoadFromTruncatedSnapshotFile() PASSED
ProducerStateManagerTest > testTruncateFullyAndStartAt() STARTED
ProducerStateManagerTest > testTruncateFullyAndStartAt() PASSED
ProducerStateManagerTest > testRemoveExpiredPidsOnReload() STARTED
ProducerStateManagerTest > testRemoveExpiredPidsOnReload() PASSED
ProducerStateManagerTest > testRecoverFromSnapshotFinishedTransaction() STARTED
ProducerStateManagerTest > testRecoverFromSnapshotFinishedTransaction() PASSED
ProducerStateManagerTest > testOutOfSequenceAfterControlRecordEpochBump() STARTED
ProducerStateManagerTest > testOutOfSequenceAfterControlRecordEpochBump() PASSED
ProducerStateManagerTest > testFirstUnstableOffsetAfterTruncation() STARTED
ProducerStateManagerTest > testFirstUnstableOffsetAfterTruncation() PASSED
ProducerStateManagerTest > testTakeSnapshot() STARTED
ProducerStateManagerTest > testTakeSnapshot() PASSED
ProducerStateManagerTest > testRecoverFromSnapshotUnfinishedTransaction() STARTED
ProducerStateManagerTest > testRecoverFromSnapshotUnfinishedTransaction() PASSED
ProducerStateManagerTest > testDeleteSnapshotsBefore() STARTED
ProducerStateManagerTest > testDeleteSnapshotsBefore() PASSED
ProducerStateManagerTest > testAppendEmptyControlBatch() STARTED
ProducerStateManagerTest > testAppendEmptyControlBatch() PASSED
ProducerStateManagerTest > testNoValidationOnFirstEntryWhenLoadingLog() STARTED
ProducerStateManagerTest > testNoValidationOnFirstEntryWhenLoadingLog() PASSED
ProducerStateManagerTest > testRemoveStraySnapshotsKeepCleanShutdownSnapshot() STARTED
ProducerStateManagerTest > testRemoveStraySnapshotsKeepCleanShutdownSnapshot() PASSED
ProducerStateManagerTest > testRemoveAllStraySnapshots() STARTED
ProducerStateManagerTest > testRemoveAllStraySnapshots() PASSED
ProducerStateManagerTest > testLoadFromEmptySnapshotFile() STARTED
ProducerStateManagerTest > testLoadFromEmptySnapshotFile() PASSED
ProducerStateManagerTest > testProducersWithOngoingTransactionsDontExpire() STARTED
ProducerStateManagerTest > testProducersWithOngoingTransactionsDontExpire() PASSED
ProducerStateManagerTest > testBasicIdMapping() STARTED
ProducerStateManagerTest > testBasicIdMapping() PASSED
ProducerStateManagerTest > updateProducerTransactionState() STARTED
ProducerStateManagerTest > updateProducerTransactionState() PASSED
ProducerStateManagerTest > testPrepareUpdateDoesNotMutate() STARTED
ProducerStateManagerTest > testPrepareUpdateDoesNotMutate() PASSED
ProducerStateManagerTest > testSequenceNotValidatedForGroupMetadataTopic() STARTED
ProducerStateManagerTest > testSequenceNotValidatedForGroupMetadataTopic() PASSED
ProducerStateManagerTest > testLastStableOffsetCompletedTxn() STARTED
ProducerStateManagerTest > testLastStableOffsetCompletedTxn() PASSED
ProducerStateManagerTest > testFirstUnstableOffset() STARTED
ProducerStateManagerTest > testFirstUnstableOffset() PASSED
ProducerStateManagerTest > testTxnFirstOffsetMetadataCached() STARTED
ProducerStateManagerTest > testTxnFirstOffsetMetadataCached() PASSED
ProducerStateManagerTest > testCoordinatorFencedAfterReload() STARTED
ProducerStateManagerTest > testCoordinatorFencedAfterReload() PASSED
ProducerStateManagerTest > testAcceptAppendWithoutProducerStateOnReplica() STARTED
ProducerStateManagerTest > testAcceptAppendWithoutProducerStateOnReplica() PASSED
ProducerStateManagerTest > testProducerStateAfterFencingAbortMarker() STARTED
ProducerStateManagerTest > testProducerStateAfterFencingAbortMarker() PASSED
ProducerStateManagerTest > testLoadFromCorruptSnapshotFile() STARTED
ProducerStateManagerTest > testLoadFromCorruptSnapshotFile() PASSED
ProducerStateManagerTest > testProducerSequenceWrapAround() STARTED
ProducerStateManagerTest > testProducerSequenceWrapAround() PASSED
ProducerStateManagerTest > testPidExpirationTimeout() STARTED
ProducerStateManagerTest > testPidExpirationTimeout() PASSED
ProducerStateManagerTest > testAcceptAppendWithSequenceGapsOnReplica() STARTED
ProducerStateManagerTest > testAcceptAppendWithSequenceGapsOnReplica() PASSED
ProducerStateManagerTest > testAppendTxnMarkerWithNoProducerState() STARTED
ProducerStateManagerTest > testAppendTxnMarkerWithNoProducerState() PASSED
ProducerStateManagerTest > testOldEpochForControlRecord() STARTED
ProducerStateManagerTest > testOldEpochForControlRecord() PASSED
ProducerStateManagerTest > testTruncateAndReloadRemovesOutOfRangeSnapshots() STARTED
ProducerStateManagerTest > testTruncateAndReloadRemovesOutOfRangeSnapshots() PASSED
ProducerStateManagerTest > testProducerSequenceInvalidWrapAround() STARTED
ProducerStateManagerTest > testProducerSequenceInvalidWrapAround() PASSED
ProducerStateManagerTest > testRecoverFromSnapshotEmptyTransaction() STARTED
ProducerStateManagerTest > testRecoverFromSnapshotEmptyTransaction() PASSED
ProducerStateManagerTest > testNonTransactionalAppendWithOngoingTransaction() STARTED
ProducerStateManagerTest > testNonTransactionalAppendWithOngoingTransaction() PASSED
ProducerStateManagerTest > testLoadFromSnapshotRetainsNonExpiredProducers() STARTED
ProducerStateManagerTest > testLoadFromSnapshotRetainsNonExpiredProducers() PASSED
ProducerStateManagerTest > testSkipSnapshotIfOffsetUnchanged() STARTED
ProducerStateManagerTest > testSkipSnapshotIfOffsetUnchanged() PASSED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED
3398 tests completed, 1 failed, 7 skipped
> Task :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://ci-builds.apache.org/job/Kafka/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. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 30m 18s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #478
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/478/display/redirect?page=changes>
Changes:
[github] MINOR: Improve confusing admin client shutdown logging (#10107)
------------------------------------------
[...truncated 3.59 MB...]
SocketServerTest > remoteCloseWithIncompleteBufferedReceive() PASSED
SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() STARTED
SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() PASSED
SocketServerTest > testStagedListenerStartup() STARTED
SocketServerTest > testStagedListenerStartup() PASSED
SocketServerTest > testConnectionRateLimit() STARTED
SocketServerTest > testConnectionRateLimit() PASSED
SocketServerTest > testConnectionRatePerIp() STARTED
SocketServerTest > testConnectionRatePerIp() PASSED
SocketServerTest > processCompletedSendException() STARTED
SocketServerTest > processCompletedSendException() PASSED
SocketServerTest > processDisconnectedException() STARTED
SocketServerTest > processDisconnectedException() PASSED
SocketServerTest > closingChannelWithBufferedReceives() STARTED
SocketServerTest > closingChannelWithBufferedReceives() PASSED
SocketServerTest > sendCancelledKeyException() STARTED
SocketServerTest > sendCancelledKeyException() PASSED
SocketServerTest > processCompletedReceiveException() STARTED
SocketServerTest > processCompletedReceiveException() PASSED
SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED
SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED
SocketServerTest > closingChannelSendFailure() STARTED
SocketServerTest > closingChannelSendFailure() PASSED
SocketServerTest > idleExpiryWithBufferedReceives() STARTED
SocketServerTest > idleExpiryWithBufferedReceives() PASSED
SocketServerTest > testSocketsCloseOnShutdown() STARTED
SocketServerTest > testSocketsCloseOnShutdown() PASSED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED
SocketServerTest > pollException() STARTED
SocketServerTest > pollException() PASSED
SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED
SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED
SocketServerTest > remoteCloseWithBufferedReceives() STARTED
SocketServerTest > remoteCloseWithBufferedReceives() PASSED
SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED
SocketServerTest > testThrottledSocketsClosedOnShutdown() PASSED
SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() STARTED
SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() PASSED
SocketServerTest > testInterBrokerListenerAsPrivilegedListener() STARTED
SocketServerTest > testInterBrokerListenerAsPrivilegedListener() PASSED
SocketServerTest > testSslSocketServer() STARTED
SocketServerTest > testSslSocketServer() PASSED
SocketServerTest > testDisabledRequestIsRejected() STARTED
SocketServerTest > testDisabledRequestIsRejected() PASSED
SocketServerTest > tooBigRequestIsRejected() STARTED
SocketServerTest > tooBigRequestIsRejected() PASSED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED
DynamicConnectionQuotaTest > testDynamicConnectionQuota() STARTED
DynamicConnectionQuotaTest > testDynamicConnectionQuota() PASSED
DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() STARTED
DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() PASSED
DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() STARTED
DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() PASSED
DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() STARTED
DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() PASSED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@49ef8392, value = [B@79f975dd), properties=Map(print.value -> false), expected= STARTED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@49ef8392, value = [B@79f975dd), properties=Map(print.value -> false), expected= PASSED
DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@57886d2f, value = [B@3ffa03ae), properties=Map(print.key -> true, print.value -> false), expected=someKey
STARTED
DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@57886d2f, value = [B@3ffa03ae), properties=Map(print.key -> true, print.value -> false), expected=someKey
PASSED
DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@35d1d476, value = [B@3dea5ab5), properties=Map(), expected=someValue
STARTED
DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@35d1d476, value = [B@3dea5ab5), properties=Map(), expected=someValue
PASSED
DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@299fa932, value = [B@461728dc), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP
STARTED
DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@299fa932, value = [B@461728dc), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP
PASSED
DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7dde260c, value = [B@128ee4f0), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234
STARTED
DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7dde260c, value = [B@128ee4f0), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234
PASSED
DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@460c09aa, value = [B@3922987f), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234
STARTED
DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@460c09aa, value = [B@3922987f), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234
PASSED
DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@35403711, value = [B@508cec2d), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9
STARTED
DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@35403711, value = [B@508cec2d), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9
PASSED
DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@76ebeecf, value = [B@5b27710d), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876
STARTED
DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@76ebeecf, value = [B@5b27710d), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876
PASSED
DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6f6b2dc7, value = [B@58314983), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2
STARTED
DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6f6b2dc7, value = [B@58314983), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2
PASSED
DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@114ae1e8, value = [B@2779e313), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS
STARTED
DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@114ae1e8, value = [B@2779e313), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS
PASSED
DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7556db2e, value = [B@2ec6b7e1), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue
STARTED
DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7556db2e, value = [B@2ec6b7e1), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue
PASSED
DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@68454670, value = [B@4c5110), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ STARTED
DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@68454670, value = [B@4c5110), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ PASSED
DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4380759c, value = [B@5862bbb2), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue
STARTED
DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4380759c, value = [B@5862bbb2), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue
PASSED
DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@78f01683, value = [B@389cb094), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE
STARTED
DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@78f01683, value = [B@389cb094), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE
PASSED
DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@75ee331e, value = [B@5f12bbfb), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue
STARTED
DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@75ee331e, value = [B@5f12bbfb), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue
PASSED
DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@272efa94, value = [B@7a6bf6f5), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue
STARTED
DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@272efa94, value = [B@7a6bf6f5), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue
PASSED
DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@64b45b73, value = [B@414dc54e), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue
STARTED
DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@64b45b73, value = [B@414dc54e), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue
PASSED
DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7583c366, value = null), properties=Map(print.key -> true), expected=someKey null
STARTED
DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7583c366, value = null), properties=Map(print.key -> true), expected=someKey null
PASSED
DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@36b7a7f5, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
STARTED
DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@36b7a7f5, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
PASSED
3398 tests completed, 1 failed, 7 skipped
> Task :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://ci-builds.apache.org/job/Kafka/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. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 28m 2s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #477
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/477/display/redirect?page=changes>
Changes:
[github] MINOR: Add BrokerMetadataListener (#10111)
------------------------------------------
[...truncated 3.59 MB...]
SimpleAclAuthorizerTest > testAllowAccessWithCustomPrincipal() PASSED
SimpleAclAuthorizerTest > testDeleteAclOnWildcardResource() STARTED
SimpleAclAuthorizerTest > testDeleteAclOnWildcardResource() PASSED
SimpleAclAuthorizerTest > testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions() STARTED
SimpleAclAuthorizerTest > testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions() PASSED
SimpleAclAuthorizerTest > testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() STARTED
SimpleAclAuthorizerTest > testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() PASSED
SimpleAclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnPrefixedResource() STARTED
SimpleAclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnPrefixedResource() PASSED
SimpleAclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls() STARTED
SimpleAclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls() PASSED
SimpleAclAuthorizerTest > testAuthorizeWithEmptyResourceName() STARTED
SimpleAclAuthorizerTest > testAuthorizeWithEmptyResourceName() PASSED
SimpleAclAuthorizerTest > testAuthorizeThrowsOnNonLiteralResource() STARTED
SimpleAclAuthorizerTest > testAuthorizeThrowsOnNonLiteralResource() PASSED
SimpleAclAuthorizerTest > testDeleteAllAclOnPrefixedResource() STARTED
SimpleAclAuthorizerTest > testDeleteAllAclOnPrefixedResource() PASSED
SimpleAclAuthorizerTest > testAddAclsOnLiteralResource() STARTED
SimpleAclAuthorizerTest > testAddAclsOnLiteralResource() PASSED
SimpleAclAuthorizerTest > testGetAclsPrincipal() STARTED
SimpleAclAuthorizerTest > testGetAclsPrincipal() PASSED
SimpleAclAuthorizerTest > testAddAclsOnPrefiexedResource() STARTED
SimpleAclAuthorizerTest > testAddAclsOnPrefiexedResource() PASSED
SimpleAclAuthorizerTest > testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() STARTED
SimpleAclAuthorizerTest > testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() PASSED
SimpleAclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnWildcardResource() STARTED
SimpleAclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnWildcardResource() PASSED
SimpleAclAuthorizerTest > testLoadCache() STARTED
SimpleAclAuthorizerTest > testLoadCache() PASSED
OperationTest > testJavaConversions() STARTED
OperationTest > testJavaConversions() PASSED
AclEntryTest > testAclJsonConversion() STARTED
AclEntryTest > testAclJsonConversion() PASSED
MiniKdcTest > shouldNotStopImmediatelyWhenStarted() STARTED
MiniKdcTest > shouldNotStopImmediatelyWhenStarted() PASSED
RaftManagerTest > testShutdownIoThread() STARTED
RaftManagerTest > testShutdownIoThread() PASSED
RaftManagerTest > testUncaughtExceptionInIoThread() STARTED
RaftManagerTest > testUncaughtExceptionInIoThread() PASSED
KafkaNetworkChannelTest > testWakeupClientOnSend() STARTED
KafkaNetworkChannelTest > testWakeupClientOnSend() PASSED
KafkaNetworkChannelTest > testSendToBlackedOutDestination() STARTED
KafkaNetworkChannelTest > testSendToBlackedOutDestination() PASSED
KafkaNetworkChannelTest > testSendAndFailAuthentication() STARTED
KafkaNetworkChannelTest > testSendAndFailAuthentication() PASSED
KafkaNetworkChannelTest > testSendAndReceiveOutboundRequest() STARTED
KafkaNetworkChannelTest > testSendAndReceiveOutboundRequest() PASSED
KafkaNetworkChannelTest > testSendAndDisconnect() STARTED
KafkaNetworkChannelTest > testSendAndDisconnect() PASSED
KafkaNetworkChannelTest > testSendToUnknownDestination() STARTED
KafkaNetworkChannelTest > testSendToUnknownDestination() PASSED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@60be9255, value = [B@24333b87), properties=Map(print.value -> false), expected= STARTED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@60be9255, value = [B@24333b87), properties=Map(print.value -> false), expected= PASSED
DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@5c882ae7, value = [B@61daddf2), properties=Map(print.key -> true, print.value -> false), expected=someKey
STARTED
DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@5c882ae7, value = [B@61daddf2), properties=Map(print.key -> true, print.value -> false), expected=someKey
PASSED
DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@152f1757, value = [B@5cfa5cb9), properties=Map(), expected=someValue
STARTED
DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@152f1757, value = [B@5cfa5cb9), properties=Map(), expected=someValue
PASSED
DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@41b89ad3, value = [B@763afa5b), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP
STARTED
DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@41b89ad3, value = [B@763afa5b), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP
PASSED
DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1bc2ce64, value = [B@15534631), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234
STARTED
DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1bc2ce64, value = [B@15534631), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234
PASSED
DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1038384a, value = [B@3171e034), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234
STARTED
DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1038384a, value = [B@3171e034), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234
PASSED
DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@3ccdb990, value = [B@33a012f6), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9
STARTED
DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@3ccdb990, value = [B@33a012f6), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9
PASSED
DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@620b86a0, value = [B@5cc5ba95), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876
STARTED
DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@620b86a0, value = [B@5cc5ba95), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876
PASSED
DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@d9599a4, value = [B@3e911d42), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2
STARTED
DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@d9599a4, value = [B@3e911d42), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2
PASSED
DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@17c8f4d1, value = [B@5a250f6), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS
STARTED
DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@17c8f4d1, value = [B@5a250f6), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS
PASSED
DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4a3a55de, value = [B@40bde993), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue
STARTED
DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4a3a55de, value = [B@40bde993), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue
PASSED
DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1003e329, value = [B@7b1243f), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ STARTED
DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1003e329, value = [B@7b1243f), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ PASSED
DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1f3d05b2, value = [B@30e396b7), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue
STARTED
DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1f3d05b2, value = [B@30e396b7), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue
PASSED
DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@31686a34, value = [B@460ff93e), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE
STARTED
DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@31686a34, value = [B@460ff93e), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE
PASSED
DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6af59966, value = [B@64849268), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue
STARTED
DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6af59966, value = [B@64849268), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue
PASSED
DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@164f6d06, value = [B@2f30b0f8), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue
STARTED
DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@164f6d06, value = [B@2f30b0f8), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue
PASSED
DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4455953a, value = [B@6e485a38), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue
STARTED
DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4455953a, value = [B@6e485a38), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue
PASSED
DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@463e338a, value = null), properties=Map(print.key -> true), expected=someKey null
STARTED
DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@463e338a, value = null), properties=Map(print.key -> true), expected=someKey null
PASSED
DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@10251c75, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
STARTED
DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@10251c75, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
PASSED
3398 tests completed, 1 failed, 7 skipped
> Task :core:test FAILED
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/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. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':core:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/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. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 33m 28s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #476
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/476/display/redirect?page=changes>
Changes:
[github] MINOR: Introduce the KIP-500 Broker lifecycle manager (#10095)
[github] MINOR: add the MetaLogListener, LocalLogManager, and Controller interface. (#10106)
[github] MINOR: Support Raft-based metadata quorums in system tests (#10093)
------------------------------------------
[...truncated 3.61 MB...]
JsonTest > testJsonParse() STARTED
JsonTest > testJsonParse() PASSED
JsonTest > testEncodeAsBytes() STARTED
JsonTest > testEncodeAsBytes() PASSED
JsonTest > testEncodeAsString() STARTED
JsonTest > testEncodeAsString() PASSED
ShutdownableThreadTest > testShutdownWhenCalledAfterThreadStart() STARTED
ShutdownableThreadTest > testShutdownWhenCalledAfterThreadStart() PASSED
QuotaUtilsTest > testBoundedThrottleTimeObservedRateAboveQuotaAboveLimit() STARTED
QuotaUtilsTest > testBoundedThrottleTimeObservedRateAboveQuotaAboveLimit() PASSED
QuotaUtilsTest > testThrottleTimeObservedRateBelowQuota() STARTED
QuotaUtilsTest > testThrottleTimeObservedRateBelowQuota() PASSED
QuotaUtilsTest > testBoundedThrottleTimeObservedRateBelowQuota() STARTED
QuotaUtilsTest > testBoundedThrottleTimeObservedRateBelowQuota() PASSED
QuotaUtilsTest > testBoundedThrottleTimeThrowsExceptionIfProvidedNonRateMetric() STARTED
QuotaUtilsTest > testBoundedThrottleTimeThrowsExceptionIfProvidedNonRateMetric() PASSED
QuotaUtilsTest > testBoundedThrottleTimeObservedRateAboveQuotaBelowLimit() STARTED
QuotaUtilsTest > testBoundedThrottleTimeObservedRateAboveQuotaBelowLimit() PASSED
QuotaUtilsTest > testBoundedThrottleTimeObservedRateEqualsQuota() STARTED
QuotaUtilsTest > testBoundedThrottleTimeObservedRateEqualsQuota() PASSED
QuotaUtilsTest > testThrottleTimeThrowsExceptionIfProvidedNonRateMetric() STARTED
QuotaUtilsTest > testThrottleTimeThrowsExceptionIfProvidedNonRateMetric() PASSED
QuotaUtilsTest > testThrottleTimeObservedRateEqualsQuota() STARTED
QuotaUtilsTest > testThrottleTimeObservedRateEqualsQuota() PASSED
QuotaUtilsTest > testThrottleTimeObservedRateAboveQuota() STARTED
QuotaUtilsTest > testThrottleTimeObservedRateAboveQuota() PASSED
TimerTaskListTest > testAll() STARTED
TimerTaskListTest > testAll() PASSED
CoreUtilsTest > testGenerateUuidAsBase64() STARTED
CoreUtilsTest > testGenerateUuidAsBase64() PASSED
CoreUtilsTest > testAbs() STARTED
CoreUtilsTest > testAbs() PASSED
CoreUtilsTest > testReplaceSuffix() STARTED
CoreUtilsTest > testReplaceSuffix() PASSED
CoreUtilsTest > testCircularIterator() STARTED
CoreUtilsTest > testCircularIterator() PASSED
CoreUtilsTest > testReadBytes() STARTED
CoreUtilsTest > testReadBytes() PASSED
CoreUtilsTest > testCsvList() STARTED
CoreUtilsTest > testCsvList() PASSED
CoreUtilsTest > testReadInt() STARTED
CoreUtilsTest > testReadInt() PASSED
CoreUtilsTest > testAtomicGetOrUpdate() STARTED
CoreUtilsTest > testAtomicGetOrUpdate() PASSED
CoreUtilsTest > testUrlSafeBase64EncodeUUID() STARTED
CoreUtilsTest > testUrlSafeBase64EncodeUUID() PASSED
CoreUtilsTest > testCsvMap() STARTED
CoreUtilsTest > testCsvMap() PASSED
CoreUtilsTest > testInLock() STARTED
CoreUtilsTest > testInLock() PASSED
CoreUtilsTest > testTryAll() STARTED
CoreUtilsTest > testTryAll() PASSED
CoreUtilsTest > testSwallow() STARTED
CoreUtilsTest > testSwallow() PASSED
ExitTest > shouldAddShutdownHookImmediately() STARTED
ExitTest > shouldAddShutdownHookImmediately() PASSED
ExitTest > shouldHaltImmediately() STARTED
ExitTest > shouldHaltImmediately() PASSED
ExitTest > shouldExitImmediately() STARTED
ExitTest > shouldExitImmediately() PASSED
ExitTest > shouldNotInvokeShutdownHookImmediately() STARTED
ExitTest > shouldNotInvokeShutdownHookImmediately() PASSED
KafkaMetadataLogTest > testFailToIncreaseLogStartPastHighWatermark() STARTED
KafkaMetadataLogTest > testFailToIncreaseLogStartPastHighWatermark() PASSED
KafkaMetadataLogTest > testCreateReplicatedLogTruncatesFully() STARTED
KafkaMetadataLogTest > testCreateReplicatedLogTruncatesFully() PASSED
KafkaMetadataLogTest > testCreateSnapshot() STARTED
KafkaMetadataLogTest > testCreateSnapshot() PASSED
KafkaMetadataLogTest > testUpdateLogStartOffset() STARTED
KafkaMetadataLogTest > testUpdateLogStartOffset() PASSED
KafkaMetadataLogTest > testCleanupSnapshots() STARTED
KafkaMetadataLogTest > testCleanupSnapshots() PASSED
KafkaMetadataLogTest > testTruncateFullyToLatestSnapshot() STARTED
KafkaMetadataLogTest > testTruncateFullyToLatestSnapshot() PASSED
KafkaMetadataLogTest > testDoesntTruncateFully() STARTED
KafkaMetadataLogTest > testDoesntTruncateFully() PASSED
KafkaMetadataLogTest > testUpdateLogStartOffsetWithMissingSnapshot() STARTED
KafkaMetadataLogTest > testUpdateLogStartOffsetWithMissingSnapshot() PASSED
KafkaMetadataLogTest > testReadMissingSnapshot() STARTED
KafkaMetadataLogTest > testReadMissingSnapshot() PASSED
RaftManagerTest > testShutdownIoThread() STARTED
RaftManagerTest > testShutdownIoThread() PASSED
RaftManagerTest > testUncaughtExceptionInIoThread() STARTED
RaftManagerTest > testUncaughtExceptionInIoThread() PASSED
RequestChannelTest > testNonAlterRequestsNotTransformed() STARTED
RequestChannelTest > testNonAlterRequestsNotTransformed() PASSED
RequestChannelTest > testAlterRequests() STARTED
RequestChannelTest > testAlterRequests() PASSED
RequestChannelTest > testJsonRequests() STARTED
RequestChannelTest > testJsonRequests() PASSED
RequestChannelTest > testIncrementalAlterRequests() STARTED
RequestChannelTest > testIncrementalAlterRequests() PASSED
ControllerContextTest > testPartitionFullReplicaAssignmentReturnsEmptyAssignmentIfTopicOrPartitionDoesNotExist() STARTED
ControllerContextTest > testPartitionFullReplicaAssignmentReturnsEmptyAssignmentIfTopicOrPartitionDoesNotExist() PASSED
ControllerContextTest > testPartitionReplicaAssignmentForTopicReturnsEmptyMapIfTopicDoesNotExist() STARTED
ControllerContextTest > testPartitionReplicaAssignmentForTopicReturnsEmptyMapIfTopicDoesNotExist() PASSED
ControllerContextTest > testPreferredReplicaImbalanceMetric() STARTED
ControllerContextTest > testPreferredReplicaImbalanceMetric() PASSED
ControllerContextTest > testPartitionReplicaAssignmentForTopicReturnsExpectedReplicaAssignments() STARTED
ControllerContextTest > testPartitionReplicaAssignmentForTopicReturnsExpectedReplicaAssignments() PASSED
ControllerContextTest > testReassignTo() STARTED
ControllerContextTest > testReassignTo() PASSED
ControllerContextTest > testPartitionReplicaAssignment() STARTED
ControllerContextTest > testPartitionReplicaAssignment() PASSED
ControllerContextTest > testUpdatePartitionFullReplicaAssignmentUpdatesReplicaAssignment() STARTED
ControllerContextTest > testUpdatePartitionFullReplicaAssignmentUpdatesReplicaAssignment() PASSED
ControllerContextTest > testReassignToIdempotence() STARTED
ControllerContextTest > testReassignToIdempotence() PASSED
ControllerContextTest > testPartitionReplicaAssignmentReturnsEmptySeqIfTopicOrPartitionDoesNotExist() STARTED
ControllerContextTest > testPartitionReplicaAssignmentReturnsEmptySeqIfTopicOrPartitionDoesNotExist() PASSED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED
3398 tests completed, 1 failed, 7 skipped
> Task :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://ci-builds.apache.org/job/Kafka/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. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 34m 59s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #475
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/475/display/redirect?page=changes>
Changes:
[github] MINOR: Remove always-passing validation in TestRecordTest#testProducerRecord (#9930)
------------------------------------------
[...truncated 3.65 MB...]
SaslOAuthBearerSslEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() STARTED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() STARTED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoGroupAcl() STARTED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoGroupAcl() PASSED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl() STARTED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl() PASSED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl() STARTED
SaslOAuthBearerSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl() PASSED
SaslOAuthBearerSslEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() STARTED
SaslOAuthBearerSslEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED
SaslOAuthBearerSslEndToEndAuthorizationTest > testTwoConsumersWithDifferentSaslCredentials() STARTED
SaslOAuthBearerSslEndToEndAuthorizationTest > testTwoConsumersWithDifferentSaslCredentials() PASSED
SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() STARTED
SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() PASSED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() STARTED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() PASSED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeViaAssign() STARTED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeViaAssign() PASSED
SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() STARTED
SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() PASSED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() STARTED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() PASSED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() STARTED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED
SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() STARTED
SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED
SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() STARTED
SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED
SaslPlainSslEndToEndAuthorizationTest > testNoGroupAcl() STARTED
SaslPlainSslEndToEndAuthorizationTest > testNoGroupAcl() PASSED
SaslPlainSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl() STARTED
SaslPlainSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl() PASSED
SaslPlainSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl() STARTED
SaslPlainSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl() PASSED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() STARTED
SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED
SaslPlainSslEndToEndAuthorizationTest > testTwoConsumersWithDifferentSaslCredentials() STARTED
SaslPlainSslEndToEndAuthorizationTest > testTwoConsumersWithDifferentSaslCredentials() PASSED
SaslPlainSslEndToEndAuthorizationTest > testAcls() STARTED
SaslPlainSslEndToEndAuthorizationTest > testAcls() PASSED
SslAdminIntegrationTest > testCreateDeleteTopics() STARTED
SslAdminIntegrationTest > testCreateDeleteTopics() PASSED
SslAdminIntegrationTest > testAuthorizedOperations() STARTED
SslAdminIntegrationTest > testAuthorizedOperations() PASSED
SslAdminIntegrationTest > testAclDescribe() STARTED
SslAdminIntegrationTest > testAclDescribe() PASSED
SslAdminIntegrationTest > testLegacyAclOpsNeverAffectOrReturnPrefixed() STARTED
SslAdminIntegrationTest > testLegacyAclOpsNeverAffectOrReturnPrefixed() PASSED
SslAdminIntegrationTest > testCreateTopicsResponseMetadataAndConfig() STARTED
SslAdminIntegrationTest > testCreateTopicsResponseMetadataAndConfig() PASSED
SslAdminIntegrationTest > testAttemptToCreateInvalidAcls() STARTED
SslAdminIntegrationTest > testAttemptToCreateInvalidAcls() PASSED
SslAdminIntegrationTest > testAclAuthorizationDenied() STARTED
SslAdminIntegrationTest > testAclAuthorizationDenied() PASSED
SslAdminIntegrationTest > testAclOperations() STARTED
SslAdminIntegrationTest > testAclOperations() PASSED
SslAdminIntegrationTest > testAclOperations2() STARTED
SslAdminIntegrationTest > testAclOperations2() PASSED
SslAdminIntegrationTest > testAclDelete() STARTED
SslAdminIntegrationTest > testAclDelete() PASSED
SslAdminIntegrationTest > testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads() STARTED
SslAdminIntegrationTest > testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads() PASSED
SslAdminIntegrationTest > testSynchronousAuthorizerAclUpdatesBlockRequestThreads() STARTED
SslAdminIntegrationTest > testSynchronousAuthorizerAclUpdatesBlockRequestThreads() PASSED
SslAdminIntegrationTest > testAclUpdatesUsingAsynchronousAuthorizer() STARTED
SslAdminIntegrationTest > testAclUpdatesUsingAsynchronousAuthorizer() PASSED
SslAdminIntegrationTest > testAclUpdatesUsingSynchronousAuthorizer() STARTED
SslAdminIntegrationTest > testAclUpdatesUsingSynchronousAuthorizer() PASSED
TransactionsExpirationTest > testBumpTransactionalEpochAfterInvalidProducerIdMapping() STARTED
TransactionsExpirationTest > testBumpTransactionalEpochAfterInvalidProducerIdMapping() PASSED
DescribeAuthorizedOperationsTest > testClusterAuthorizedOperations() STARTED
DescribeAuthorizedOperationsTest > testClusterAuthorizedOperations() PASSED
DescribeAuthorizedOperationsTest > testTopicAuthorizedOperations() STARTED
DescribeAuthorizedOperationsTest > testTopicAuthorizedOperations() PASSED
DescribeAuthorizedOperationsTest > testConsumerGroupAuthorizedOperations() STARTED
DescribeAuthorizedOperationsTest > testConsumerGroupAuthorizedOperations() PASSED
CustomQuotaCallbackTest > testCustomQuotaCallback() STARTED
CustomQuotaCallbackTest > testCustomQuotaCallback() PASSED
GroupAuthorizerIntegrationTest > testUnauthorizedProduceAndConsume() STARTED
GroupAuthorizerIntegrationTest > testUnauthorizedProduceAndConsume() PASSED
GroupAuthorizerIntegrationTest > testAuthorizedProduceAndConsume() STARTED
GroupAuthorizerIntegrationTest > testAuthorizedProduceAndConsume() PASSED
TransactionsBounceTest > testWithGroupMetadata() STARTED
TransactionsBounceTest > testWithGroupMetadata() PASSED
TransactionsBounceTest > testWithGroupId() STARTED
TransactionsBounceTest > testWithGroupId() PASSED
UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() STARTED
UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED
UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() STARTED
UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED
UserClientIdQuotaTest > testThrottledProducerConsumer() STARTED
UserClientIdQuotaTest > testThrottledProducerConsumer() PASSED
UserClientIdQuotaTest > testQuotaOverrideDelete() STARTED
UserClientIdQuotaTest > testQuotaOverrideDelete() PASSED
UserClientIdQuotaTest > testThrottledRequest() STARTED
UserClientIdQuotaTest > testThrottledRequest() PASSED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED
3393 tests completed, 3 failed, 7 skipped
> Task :core:test FAILED
FAILURE: Build completed with 3 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':connect:mirror:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/ws/connect/mirror/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.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/ws/connect/runtime/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.
==============================================================================
3: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':core:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/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. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 39m 7s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #474
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/474/display/redirect?page=changes>
Changes:
[github] KAFKA-5235: GetOffsetShell: Support for multiple topics and consumer configuration override (KIP-635) (#9430)
------------------------------------------
[...truncated 7.21 MB...]
LogTest > testFetchUpToLogEndOffset() STARTED
LogTest > testFetchUpToLogEndOffset() PASSED
LogTest > testLastStableOffsetDoesNotExceedLogStartOffsetMidSegment() STARTED
LogTest > testLastStableOffsetDoesNotExceedLogStartOffsetMidSegment() PASSED
LogTest > testDeleteSnapshotsOnIncrementLogStartOffset() STARTED
LogTest > testDeleteSnapshotsOnIncrementLogStartOffset() PASSED
LogTest > testCorruptIndexRebuild() STARTED
LogTest > testCorruptIndexRebuild() PASSED
LogTest > shouldDeleteTimeBasedSegmentsReadyToBeDeleted() STARTED
LogTest > shouldDeleteTimeBasedSegmentsReadyToBeDeleted() PASSED
LogTest > testReadWithTooSmallMaxLength() STARTED
LogTest > testReadWithTooSmallMaxLength() PASSED
LogTest > testOverCompactedLogRecovery() STARTED
LogTest > testOverCompactedLogRecovery() PASSED
LogTest > testBogusIndexSegmentsAreRemoved() STARTED
LogTest > testBogusIndexSegmentsAreRemoved() PASSED
LogTest > testLeaderEpochCacheClearedAfterStaticMessageFormatDowngrade() STARTED
LogTest > testLeaderEpochCacheClearedAfterStaticMessageFormatDowngrade() PASSED
LogTest > testCompressedMessages() STARTED
LogTest > testCompressedMessages() PASSED
LogTest > testAppendMessageWithNullPayload() STARTED
LogTest > testAppendMessageWithNullPayload() PASSED
LogTest > testCorruptLog() STARTED
LogTest > testCorruptLog() PASSED
LogTest > testLogRecoversToCorrectOffset() STARTED
LogTest > testLogRecoversToCorrectOffset() PASSED
LogTest > testReopenThenTruncate() STARTED
LogTest > testReopenThenTruncate() PASSED
LogTest > testZombieCoordinatorFenced() STARTED
LogTest > testZombieCoordinatorFenced() PASSED
LogTest > testOldProducerEpoch() STARTED
LogTest > testOldProducerEpoch() PASSED
LogTest > testProducerSnapshotsRecoveryAfterUncleanShutdownV1() STARTED
LogTest > testProducerSnapshotsRecoveryAfterUncleanShutdownV1() PASSED
LogTest > testDegenerateSegmentSplit() STARTED
LogTest > testDegenerateSegmentSplit() PASSED
LogTest > testParseTopicPartitionNameForMissingPartition() STARTED
LogTest > testParseTopicPartitionNameForMissingPartition() PASSED
LogTest > testParseTopicPartitionNameForEmptyName() STARTED
LogTest > testParseTopicPartitionNameForEmptyName() PASSED
LogTest > testOffsetSnapshot() STARTED
LogTest > testOffsetSnapshot() PASSED
LogTest > testOpenDeletesObsoleteFiles() STARTED
LogTest > testOpenDeletesObsoleteFiles() PASSED
LogTest > shouldUpdateOffsetForLeaderEpochsWhenDeletingSegments() STARTED
LogTest > shouldUpdateOffsetForLeaderEpochsWhenDeletingSegments() PASSED
LogTest > testLogDeleteDirName() STARTED
LogTest > testLogDeleteDirName() PASSED
LogTest > testDeleteOldSegments() STARTED
LogTest > testDeleteOldSegments() PASSED
LogTest > testRebuildTimeIndexForOldMessages() STARTED
LogTest > testRebuildTimeIndexForOldMessages() PASSED
LogTest > testProducerIdMapTruncateTo() STARTED
LogTest > testProducerIdMapTruncateTo() PASSED
LogTest > testTakeSnapshotOnRollAndDeleteSnapshotOnRecoveryPointCheckpoint() STARTED
LogTest > testTakeSnapshotOnRollAndDeleteSnapshotOnRecoveryPointCheckpoint() PASSED
LogTest > testLogEndLessThanStartAfterReopen() STARTED
LogTest > testLogEndLessThanStartAfterReopen() PASSED
LogTest > testLogRecoversForLeaderEpoch() STARTED
LogTest > testLogRecoversForLeaderEpoch() PASSED
LogTest > testRetentionDeletesProducerStateSnapshots() STARTED
LogTest > testRetentionDeletesProducerStateSnapshots() PASSED
LogTest > testLoadingLogDeletesProducerStateSnapshotsPastLogEndOffset() STARTED
LogTest > testLoadingLogDeletesProducerStateSnapshotsPastLogEndOffset() PASSED
LogTest > testWriteLeaderEpochCheckpointAfterDirectoryRename() STARTED
LogTest > testWriteLeaderEpochCheckpointAfterDirectoryRename() PASSED
LogTest > testOverCompactedLogRecoveryMultiRecord() STARTED
LogTest > testOverCompactedLogRecoveryMultiRecord() PASSED
LogTest > testSizeBasedLogRoll() STARTED
LogTest > testSizeBasedLogRoll() PASSED
LogTest > testRebuildProducerIdMapWithCompactedData() STARTED
LogTest > testRebuildProducerIdMapWithCompactedData() PASSED
LogTest > shouldNotDeleteSizeBasedSegmentsWhenUnderRetentionSize() STARTED
LogTest > shouldNotDeleteSizeBasedSegmentsWhenUnderRetentionSize() PASSED
LogTest > testTransactionIndexUpdatedThroughReplication() STARTED
LogTest > testTransactionIndexUpdatedThroughReplication() PASSED
LogTest > testTimeBasedLogRollJitter() STARTED
LogTest > testTimeBasedLogRollJitter() PASSED
LogTest > testParseTopicPartitionName() STARTED
LogTest > testParseTopicPartitionName() PASSED
LogTest > testEndTxnWithFencedProducerEpoch() STARTED
LogTest > testEndTxnWithFencedProducerEpoch() PASSED
LogTest > testRecoveryOfSegmentWithOffsetOverflow() STARTED
LogTest > testRecoveryOfSegmentWithOffsetOverflow() PASSED
LogTest > testRecoverAfterNonMonotonicCoordinatorEpochWrite() STARTED
LogTest > testRecoverAfterNonMonotonicCoordinatorEpochWrite() PASSED
LogTest > testLoadProducersAfterDeleteRecordsMidSegment() STARTED
LogTest > testLoadProducersAfterDeleteRecordsMidSegment() PASSED
LogTest > testInitializationOfProducerSnapshotsUpgradePath() STARTED
LogTest > testInitializationOfProducerSnapshotsUpgradePath() PASSED
LogTest > shouldDeleteStartOffsetBreachedSegmentsWhenPolicyDoesNotIncludeDelete() STARTED
LogTest > shouldDeleteStartOffsetBreachedSegmentsWhenPolicyDoesNotIncludeDelete() PASSED
LogTest > testSkipLoadingIfEmptyProducerStateBeforeTruncation() STARTED
LogTest > testSkipLoadingIfEmptyProducerStateBeforeTruncation() PASSED
LogTest > testTruncateTo() STARTED
LogTest > testTruncateTo() PASSED
LogTest > testSkipTruncateAndReloadIfNewMessageFormatAndCleanShutdown() STARTED
LogTest > testSkipTruncateAndReloadIfNewMessageFormatAndCleanShutdown() PASSED
LogTest > shouldApplyEpochToMessageOnAppendIfLeader() STARTED
LogTest > shouldApplyEpochToMessageOnAppendIfLeader() PASSED
LogTest > testLogDeletionAfterClose() STARTED
LogTest > testLogDeletionAfterClose() PASSED
LogTest > testLoadProducersAfterDeleteRecordsOnSegment() STARTED
LogTest > testLoadProducersAfterDeleteRecordsOnSegment() PASSED
LogTest > testAppendToOrReadFromLogInFailedLogDir() STARTED
LogTest > testAppendToOrReadFromLogInFailedLogDir() PASSED
LogTest > testCleanShutdownFile() STARTED
LogTest > testCleanShutdownFile() PASSED
LogTest > testTransactionIndexUpdated() STARTED
LogTest > testTransactionIndexUpdated() PASSED
LogTest > testBuildTimeIndexWhenNotAssigningOffsets() STARTED
LogTest > testBuildTimeIndexWhenNotAssigningOffsets() PASSED
LogTest > testProducerExpireCheckAfterDelete() STARTED
LogTest > testProducerExpireCheckAfterDelete() PASSED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/ws/connect/runtime/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
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 58m 10s
250 actionable tasks: 243 executed, 7 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #473
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/473/display/redirect?page=changes>
Changes:
[github] MINOR: Prevent creating partition.metadata until ID can be written (#10041)
------------------------------------------
[...truncated 3.58 MB...]
PlaintextAdminIntegrationTest > testValidIncrementalAlterConfigs() PASSED
PlaintextAdminIntegrationTest > testInvalidIncrementalAlterConfigs() STARTED
PlaintextAdminIntegrationTest > testInvalidIncrementalAlterConfigs() PASSED
PlaintextAdminIntegrationTest > testSeekAfterDeleteRecords() STARTED
PlaintextAdminIntegrationTest > testSeekAfterDeleteRecords() PASSED
PlaintextAdminIntegrationTest > testCallInFlightTimeouts() STARTED
PlaintextAdminIntegrationTest > testCallInFlightTimeouts() PASSED
PlaintextAdminIntegrationTest > testNullConfigs() STARTED
PlaintextAdminIntegrationTest > testNullConfigs() PASSED
PlaintextAdminIntegrationTest > testDescribeConfigsForTopic() STARTED
PlaintextAdminIntegrationTest > testDescribeConfigsForTopic() PASSED
PlaintextAdminIntegrationTest > testConsumerGroups() STARTED
PlaintextAdminIntegrationTest > testConsumerGroups() PASSED
PlaintextAdminIntegrationTest > testElectUncleanLeadersWhenNoLiveBrokers() STARTED
PlaintextAdminIntegrationTest > testElectUncleanLeadersWhenNoLiveBrokers() PASSED
PlaintextAdminIntegrationTest > testCreateExistingTopicsThrowTopicExistsException() STARTED
PlaintextAdminIntegrationTest > testCreateExistingTopicsThrowTopicExistsException() PASSED
ClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() STARTED
ClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED
ClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() STARTED
ClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED
ClientIdQuotaTest > testThrottledProducerConsumer() STARTED
ClientIdQuotaTest > testThrottledProducerConsumer() PASSED
ClientIdQuotaTest > testQuotaOverrideDelete() STARTED
ClientIdQuotaTest > testQuotaOverrideDelete() PASSED
ClientIdQuotaTest > testThrottledRequest() STARTED
ClientIdQuotaTest > testThrottledRequest() PASSED
ProducerCompressionTest > [1] compression=none STARTED
ProducerCompressionTest > [1] compression=none PASSED
ProducerCompressionTest > [2] compression=gzip STARTED
ProducerCompressionTest > [2] compression=gzip PASSED
ProducerCompressionTest > [3] compression=snappy STARTED
ProducerCompressionTest > [3] compression=snappy PASSED
ProducerCompressionTest > [4] compression=lz4 STARTED
ProducerCompressionTest > [4] compression=lz4 PASSED
ProducerCompressionTest > [5] compression=zstd STARTED
ProducerCompressionTest > [5] compression=zstd PASSED
DescribeAuthorizedOperationsTest > testClusterAuthorizedOperations() STARTED
DescribeAuthorizedOperationsTest > testClusterAuthorizedOperations() PASSED
DescribeAuthorizedOperationsTest > testTopicAuthorizedOperations() STARTED
DescribeAuthorizedOperationsTest > testTopicAuthorizedOperations() PASSED
DescribeAuthorizedOperationsTest > testConsumerGroupAuthorizedOperations() STARTED
DescribeAuthorizedOperationsTest > testConsumerGroupAuthorizedOperations() PASSED
GroupCoordinatorIntegrationTest > testGroupCoordinatorPropagatesOffsetsTopicCompressionCodec() STARTED
GroupCoordinatorIntegrationTest > testGroupCoordinatorPropagatesOffsetsTopicCompressionCodec() PASSED
UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() STARTED
UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED
UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() STARTED
UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED
UserClientIdQuotaTest > testThrottledProducerConsumer() STARTED
UserClientIdQuotaTest > testThrottledProducerConsumer() PASSED
UserClientIdQuotaTest > testQuotaOverrideDelete() STARTED
UserClientIdQuotaTest > testQuotaOverrideDelete() PASSED
UserClientIdQuotaTest > testThrottledRequest() STARTED
UserClientIdQuotaTest > testThrottledRequest() PASSED
MinIsrConfigTest > testDefaultKafkaConfig() STARTED
MinIsrConfigTest > testDefaultKafkaConfig() PASSED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@510d80e7, value = [B@34f83951), properties=Map(print.value -> false), expected= STARTED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@510d80e7, value = [B@34f83951), properties=Map(print.value -> false), expected= PASSED
DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7e959926, value = [B@b520514), properties=Map(print.key -> true, print.value -> false), expected=someKey
STARTED
DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7e959926, value = [B@b520514), properties=Map(print.key -> true, print.value -> false), expected=someKey
PASSED
DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7634d789, value = [B@245c3899), properties=Map(), expected=someValue
STARTED
DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7634d789, value = [B@245c3899), properties=Map(), expected=someValue
PASSED
DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7652d99d, value = [B@6db318e6), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP
STARTED
DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7652d99d, value = [B@6db318e6), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP
PASSED
DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@3d6b0246, value = [B@78b66d82), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234
STARTED
DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@3d6b0246, value = [B@78b66d82), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234
PASSED
DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1848cd38, value = [B@6dc992ff), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234
STARTED
DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1848cd38, value = [B@6dc992ff), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234
PASSED
DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@8d5c432, value = [B@43c472d7), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9
STARTED
DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@8d5c432, value = [B@43c472d7), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9
PASSED
DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1dbb569a, value = [B@3c4461b8), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876
STARTED
DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1dbb569a, value = [B@3c4461b8), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876
PASSED
DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1a96d656, value = [B@7aa45d19), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2
STARTED
DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1a96d656, value = [B@7aa45d19), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2
PASSED
DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@22ba24e5, value = [B@eb27282), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS
STARTED
DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@22ba24e5, value = [B@eb27282), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS
PASSED
DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@5626bad8, value = [B@d4bc50e), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue
STARTED
DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@5626bad8, value = [B@d4bc50e), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue
PASSED
DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7ea5554e, value = [B@639e1e7a), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ STARTED
DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7ea5554e, value = [B@639e1e7a), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ PASSED
DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@d98ab, value = [B@533d4e11), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue
STARTED
DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@d98ab, value = [B@533d4e11), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue
PASSED
DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7666e1d, value = [B@1498cd45), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE
STARTED
DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7666e1d, value = [B@1498cd45), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE
PASSED
DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@783cd7bd, value = [B@41c8436d), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue
STARTED
DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@783cd7bd, value = [B@41c8436d), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue
PASSED
DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@75eadbcf, value = [B@274ac2d2), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue
STARTED
DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@75eadbcf, value = [B@274ac2d2), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue
PASSED
DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@191217e9, value = [B@683f1a4b), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue
STARTED
DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@191217e9, value = [B@683f1a4b), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue
PASSED
DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7abdb745, value = null), properties=Map(print.key -> true), expected=someKey null
STARTED
DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7abdb745, value = null), properties=Map(print.key -> true), expected=someKey null
PASSED
DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6c903c78, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
STARTED
DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6c903c78, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
PASSED
3354 tests completed, 1 failed, 7 skipped
> Task :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://ci-builds.apache.org/job/Kafka/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. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 24m 23s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #472
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/472/display/redirect?page=changes>
Changes:
[github] MINOR: Add ClientQuotaMetadataManager for processing QuotaRecord (#10101)
[github] MINOR: Add RaftReplicaManager (#10069)
------------------------------------------
[...truncated 3.36 MB...]
LogValidatorTest > testInvalidTimestampExceptionHasBatchIndex() PASSED
LogValidatorTest > testRelativeOffsetAssignmentNonCompressedV1() STARTED
LogValidatorTest > testRelativeOffsetAssignmentNonCompressedV1() PASSED
LogValidatorTest > testRelativeOffsetAssignmentNonCompressedV2() STARTED
LogValidatorTest > testRelativeOffsetAssignmentNonCompressedV2() PASSED
LogValidatorTest > testControlRecordsNotAllowedFromClients() STARTED
LogValidatorTest > testControlRecordsNotAllowedFromClients() PASSED
LogValidatorTest > testRelativeOffsetAssignmentCompressedV1() STARTED
LogValidatorTest > testRelativeOffsetAssignmentCompressedV1() PASSED
LogValidatorTest > testRelativeOffsetAssignmentCompressedV2() STARTED
LogValidatorTest > testRelativeOffsetAssignmentCompressedV2() PASSED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1NonCompressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1NonCompressed() PASSED
LogValidatorTest > testMisMatchMagic() STARTED
LogValidatorTest > testMisMatchMagic() PASSED
LogValidatorTest > testLogAppendTimeNonCompressedV1() STARTED
LogValidatorTest > testLogAppendTimeNonCompressedV1() PASSED
LogValidatorTest > testLogAppendTimeNonCompressedV2() STARTED
LogValidatorTest > testLogAppendTimeNonCompressedV2() PASSED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV0NonCompressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV0NonCompressed() PASSED
LogValidatorTest > testControlRecordsNotCompressed() STARTED
LogValidatorTest > testControlRecordsNotCompressed() PASSED
LogValidatorTest > testInvalidCreateTimeNonCompressedV1() STARTED
LogValidatorTest > testInvalidCreateTimeNonCompressedV1() PASSED
LogValidatorTest > testInvalidCreateTimeNonCompressedV2() STARTED
LogValidatorTest > testInvalidCreateTimeNonCompressedV2() PASSED
LogValidatorTest > testCompressedBatchWithoutRecordsNotAllowed() STARTED
LogValidatorTest > testCompressedBatchWithoutRecordsNotAllowed() PASSED
LogValidatorTest > testOnlyOneBatch() STARTED
LogValidatorTest > testOnlyOneBatch() PASSED
LogValidatorTest > testBatchWithInvalidRecordsAndInvalidTimestamp() STARTED
LogValidatorTest > testBatchWithInvalidRecordsAndInvalidTimestamp() PASSED
LogValidatorTest > testAllowMultiBatch() STARTED
LogValidatorTest > testAllowMultiBatch() PASSED
LogValidatorTest > testInvalidOffsetRangeAndRecordCount() STARTED
LogValidatorTest > testInvalidOffsetRangeAndRecordCount() PASSED
LogValidatorTest > testLogAppendTimeWithoutRecompressionV1() STARTED
LogValidatorTest > testLogAppendTimeWithoutRecompressionV1() PASSED
LogValidatorTest > testLogAppendTimeWithoutRecompressionV2() STARTED
LogValidatorTest > testLogAppendTimeWithoutRecompressionV2() PASSED
LogValidatorTest > testUncompressedBatchWithoutRecordsNotAllowed() STARTED
LogValidatorTest > testUncompressedBatchWithoutRecordsNotAllowed() PASSED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0NonCompressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0NonCompressed() PASSED
LogValidatorTest > testAbsoluteOffsetAssignmentNonCompressed() STARTED
LogValidatorTest > testAbsoluteOffsetAssignmentNonCompressed() PASSED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1Compressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1Compressed() PASSED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0Compressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0Compressed() PASSED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV0ToV2Compressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV0ToV2Compressed() PASSED
LogValidatorTest > testNonCompressedV1() STARTED
LogValidatorTest > testNonCompressedV1() PASSED
LogValidatorTest > testNonCompressedV2() STARTED
LogValidatorTest > testNonCompressedV2() PASSED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() PASSED
LogValidatorTest > testInvalidCreateTimeCompressedV1() STARTED
LogValidatorTest > testInvalidCreateTimeCompressedV1() PASSED
LogValidatorTest > testInvalidCreateTimeCompressedV2() STARTED
LogValidatorTest > testInvalidCreateTimeCompressedV2() PASSED
LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() STARTED
LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() PASSED
LogValidatorTest > testRecompressionV1() STARTED
LogValidatorTest > testRecompressionV1() PASSED
LogValidatorTest > testRecompressionV2() STARTED
LogValidatorTest > testRecompressionV2() PASSED
TransactionIndexTest > testTruncate() STARTED
TransactionIndexTest > testTruncate() PASSED
TransactionIndexTest > testAbortedTxnSerde() STARTED
TransactionIndexTest > testAbortedTxnSerde() PASSED
TransactionIndexTest > testRenameIndex() STARTED
TransactionIndexTest > testRenameIndex() PASSED
TransactionIndexTest > testPositionSetCorrectlyWhenOpened() STARTED
TransactionIndexTest > testPositionSetCorrectlyWhenOpened() PASSED
TransactionIndexTest > testLastOffsetCannotDecrease() STARTED
TransactionIndexTest > testLastOffsetCannotDecrease() PASSED
TransactionIndexTest > testLastOffsetMustIncrease() STARTED
TransactionIndexTest > testLastOffsetMustIncrease() PASSED
TransactionIndexTest > testSanityCheck() STARTED
TransactionIndexTest > testSanityCheck() PASSED
TransactionIndexTest > testCollectAbortedTransactions() STARTED
TransactionIndexTest > testCollectAbortedTransactions() PASSED
LogConcurrencyTest > testUncommittedDataNotConsumedFrequentSegmentRolls() STARTED
LogConcurrencyTest > testUncommittedDataNotConsumedFrequentSegmentRolls() PASSED
LogConcurrencyTest > testUncommittedDataNotConsumed() STARTED
LogConcurrencyTest > testUncommittedDataNotConsumed() PASSED
OffsetIndexTest > lookupExtremeCases() STARTED
OffsetIndexTest > lookupExtremeCases() PASSED
OffsetIndexTest > appendTooMany() STARTED
OffsetIndexTest > appendTooMany() PASSED
OffsetIndexTest > testEntry() STARTED
OffsetIndexTest > testEntry() PASSED
OffsetIndexTest > testSanityLastOffsetEqualToBaseOffset() STARTED
OffsetIndexTest > testSanityLastOffsetEqualToBaseOffset() PASSED
OffsetIndexTest > forceUnmapTest() STARTED
OffsetIndexTest > forceUnmapTest() PASSED
OffsetIndexTest > testFetchUpperBoundOffset() STARTED
OffsetIndexTest > testFetchUpperBoundOffset() PASSED
OffsetIndexTest > randomLookupTest() STARTED
OffsetIndexTest > randomLookupTest() PASSED
OffsetIndexTest > testEntryOverflow() STARTED
OffsetIndexTest > testEntryOverflow() PASSED
OffsetIndexTest > testReopen() STARTED
OffsetIndexTest > testReopen() PASSED
OffsetIndexTest > appendOutOfOrder() STARTED
OffsetIndexTest > appendOutOfOrder() PASSED
OffsetIndexTest > truncate() STARTED
OffsetIndexTest > truncate() PASSED
TransactionsTest > testFailureToFenceEpoch() SKIPPED
> Task :core:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':core:test'.
> Process 'Gradle Test Executor 74' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the User Manual at https://docs.gradle.org/6.8.1/userguide/java_testing.html#sec:test_execution
* 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
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 57m 3s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #471
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/471/display/redirect?page=changes>
Changes:
[github] MINOR: Rename DecommissionBrokers to UnregisterBrokers (#10084)
------------------------------------------
[...truncated 3.49 MB...]
LogValidatorTest > testNonCompressedV1() STARTED
LogValidatorTest > testNonCompressedV1() PASSED
LogValidatorTest > testNonCompressedV2() STARTED
LogValidatorTest > testNonCompressedV2() PASSED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() STARTED
LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() PASSED
LogValidatorTest > testInvalidCreateTimeCompressedV1() STARTED
LogValidatorTest > testInvalidCreateTimeCompressedV1() PASSED
LogValidatorTest > testInvalidCreateTimeCompressedV2() STARTED
LogValidatorTest > testInvalidCreateTimeCompressedV2() PASSED
LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() STARTED
LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() PASSED
LogValidatorTest > testRecompressionV1() STARTED
LogValidatorTest > testRecompressionV1() PASSED
LogValidatorTest > testRecompressionV2() STARTED
LogValidatorTest > testRecompressionV2() PASSED
ProducerStateManagerTest > testSkipEmptyTransactions() STARTED
ProducerStateManagerTest > testSkipEmptyTransactions() PASSED
ProducerStateManagerTest > testControlRecordBumpsProducerEpoch() STARTED
ProducerStateManagerTest > testControlRecordBumpsProducerEpoch() PASSED
ProducerStateManagerTest > testProducerSequenceWithWrapAroundBatchRecord() STARTED
ProducerStateManagerTest > testProducerSequenceWithWrapAroundBatchRecord() PASSED
ProducerStateManagerTest > testCoordinatorFencing() STARTED
ProducerStateManagerTest > testCoordinatorFencing() PASSED
ProducerStateManagerTest > testLoadFromTruncatedSnapshotFile() STARTED
ProducerStateManagerTest > testLoadFromTruncatedSnapshotFile() PASSED
ProducerStateManagerTest > testTruncateFullyAndStartAt() STARTED
ProducerStateManagerTest > testTruncateFullyAndStartAt() PASSED
ProducerStateManagerTest > testRemoveExpiredPidsOnReload() STARTED
ProducerStateManagerTest > testRemoveExpiredPidsOnReload() PASSED
ProducerStateManagerTest > testRecoverFromSnapshotFinishedTransaction() STARTED
ProducerStateManagerTest > testRecoverFromSnapshotFinishedTransaction() PASSED
ProducerStateManagerTest > testOutOfSequenceAfterControlRecordEpochBump() STARTED
ProducerStateManagerTest > testOutOfSequenceAfterControlRecordEpochBump() PASSED
ProducerStateManagerTest > testFirstUnstableOffsetAfterTruncation() STARTED
ProducerStateManagerTest > testFirstUnstableOffsetAfterTruncation() PASSED
ProducerStateManagerTest > testTakeSnapshot() STARTED
ProducerStateManagerTest > testTakeSnapshot() PASSED
ProducerStateManagerTest > testRecoverFromSnapshotUnfinishedTransaction() STARTED
ProducerStateManagerTest > testRecoverFromSnapshotUnfinishedTransaction() PASSED
ProducerStateManagerTest > testDeleteSnapshotsBefore() STARTED
ProducerStateManagerTest > testDeleteSnapshotsBefore() PASSED
ProducerStateManagerTest > testAppendEmptyControlBatch() STARTED
ProducerStateManagerTest > testAppendEmptyControlBatch() PASSED
ProducerStateManagerTest > testNoValidationOnFirstEntryWhenLoadingLog() STARTED
ProducerStateManagerTest > testNoValidationOnFirstEntryWhenLoadingLog() PASSED
ProducerStateManagerTest > testRemoveStraySnapshotsKeepCleanShutdownSnapshot() STARTED
ProducerStateManagerTest > testRemoveStraySnapshotsKeepCleanShutdownSnapshot() PASSED
ProducerStateManagerTest > testRemoveAllStraySnapshots() STARTED
ProducerStateManagerTest > testRemoveAllStraySnapshots() PASSED
ProducerStateManagerTest > testLoadFromEmptySnapshotFile() STARTED
ProducerStateManagerTest > testLoadFromEmptySnapshotFile() PASSED
ProducerStateManagerTest > testProducersWithOngoingTransactionsDontExpire() STARTED
ProducerStateManagerTest > testProducersWithOngoingTransactionsDontExpire() PASSED
ProducerStateManagerTest > testBasicIdMapping() STARTED
ProducerStateManagerTest > testBasicIdMapping() PASSED
ProducerStateManagerTest > updateProducerTransactionState() STARTED
ProducerStateManagerTest > updateProducerTransactionState() PASSED
ProducerStateManagerTest > testPrepareUpdateDoesNotMutate() STARTED
ProducerStateManagerTest > testPrepareUpdateDoesNotMutate() PASSED
ProducerStateManagerTest > testSequenceNotValidatedForGroupMetadataTopic() STARTED
ProducerStateManagerTest > testSequenceNotValidatedForGroupMetadataTopic() PASSED
ProducerStateManagerTest > testLastStableOffsetCompletedTxn() STARTED
ProducerStateManagerTest > testLastStableOffsetCompletedTxn() PASSED
ProducerStateManagerTest > testFirstUnstableOffset() STARTED
ProducerStateManagerTest > testFirstUnstableOffset() PASSED
ProducerStateManagerTest > testTxnFirstOffsetMetadataCached() STARTED
ProducerStateManagerTest > testTxnFirstOffsetMetadataCached() PASSED
ProducerStateManagerTest > testCoordinatorFencedAfterReload() STARTED
ProducerStateManagerTest > testCoordinatorFencedAfterReload() PASSED
ProducerStateManagerTest > testAcceptAppendWithoutProducerStateOnReplica() STARTED
ProducerStateManagerTest > testAcceptAppendWithoutProducerStateOnReplica() PASSED
ProducerStateManagerTest > testProducerStateAfterFencingAbortMarker() STARTED
ProducerStateManagerTest > testProducerStateAfterFencingAbortMarker() PASSED
ProducerStateManagerTest > testLoadFromCorruptSnapshotFile() STARTED
ProducerStateManagerTest > testLoadFromCorruptSnapshotFile() PASSED
ProducerStateManagerTest > testProducerSequenceWrapAround() STARTED
ProducerStateManagerTest > testProducerSequenceWrapAround() PASSED
ProducerStateManagerTest > testPidExpirationTimeout() STARTED
ProducerStateManagerTest > testPidExpirationTimeout() PASSED
ProducerStateManagerTest > testAcceptAppendWithSequenceGapsOnReplica() STARTED
ProducerStateManagerTest > testAcceptAppendWithSequenceGapsOnReplica() PASSED
ProducerStateManagerTest > testAppendTxnMarkerWithNoProducerState() STARTED
ProducerStateManagerTest > testAppendTxnMarkerWithNoProducerState() PASSED
ProducerStateManagerTest > testOldEpochForControlRecord() STARTED
ProducerStateManagerTest > testOldEpochForControlRecord() PASSED
ProducerStateManagerTest > testTruncateAndReloadRemovesOutOfRangeSnapshots() STARTED
ProducerStateManagerTest > testTruncateAndReloadRemovesOutOfRangeSnapshots() PASSED
ProducerStateManagerTest > testProducerSequenceInvalidWrapAround() STARTED
ProducerStateManagerTest > testProducerSequenceInvalidWrapAround() PASSED
ProducerStateManagerTest > testRecoverFromSnapshotEmptyTransaction() STARTED
ProducerStateManagerTest > testRecoverFromSnapshotEmptyTransaction() PASSED
ProducerStateManagerTest > testNonTransactionalAppendWithOngoingTransaction() STARTED
ProducerStateManagerTest > testNonTransactionalAppendWithOngoingTransaction() PASSED
ProducerStateManagerTest > testLoadFromSnapshotRetainsNonExpiredProducers() STARTED
ProducerStateManagerTest > testLoadFromSnapshotRetainsNonExpiredProducers() PASSED
ProducerStateManagerTest > testSkipSnapshotIfOffsetUnchanged() STARTED
ProducerStateManagerTest > testSkipSnapshotIfOffsetUnchanged() PASSED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED
TransactionsTest > testFailureToFenceEpoch() SKIPPED
> Task :core:test FAILED
FAILURE: Build completed with 3 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':connect:mirror:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/ws/connect/mirror/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.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/ws/connect/runtime/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.
==============================================================================
3: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':core:test'.
> Process 'Gradle Test Executor 70' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the User Manual at https://docs.gradle.org/6.8.1/userguide/java_testing.html#sec:test_execution
* 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
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 26m 43s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #470
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/470/display/redirect?page=changes>
Changes:
[github] MINOR: KafkaBroker.brokerState should be volatile instead of AtomicReference (#10080)
------------------------------------------
[...truncated 3.58 MB...]
SocketServerTest > remoteCloseWithIncompleteBufferedReceive() STARTED
SocketServerTest > remoteCloseWithIncompleteBufferedReceive() PASSED
SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() STARTED
SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() PASSED
SocketServerTest > testStagedListenerStartup() STARTED
SocketServerTest > testStagedListenerStartup() PASSED
SocketServerTest > testConnectionRateLimit() STARTED
SocketServerTest > testConnectionRateLimit() PASSED
SocketServerTest > testConnectionRatePerIp() STARTED
SocketServerTest > testConnectionRatePerIp() PASSED
SocketServerTest > processCompletedSendException() STARTED
SocketServerTest > processCompletedSendException() PASSED
SocketServerTest > processDisconnectedException() STARTED
SocketServerTest > processDisconnectedException() PASSED
SocketServerTest > closingChannelWithBufferedReceives() STARTED
SocketServerTest > closingChannelWithBufferedReceives() PASSED
SocketServerTest > sendCancelledKeyException() STARTED
SocketServerTest > sendCancelledKeyException() PASSED
SocketServerTest > processCompletedReceiveException() STARTED
SocketServerTest > processCompletedReceiveException() PASSED
SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED
SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED
SocketServerTest > closingChannelSendFailure() STARTED
SocketServerTest > closingChannelSendFailure() PASSED
SocketServerTest > idleExpiryWithBufferedReceives() STARTED
SocketServerTest > idleExpiryWithBufferedReceives() PASSED
SocketServerTest > testSocketsCloseOnShutdown() STARTED
SocketServerTest > testSocketsCloseOnShutdown() PASSED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED
SocketServerTest > pollException() STARTED
SocketServerTest > pollException() PASSED
SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED
SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED
SocketServerTest > remoteCloseWithBufferedReceives() STARTED
SocketServerTest > remoteCloseWithBufferedReceives() PASSED
SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED
SocketServerTest > testThrottledSocketsClosedOnShutdown() PASSED
SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() STARTED
SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() PASSED
SocketServerTest > testInterBrokerListenerAsPrivilegedListener() STARTED
SocketServerTest > testInterBrokerListenerAsPrivilegedListener() PASSED
SocketServerTest > testSslSocketServer() STARTED
SocketServerTest > testSslSocketServer() PASSED
SocketServerTest > testDisabledRequestIsRejected() STARTED
SocketServerTest > testDisabledRequestIsRejected() PASSED
SocketServerTest > tooBigRequestIsRejected() STARTED
SocketServerTest > tooBigRequestIsRejected() PASSED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED
DynamicConnectionQuotaTest > testDynamicConnectionQuota() STARTED
DynamicConnectionQuotaTest > testDynamicConnectionQuota() PASSED
DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() STARTED
DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() PASSED
DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() STARTED
DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() PASSED
DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() STARTED
DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() PASSED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@68f17a6d, value = [B@5bfa4a0f), properties=Map(print.value -> false), expected= STARTED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@68f17a6d, value = [B@5bfa4a0f), properties=Map(print.value -> false), expected= PASSED
DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4b1067ef, value = [B@5fb16187), properties=Map(print.key -> true, print.value -> false), expected=someKey
STARTED
DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4b1067ef, value = [B@5fb16187), properties=Map(print.key -> true, print.value -> false), expected=someKey
PASSED
DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@686a6ddf, value = [B@35382801), properties=Map(), expected=someValue
STARTED
DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@686a6ddf, value = [B@35382801), properties=Map(), expected=someValue
PASSED
DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7ddf1e56, value = [B@2936e533), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP
STARTED
DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7ddf1e56, value = [B@2936e533), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP
PASSED
DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1209615f, value = [B@66852b3f), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234
STARTED
DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@1209615f, value = [B@66852b3f), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234
PASSED
DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@63ada417, value = [B@7dacca2c), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234
STARTED
DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@63ada417, value = [B@7dacca2c), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234
PASSED
DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@24765f5f, value = [B@6be5443d), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9
STARTED
DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@24765f5f, value = [B@6be5443d), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9
PASSED
DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6566c84a, value = [B@7e808360), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876
STARTED
DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6566c84a, value = [B@7e808360), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876
PASSED
DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@681ab748, value = [B@291fc2da), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2
STARTED
DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@681ab748, value = [B@291fc2da), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2
PASSED
DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@897c95, value = [B@3d142b3b), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS
STARTED
DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@897c95, value = [B@3d142b3b), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS
PASSED
DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6aca3751, value = [B@53423800), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue
STARTED
DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6aca3751, value = [B@53423800), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue
PASSED
DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@18648b29, value = [B@4b536ed), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ STARTED
DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@18648b29, value = [B@4b536ed), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ PASSED
DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@3f7ee995, value = [B@7dbe5442), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue
STARTED
DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@3f7ee995, value = [B@7dbe5442), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue
PASSED
DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6c90f19b, value = [B@246a8fdd), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE
STARTED
DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6c90f19b, value = [B@246a8fdd), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE
PASSED
DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@2bf9c356, value = [B@17d20c6b), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue
STARTED
DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@2bf9c356, value = [B@17d20c6b), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue
PASSED
DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7c252b23, value = [B@cc1571d), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue
STARTED
DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7c252b23, value = [B@cc1571d), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue
PASSED
DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@3b587c79, value = [B@3da7bdb0), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue
STARTED
DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@3b587c79, value = [B@3da7bdb0), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue
PASSED
DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6a820e72, value = null), properties=Map(print.key -> true), expected=someKey null
STARTED
DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6a820e72, value = null), properties=Map(print.key -> true), expected=someKey null
PASSED
DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@de19183, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
STARTED
DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@de19183, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
PASSED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test-utils:test'.
> Process 'Gradle Test Executor 66' finished with non-zero exit value 134
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the User Manual at https://docs.gradle.org/6.8.1/userguide/java_testing.html#sec:test_execution
* 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
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 36m 16s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de