Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #16

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/16/display/redirect?page=changes>

Changes:

[Ismael Juma] MINOR: Update zstd and use classes with no finalizers (#10120)

[Ismael Juma] KAFKA-12327: Remove MethodHandle usage in CompressionType (#10123)


------------------------------------------
[...truncated 7.18 MB...]
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

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@6cc70003, value = [B@77e78cd0), 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@6cc70003, value = [B@77e78cd0), 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@3af90c7c, value = [B@41ed549b), 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@3af90c7c, value = [B@41ed549b), 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@664b4193, value = [B@be93d73), 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@664b4193, value = [B@be93d73), 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@79015a9e, value = [B@526380a9), 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@79015a9e, value = [B@526380a9), 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@6e9804af, value = [B@2c58aeaa), 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@6e9804af, value = [B@2c58aeaa), 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@5f7ec415, value = [B@11d6619b), 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@5f7ec415, value = [B@11d6619b), 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@3fc5b272, value = [B@568166de), 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@3fc5b272, value = [B@568166de), 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@7f765e77, value = [B@5d8e22bb), 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@7f765e77, value = [B@5d8e22bb), 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@4fca4d5a, value = [B@122075eb), 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@4fca4d5a, value = [B@122075eb), 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@6ee24d3e, value = [B@7ffcf224), 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@6ee24d3e, value = [B@7ffcf224), 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@60aac011, value = [B@680999e8), properties=HashMap(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@60aac011, value = [B@680999e8), properties=HashMap(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@147ea26a, value = [B@c8b0f13), properties=HashMap(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@147ea26a, value = [B@c8b0f13), properties=HashMap(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@3a97ecdb, value = [B@1e75e4b8), 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@3a97ecdb, value = [B@1e75e4b8), 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@2bde1385, value = [B@2e2ac311), 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@2bde1385, value = [B@2e2ac311), 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@1f4ba248, value = [B@2b419757), 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@1f4ba248, value = [B@2b419757), 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@7058fb81, value = [B@8929cd0), 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@7058fb81, value = [B@8929cd0), 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@5ae69189, value = [B@460ef219), 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@5ae69189, value = [B@460ef219), 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@45b7b6d6, 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@45b7b6d6, 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@77ad252, 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@77ad252, 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 ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-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 25m 1s
250 actionable tasks: 243 executed, 7 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results

Jenkins build is back to normal : Kafka » kafka-2.8-jdk8 #37

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/37/display/redirect?page=changes>

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #36

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/36/display/redirect?page=changes>

Changes:

[Guozhang Wang] KAFKA-12323: Set timestamp in record context when punctuate (#10170)


------------------------------------------
[...truncated 7.21 MB...]
RequestConvertToJsonTest > testRequestDescMetrics() PASSED

RequestConvertToJsonTest > testClientInfoNode() STARTED

RequestConvertToJsonTest > testClientInfoNode() PASSED

RequestConvertToJsonTest > testRequestDesc() STARTED

RequestConvertToJsonTest > testRequestDesc() PASSED

RequestConvertToJsonTest > testRequestHeaderNode() STARTED

RequestConvertToJsonTest > testRequestHeaderNode() PASSED

MetricsTest > testUpdateJMXFilter() STARTED

MetricsTest > testUpdateJMXFilter() PASSED

MetricsTest > testGeneralBrokerTopicMetricsAreGreedilyRegistered() STARTED

MetricsTest > testGeneralBrokerTopicMetricsAreGreedilyRegistered() PASSED

MetricsTest > testLinuxIoMetrics() STARTED

MetricsTest > testLinuxIoMetrics() PASSED

MetricsTest > testMetricsReporterAfterDeletingTopic() STARTED

MetricsTest > testMetricsReporterAfterDeletingTopic() PASSED

MetricsTest > testSessionExpireListenerMetrics() STARTED

MetricsTest > testSessionExpireListenerMetrics() PASSED

MetricsTest > testBrokerTopicMetricsUnregisteredAfterDeletingTopic() STARTED

MetricsTest > testBrokerTopicMetricsUnregisteredAfterDeletingTopic() PASSED

MetricsTest > testYammerMetricsCountMetric() STARTED

MetricsTest > testYammerMetricsCountMetric() PASSED

MetricsTest > testClusterIdMetric() STARTED

MetricsTest > testClusterIdMetric() PASSED

MetricsTest > testControllerMetrics() STARTED

MetricsTest > testControllerMetrics() PASSED

MetricsTest > testWindowsStyleTagNames() STARTED

MetricsTest > testWindowsStyleTagNames() PASSED

MetricsTest > testBrokerStateMetric() STARTED

MetricsTest > testBrokerStateMetric() PASSED

MetricsTest > testBrokerTopicMetricsBytesInOut() STARTED

MetricsTest > testBrokerTopicMetricsBytesInOut() PASSED

MetricsTest > testJMXFilter() STARTED

MetricsTest > testJMXFilter() 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

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@effe9e2, value = [B@33ff34a4), 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@effe9e2, value = [B@33ff34a4), 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@71f3ee35, value = [B@58bc9190), 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@71f3ee35, value = [B@58bc9190), 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@cac0df2, value = [B@5af95aff), 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@cac0df2, value = [B@5af95aff), 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@349585d3, value = [B@819a2c0), 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@349585d3, value = [B@819a2c0), 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@6436edac, value = [B@74086d77), 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@6436edac, value = [B@74086d77), 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@6c2bc538, value = [B@296175df), 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@6c2bc538, value = [B@296175df), 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@7ae9b6d2, value = [B@4dbd0f2d), 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@7ae9b6d2, value = [B@4dbd0f2d), 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@7f0d01a7, value = [B@5d605c14), 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@7f0d01a7, value = [B@5d605c14), 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@6a082e4c, value = [B@4f698047), 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@6a082e4c, value = [B@4f698047), 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@721d7c3, value = [B@2c70e325), 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@721d7c3, value = [B@2c70e325), 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@2f983554, value = [B@2cadf93), properties=HashMap(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@2f983554, value = [B@2cadf93), properties=HashMap(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@b5c8fc6, value = [B@209e2c43), properties=HashMap(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@b5c8fc6, value = [B@209e2c43), properties=HashMap(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@4ec29f91, value = [B@1aa0f79d), 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@4ec29f91, value = [B@1aa0f79d), 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@24c0bf6a, value = [B@7e249274), 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@24c0bf6a, value = [B@7e249274), 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@63a58e32, value = [B@7d1bdb0f), 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@63a58e32, value = [B@7d1bdb0f), 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@5c010029, value = [B@66c8eef), 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@5c010029, value = [B@66c8eef), 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@3ec368af, value = [B@5c3a826e), 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@3ec368af, value = [B@5c3a826e), 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@2f1eeac3, 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@2f1eeac3, 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@7c36c971, 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@7c36c971, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey	NULL
 PASSED

3386 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-2.8-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-2.8-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 2h 4m 24s
257 actionable tasks: 250 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-2.8-jdk8 #35

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/35/display/redirect?page=changes>

Changes:

[Ismael Juma] KAFKA-12341: Ensure consistent versions for javassist (#10191)


------------------------------------------
[...truncated 7.22 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

3386 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-2.8-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 29m 27s
257 actionable tasks: 250 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-2.8-jdk8 #34

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/34/display/redirect?page=changes>

Changes:

[Guozhang Wang] MINOR: document restriction against running multiple Streams apps on same state.dir (#10187)


------------------------------------------
[...truncated 3.60 MB...]
LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 STARTED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 PASSED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE STARTED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE PASSED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP STARTED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP PASSED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY STARTED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY PASSED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 STARTED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 PASSED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD STARTED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD PASSED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE STARTED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE PASSED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP STARTED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP PASSED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY STARTED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY PASSED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 STARTED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 PASSED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD STARTED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD PASSED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE STARTED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE PASSED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP STARTED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP PASSED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY STARTED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY PASSED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 STARTED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 PASSED

TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED

TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() 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@38d8db39, value = [B@3dec592b), 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@38d8db39, value = [B@3dec592b), 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@45ffca28, value = [B@1a85f6bd), 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@45ffca28, value = [B@1a85f6bd), 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@1a4cf279, value = [B@270a551d), 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@1a4cf279, value = [B@270a551d), 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@1c9f655e, value = [B@291a586e), 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@1c9f655e, value = [B@291a586e), 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@54b8b80e, value = [B@21efad39), 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@54b8b80e, value = [B@21efad39), 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@463d99cf, value = [B@3d1f704e), 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@463d99cf, value = [B@3d1f704e), 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@2cf6c72b, value = [B@70ac31e9), 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@2cf6c72b, value = [B@70ac31e9), 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@5a752dd2, value = [B@1c2ebbd2), 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@5a752dd2, value = [B@1c2ebbd2), 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@6fbf8e3, value = [B@17c9b2ac), 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@6fbf8e3, value = [B@17c9b2ac), 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@d38d147, value = [B@545d1ce3), 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@d38d147, value = [B@545d1ce3), 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@edb8816, value = [B@62a74f21), 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@edb8816, value = [B@62a74f21), 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@295e18db, value = [B@15d8a317), 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@295e18db, value = [B@15d8a317), 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@47910282, value = [B@1f178316), 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@47910282, value = [B@1f178316), 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@4656c8ef, value = [B@16461b29), 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@4656c8ef, value = [B@16461b29), 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@598c9e71, value = [B@7aa0b965), 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@598c9e71, value = [B@7aa0b965), 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@a41076e, value = [B@2c78ca5c), 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@a41076e, value = [B@2c78ca5c), 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@6c565eab, value = [B@6164357), 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@6c565eab, value = [B@6164357), 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@42dd4a37, 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@42dd4a37, 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@5e1ce9ed, 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@5e1ce9ed, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey	NULL
 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

3386 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'.
> Process 'Gradle Test Executor 79' 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.
==============================================================================

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-2.8-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 23m 51s
257 actionable tasks: 220 executed, 37 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-2.8-jdk8 #33

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/33/display/redirect?page=changes>

Changes:

[Manikumar Reddy] MINOR: Update HttpClient to "4.5.13"


------------------------------------------
[...truncated 3.61 MB...]

AclAuthorizerTest > testSuperUserHasAccess() STARTED

AclAuthorizerTest > testSuperUserHasAccess() PASSED

AclAuthorizerTest > testDeleteAclOnPrefixedResource() STARTED

AclAuthorizerTest > testDeleteAclOnPrefixedResource() PASSED

AclAuthorizerTest > testDenyTakesPrecedence() STARTED

AclAuthorizerTest > testDenyTakesPrecedence() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED

AclAuthorizerTest > testSingleCharacterResourceAcls() STARTED

AclAuthorizerTest > testSingleCharacterResourceAcls() PASSED

AclAuthorizerTest > testNoAclFoundOverride() STARTED

AclAuthorizerTest > testNoAclFoundOverride() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() PASSED

AclAuthorizerTest > testEmptyAclThrowsException() STARTED

AclAuthorizerTest > testEmptyAclThrowsException() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeNoAclFoundOverride() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeNoAclFoundOverride() PASSED

AclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() STARTED

AclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllOperationAce() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED

AclAuthorizerTest > testAllowAccessWithCustomPrincipal() STARTED

AclAuthorizerTest > testAllowAccessWithCustomPrincipal() PASSED

AclAuthorizerTest > testDeleteAclOnWildcardResource() STARTED

AclAuthorizerTest > testDeleteAclOnWildcardResource() PASSED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() STARTED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() PASSED

AclAuthorizerTest > testChangeListenerTiming() STARTED

AclAuthorizerTest > testChangeListenerTiming() PASSED

AclAuthorizerTest > testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions() STARTED

AclAuthorizerTest > testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions() PASSED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() STARTED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeMultipleAddAndRemove() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeMultipleAddAndRemove() PASSED

AclAuthorizerTest > testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() STARTED

AclAuthorizerTest > testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() PASSED

AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnPrefixedResource() STARTED

AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnPrefixedResource() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeDenyTakesPrecedence() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED

AclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls() STARTED

AclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllPrincipalAce() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllPrincipalAce() PASSED

AclAuthorizerTest > testAuthorizeWithEmptyResourceName() STARTED

AclAuthorizerTest > testAuthorizeWithEmptyResourceName() PASSED

AclAuthorizerTest > testAuthorizeThrowsOnNonLiteralResource() STARTED

AclAuthorizerTest > testAuthorizeThrowsOnNonLiteralResource() PASSED

AclAuthorizerTest > testDeleteAllAclOnPrefixedResource() STARTED

AclAuthorizerTest > testDeleteAllAclOnPrefixedResource() PASSED

AclAuthorizerTest > testAddAclsOnLiteralResource() STARTED

AclAuthorizerTest > testAddAclsOnLiteralResource() PASSED

AclAuthorizerTest > testGetAclsPrincipal() STARTED

AclAuthorizerTest > testGetAclsPrincipal() PASSED

AclAuthorizerTest > testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() STARTED

AclAuthorizerTest > testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() PASSED

AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnWildcardResource() STARTED

AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnWildcardResource() PASSED

AclAuthorizerTest > testLoadCache() STARTED

AclAuthorizerTest > testLoadCache() PASSED

MinIsrConfigTest > testDefaultKafkaConfig() STARTED

MinIsrConfigTest > testDefaultKafkaConfig() PASSED

BrokerEndPointTest > testFromJsonV4WithNoFeatures() STARTED

BrokerEndPointTest > testFromJsonV4WithNoFeatures() PASSED

BrokerEndPointTest > testEndpointFromUri() STARTED

BrokerEndPointTest > testEndpointFromUri() PASSED

BrokerEndPointTest > testHashAndEquals() STARTED

BrokerEndPointTest > testHashAndEquals() PASSED

BrokerEndPointTest > testFromJsonV4WithNoRack() STARTED

BrokerEndPointTest > testFromJsonV4WithNoRack() PASSED

BrokerEndPointTest > testFromJsonFutureVersion() STARTED

BrokerEndPointTest > testFromJsonFutureVersion() PASSED

BrokerEndPointTest > testFromJsonV4WithNullRack() STARTED

BrokerEndPointTest > testFromJsonV4WithNullRack() PASSED

BrokerEndPointTest > testBrokerEndpointFromUri() STARTED

BrokerEndPointTest > testBrokerEndpointFromUri() PASSED

BrokerEndPointTest > testFromJsonV1() STARTED

BrokerEndPointTest > testFromJsonV1() PASSED

BrokerEndPointTest > testFromJsonV2() STARTED

BrokerEndPointTest > testFromJsonV2() PASSED

BrokerEndPointTest > testFromJsonV3() STARTED

BrokerEndPointTest > testFromJsonV3() PASSED

BrokerEndPointTest > testFromJsonV5() STARTED

BrokerEndPointTest > testFromJsonV5() PASSED

AssignmentStateTest > [1] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(), removing=List(), original=List(), isUnderReplicated=false STARTED

AssignmentStateTest > [1] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(), removing=List(), original=List(), isUnderReplicated=false PASSED

AssignmentStateTest > [2] isr=List(101, 102), replicas=List(101, 102, 103), adding=List(), removing=List(), original=List(), isUnderReplicated=true STARTED

AssignmentStateTest > [2] isr=List(101, 102), replicas=List(101, 102, 103), adding=List(), removing=List(), original=List(), isUnderReplicated=true PASSED

AssignmentStateTest > [3] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(104, 105), removing=List(102), original=List(101, 102, 103), isUnderReplicated=false STARTED

AssignmentStateTest > [3] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(104, 105), removing=List(102), original=List(101, 102, 103), isUnderReplicated=false PASSED

AssignmentStateTest > [4] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(104, 105), removing=List(), original=List(101, 102, 103), isUnderReplicated=false STARTED

AssignmentStateTest > [4] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(104, 105), removing=List(), original=List(101, 102, 103), isUnderReplicated=false PASSED

AssignmentStateTest > [5] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(), removing=List(102), original=List(101, 102, 103), isUnderReplicated=false STARTED

AssignmentStateTest > [5] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(), removing=List(102), original=List(101, 102, 103), isUnderReplicated=false PASSED

AssignmentStateTest > [6] isr=List(102, 103), replicas=List(102, 103), adding=List(101), removing=List(), original=List(102, 103), isUnderReplicated=false STARTED

AssignmentStateTest > [6] isr=List(102, 103), replicas=List(102, 103), adding=List(101), removing=List(), original=List(102, 103), isUnderReplicated=false PASSED

AssignmentStateTest > [7] isr=List(103, 104, 105), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=false STARTED

AssignmentStateTest > [7] isr=List(103, 104, 105), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=false PASSED

AssignmentStateTest > [8] isr=List(103, 104, 105), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=false STARTED

AssignmentStateTest > [8] isr=List(103, 104, 105), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=false PASSED

AssignmentStateTest > [9] isr=List(103, 104), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=true STARTED

AssignmentStateTest > [9] isr=List(103, 104), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=true PASSED

ReplicaTest > testCannotIncrementLogStartOffsetPastHighWatermark() STARTED

ReplicaTest > testCannotIncrementLogStartOffsetPastHighWatermark() PASSED

ReplicaTest > testSegmentDeletionWithHighWatermarkInitialization() STARTED

ReplicaTest > testSegmentDeletionWithHighWatermarkInitialization() PASSED

ReplicaTest > testCannotDeleteSegmentsAtOrAboveHighWatermark() STARTED

ReplicaTest > testCannotDeleteSegmentsAtOrAboveHighWatermark() PASSED

3386 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-2.8-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 33s
257 actionable tasks: 220 executed, 37 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-2.8-jdk8 #32

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/32/display/redirect?page=changes>

Changes:

[Ismael Juma] KAFKA-12357: Do not inline methods from the scala package by default (#10174)

[Ismael Juma] MINOR: Update Scala to 2.13.5 (#10169)


------------------------------------------
[...truncated 3.61 MB...]

AclAuthorizerTest > testCreateDeleteTiming() STARTED

AclAuthorizerTest > testCreateDeleteTiming() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllHostAce() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllHostAce() PASSED

AclAuthorizerTest > testWritesLiteralAclChangeEventWhenInterBrokerProtocolIsKafkaV2() STARTED

AclAuthorizerTest > testWritesLiteralAclChangeEventWhenInterBrokerProtocolIsKafkaV2() PASSED

AclAuthorizerTest > testTopicAcl() STARTED

AclAuthorizerTest > testTopicAcl() PASSED

AclAuthorizerTest > testSuperUserHasAccess() STARTED

AclAuthorizerTest > testSuperUserHasAccess() PASSED

AclAuthorizerTest > testDeleteAclOnPrefixedResource() STARTED

AclAuthorizerTest > testDeleteAclOnPrefixedResource() PASSED

AclAuthorizerTest > testDenyTakesPrecedence() STARTED

AclAuthorizerTest > testDenyTakesPrecedence() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED

AclAuthorizerTest > testSingleCharacterResourceAcls() STARTED

AclAuthorizerTest > testSingleCharacterResourceAcls() PASSED

AclAuthorizerTest > testNoAclFoundOverride() STARTED

AclAuthorizerTest > testNoAclFoundOverride() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() PASSED

AclAuthorizerTest > testEmptyAclThrowsException() STARTED

AclAuthorizerTest > testEmptyAclThrowsException() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeNoAclFoundOverride() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeNoAclFoundOverride() PASSED

AclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() STARTED

AclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllOperationAce() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED

AclAuthorizerTest > testAllowAccessWithCustomPrincipal() STARTED

AclAuthorizerTest > testAllowAccessWithCustomPrincipal() PASSED

AclAuthorizerTest > testDeleteAclOnWildcardResource() STARTED

AclAuthorizerTest > testDeleteAclOnWildcardResource() PASSED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() STARTED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() PASSED

AclAuthorizerTest > testChangeListenerTiming() STARTED

AclAuthorizerTest > testChangeListenerTiming() PASSED

AclAuthorizerTest > testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions() STARTED

AclAuthorizerTest > testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions() PASSED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() STARTED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeMultipleAddAndRemove() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeMultipleAddAndRemove() PASSED

AclAuthorizerTest > testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() STARTED

AclAuthorizerTest > testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() PASSED

AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnPrefixedResource() STARTED

AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnPrefixedResource() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeDenyTakesPrecedence() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED

AclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls() STARTED

AclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllPrincipalAce() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllPrincipalAce() PASSED

AclAuthorizerTest > testAuthorizeWithEmptyResourceName() STARTED

AclAuthorizerTest > testAuthorizeWithEmptyResourceName() PASSED

AclAuthorizerTest > testAuthorizeThrowsOnNonLiteralResource() STARTED

AclAuthorizerTest > testAuthorizeThrowsOnNonLiteralResource() PASSED

AclAuthorizerTest > testDeleteAllAclOnPrefixedResource() STARTED

AclAuthorizerTest > testDeleteAllAclOnPrefixedResource() PASSED

AclAuthorizerTest > testAddAclsOnLiteralResource() STARTED

AclAuthorizerTest > testAddAclsOnLiteralResource() PASSED

AclAuthorizerTest > testGetAclsPrincipal() STARTED

AclAuthorizerTest > testGetAclsPrincipal() PASSED

AclAuthorizerTest > testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() STARTED

AclAuthorizerTest > testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() PASSED

AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnWildcardResource() STARTED

AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnWildcardResource() PASSED

AclAuthorizerTest > testLoadCache() STARTED

AclAuthorizerTest > testLoadCache() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypeDisableAllowEveryoneOverride() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypeDisableAllowEveryoneOverride() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllHostAce() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllHostAce() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypeEnableAllowEveryOne() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypeEnableAllowEveryOne() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllOperationAce() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED

AuthorizerWrapperTest > testAuthorzeByResourceTypeSuperUserHasAccess() STARTED

AuthorizerWrapperTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypeMultipleAddAndRemove() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypeMultipleAddAndRemove() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypeDenyTakesPrecedence() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED

AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllPrincipalAce() STARTED

AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllPrincipalAce() PASSED

AclEntryTest > testAclJsonConversion() STARTED

AclEntryTest > testAclJsonConversion() PASSED

MiniKdcTest > shouldNotStopImmediatelyWhenStarted() STARTED

MiniKdcTest > shouldNotStopImmediatelyWhenStarted() PASSED

DelegationTokenManagerTest > testPeriodicTokenExpiry() STARTED

DelegationTokenManagerTest > testPeriodicTokenExpiry() PASSED

DelegationTokenManagerTest > testTokenRequestsWithDelegationTokenDisabled() STARTED

DelegationTokenManagerTest > testTokenRequestsWithDelegationTokenDisabled() PASSED

DelegationTokenManagerTest > testDescribeToken() STARTED

DelegationTokenManagerTest > testDescribeToken() PASSED

DelegationTokenManagerTest > testCreateToken() STARTED

DelegationTokenManagerTest > testCreateToken() PASSED

DelegationTokenManagerTest > testExpireToken() STARTED

DelegationTokenManagerTest > testExpireToken() PASSED

DelegationTokenManagerTest > testRenewToken() STARTED

DelegationTokenManagerTest > testRenewToken() PASSED

DelegationTokenManagerTest > testRemoveTokenHmac() STARTED

DelegationTokenManagerTest > testRemoveTokenHmac() PASSED

3386 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-2.8-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 27m 14s
257 actionable tasks: 220 executed, 37 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-2.8-jdk8 #31

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/31/display/redirect?page=changes>

Changes:

[Chia-Ping Tsai] HOTFIX: Fix build error caused by ControllerApisTest.scala (#10146)


------------------------------------------
[...truncated 3.61 MB...]

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

3386 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-2.8-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 45m 22s
257 actionable tasks: 220 executed, 37 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-2.8-jdk8 #30

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/30/display/redirect?page=changes>

Changes:

[Chia-Ping Tsai] KAFKA-12273 InterBrokerSendThread#pollOnce throws FatalExitError even… (#10024)


------------------------------------------
[...truncated 1.80 MB...]

KafkaAdminClientTest > testUnregisterBrokerTimeoutMaxRetry() STARTED

KafkaAdminClientTest > testUnregisterBrokerTimeoutMaxRetry() PASSED

KafkaAdminClientTest > testSuccessfulRetryAfterRequestTimeout() STARTED

KafkaAdminClientTest > testSuccessfulRetryAfterRequestTimeout() PASSED

KafkaAdminClientTest > testUpdateFeaturesHandleNotControllerException() STARTED

KafkaAdminClientTest > testUpdateFeaturesHandleNotControllerException() PASSED

KafkaAdminClientTest > testOffsetCommitRetryBackoff() STARTED

KafkaAdminClientTest > testOffsetCommitRetryBackoff() PASSED

KafkaAdminClientTest > testDeleteTopicsRetryThrottlingExceptionWhenEnabledUntilRequestTimeOut() STARTED

KafkaAdminClientTest > testDeleteTopicsRetryThrottlingExceptionWhenEnabledUntilRequestTimeOut() PASSED

KafkaAdminClientTest > testDeleteTopicsPartialResponse() STARTED

KafkaAdminClientTest > testDeleteTopicsPartialResponse() PASSED

KafkaAdminClientTest > testRemoveMembersFromGroup() STARTED

KafkaAdminClientTest > testRemoveMembersFromGroup() PASSED

KafkaAdminClientTest > testListOffsetsRetriableErrorOnMetadata() STARTED

KafkaAdminClientTest > testListOffsetsRetriableErrorOnMetadata() PASSED

KafkaAdminClientTest > testListOffsetsPartialResponse() STARTED

KafkaAdminClientTest > testListOffsetsPartialResponse() PASSED

KafkaAdminClientTest > testCalcTimeoutMsRemainingAsInt() STARTED

KafkaAdminClientTest > testCalcTimeoutMsRemainingAsInt() PASSED

KafkaAdminClientTest > testUnreachableBootstrapServer() STARTED

KafkaAdminClientTest > testUnreachableBootstrapServer() PASSED

KafkaAdminClientTest > testDeleteConsumerGroupOffsetsNonRetriableErrors() STARTED

KafkaAdminClientTest > testDeleteConsumerGroupOffsetsNonRetriableErrors() PASSED

RemoveMembersFromConsumerGroupResultTest > testMemberLevelErrorInResponseConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testMemberLevelErrorInResponseConstructor() PASSED

RemoveMembersFromConsumerGroupResultTest > testTopLevelErrorConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testTopLevelErrorConstructor() PASSED

RemoveMembersFromConsumerGroupResultTest > testMemberMissingErrorInRequestConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testMemberMissingErrorInRequestConstructor() PASSED

RemoveMembersFromConsumerGroupResultTest > testMemberLevelErrorConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testMemberLevelErrorConstructor() PASSED

RemoveMembersFromConsumerGroupResultTest > testNoErrorConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testNoErrorConstructor() PASSED

AdminMetadataManagerTest > testAuthenticationFailure() STARTED

AdminMetadataManagerTest > testAuthenticationFailure() PASSED

AdminMetadataManagerTest > testMetadataReady() STARTED

AdminMetadataManagerTest > testMetadataReady() PASSED

AdminMetadataManagerTest > testMetadataRefreshBackoff() STARTED

AdminMetadataManagerTest > testMetadataRefreshBackoff() PASSED

CommonClientConfigsTest > testExponentialBackoffDefaults() STARTED

CommonClientConfigsTest > testExponentialBackoffDefaults() PASSED

NodeApiVersionsTest > [1] ZK_BROKER STARTED

NodeApiVersionsTest > [1] ZK_BROKER PASSED

NodeApiVersionsTest > [2] BROKER STARTED

NodeApiVersionsTest > [2] BROKER PASSED

NodeApiVersionsTest > [3] CONTROLLER STARTED

NodeApiVersionsTest > [3] CONTROLLER PASSED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeHigh() STARTED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeHigh() PASSED

NodeApiVersionsTest > testLatestUsableVersion() STARTED

NodeApiVersionsTest > testLatestUsableVersion() PASSED

NodeApiVersionsTest > testUsableVersionCalculationNoKnownVersions() STARTED

NodeApiVersionsTest > testUsableVersionCalculationNoKnownVersions() PASSED

NodeApiVersionsTest > testVersionsToString() STARTED

NodeApiVersionsTest > testVersionsToString() PASSED

NodeApiVersionsTest > testUnsupportedVersionsToString() STARTED

NodeApiVersionsTest > testUnsupportedVersionsToString() PASSED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeLow() STARTED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeLow() PASSED

NodeApiVersionsTest > testLatestUsableVersionOutOfRange() STARTED

NodeApiVersionsTest > testLatestUsableVersionOutOfRange() PASSED

NodeApiVersionsTest > testUnknownApiVersionsToString() STARTED

NodeApiVersionsTest > testUnknownApiVersionsToString() PASSED

NodeApiVersionsTest > [1] ZK_BROKER STARTED

NodeApiVersionsTest > [1] ZK_BROKER PASSED

NodeApiVersionsTest > [2] BROKER STARTED

NodeApiVersionsTest > [2] BROKER PASSED

NodeApiVersionsTest > [3] CONTROLLER STARTED

NodeApiVersionsTest > [3] CONTROLLER PASSED

ClusterConnectionStatesTest > testIsPreparingConnection() STARTED

ClusterConnectionStatesTest > testIsPreparingConnection() PASSED

ClusterConnectionStatesTest > testNodeWithNewHostname() STARTED

ClusterConnectionStatesTest > testNodeWithNewHostname() PASSED

ClusterConnectionStatesTest > testHostResolveChange() STARTED

ClusterConnectionStatesTest > testHostResolveChange() PASSED

ClusterConnectionStatesTest > testAuthorizationFailed() STARTED

ClusterConnectionStatesTest > testAuthorizationFailed() PASSED

ClusterConnectionStatesTest > testMultipleIPsWithDefault() STARTED

ClusterConnectionStatesTest > testMultipleIPsWithDefault() PASSED

ClusterConnectionStatesTest > testTimedOutConnections() STARTED

ClusterConnectionStatesTest > testTimedOutConnections() PASSED

ClusterConnectionStatesTest > testThrottled() STARTED

ClusterConnectionStatesTest > testThrottled() PASSED

ClusterConnectionStatesTest > testExponentialReconnectBackoff() STARTED

ClusterConnectionStatesTest > testExponentialReconnectBackoff() PASSED

ClusterConnectionStatesTest > testRemoveNode() STARTED

ClusterConnectionStatesTest > testRemoveNode() PASSED

ClusterConnectionStatesTest > testExponentialConnectionSetupTimeout() STARTED

ClusterConnectionStatesTest > testExponentialConnectionSetupTimeout() PASSED

ClusterConnectionStatesTest > testSingleIPWithUseAll() STARTED

ClusterConnectionStatesTest > testSingleIPWithUseAll() PASSED

ClusterConnectionStatesTest > testMultipleIPsWithUseAll() STARTED

ClusterConnectionStatesTest > testMultipleIPsWithUseAll() PASSED

ClusterConnectionStatesTest > testMultipleNodeConnectionStates() STARTED

ClusterConnectionStatesTest > testMultipleNodeConnectionStates() PASSED

ClusterConnectionStatesTest > testClusterConnectionStateChanges() STARTED

ClusterConnectionStatesTest > testClusterConnectionStateChanges() PASSED

ClusterConnectionStatesTest > testMaxReconnectBackoff() STARTED

ClusterConnectionStatesTest > testMaxReconnectBackoff() PASSED

ClusterConnectionStatesTest > testSingleIPWithDefault() STARTED

ClusterConnectionStatesTest > testSingleIPWithDefault() PASSED

FetchSessionHandlerTest > testSessionless() STARTED

FetchSessionHandlerTest > testSessionless() PASSED

FetchSessionHandlerTest > testVerifyFullFetchResponsePartitions() STARTED

FetchSessionHandlerTest > testVerifyFullFetchResponsePartitions() PASSED

FetchSessionHandlerTest > testIncrementals() STARTED

FetchSessionHandlerTest > testIncrementals() PASSED

FetchSessionHandlerTest > testIncrementalPartitionRemoval() STARTED

FetchSessionHandlerTest > testIncrementalPartitionRemoval() PASSED

FetchSessionHandlerTest > testFindMissing() STARTED

FetchSessionHandlerTest > testFindMissing() PASSED

FetchSessionHandlerTest > testDoubleBuild() STARTED

FetchSessionHandlerTest > testDoubleBuild() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 11m 41s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #29

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/29/display/redirect?page=changes>

Changes:

[Matthias J. Sax] KAFKA-12160: Remove max.poll.interval.ms from config docs (#10182)


------------------------------------------
[...truncated 1.80 MB...]

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() STARTED

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() PASSED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() STARTED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() PASSED

QuorumStateTest > testCandidateToLeader() STARTED

QuorumStateTest > testCandidateToLeader() PASSED

QuorumStateTest > testVotedToFollowerHigherEpoch() STARTED

QuorumStateTest > testVotedToFollowerHigherEpoch() PASSED

QuorumStateTest > testLeaderToFollower() STARTED

QuorumStateTest > testLeaderToFollower() PASSED

QuorumStateTest > testInitializeAsFollower() STARTED

QuorumStateTest > testInitializeAsFollower() PASSED

QuorumStateTest > testInitializeAsResignedCandidate() STARTED

QuorumStateTest > testInitializeAsResignedCandidate() PASSED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() STARTED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() PASSED

QuorumStateTest > testFollowerToFollowerHigherEpoch() STARTED

QuorumStateTest > testFollowerToFollowerHigherEpoch() PASSED

QuorumStateTest > testHighWatermarkRetained() STARTED

QuorumStateTest > testHighWatermarkRetained() PASSED

QuorumStateTest > testVotedToVotedSameEpoch() STARTED

QuorumStateTest > testVotedToVotedSameEpoch() PASSED

QuorumStateTest > testLeaderToLeader() STARTED

QuorumStateTest > testLeaderToLeader() PASSED

QuorumStateTest > testHasRemoteLeader() STARTED

QuorumStateTest > testHasRemoteLeader() PASSED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() PASSED

QuorumStateTest > testVotedToUnattachedSameEpoch() STARTED

QuorumStateTest > testVotedToUnattachedSameEpoch() PASSED

QuorumStateTest > testLeaderToUnattached() STARTED

QuorumStateTest > testLeaderToUnattached() PASSED

QuorumStateTest > testInitializeAsVoted() STARTED

QuorumStateTest > testInitializeAsVoted() PASSED

QuorumStateTest > testUnattachedToCandidate() STARTED

QuorumStateTest > testUnattachedToCandidate() PASSED

QuorumStateTest > testUnattachedToFollowerSameEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerSameEpoch() PASSED

QuorumStateTest > testFollowerToUnattachedSameEpoch() STARTED

QuorumStateTest > testFollowerToUnattachedSameEpoch() PASSED

QuorumStateTest > testInitializeAsResignedLeader() STARTED

QuorumStateTest > testInitializeAsResignedLeader() PASSED

QuorumStateTest > testCandidateToVoted() STARTED

QuorumStateTest > testCandidateToVoted() PASSED

QuorumStateTest > testInitializeWithEmptyLocalId() STARTED

QuorumStateTest > testInitializeWithEmptyLocalId() PASSED

QuorumStateTest > testCandidateToResigned() STARTED

QuorumStateTest > testCandidateToResigned() PASSED

QuorumStateTest > testCannotFollowOrVoteForSelf() STARTED

QuorumStateTest > testCannotFollowOrVoteForSelf() PASSED

MockExpirationServiceTest > testFailAfter() STARTED

MockExpirationServiceTest > testFailAfter() PASSED

RecordsBatchReaderTest > [1] NONE STARTED

RecordsBatchReaderTest > [1] NONE PASSED

RecordsBatchReaderTest > [2] GZIP STARTED

RecordsBatchReaderTest > [2] GZIP PASSED

RecordsBatchReaderTest > [3] SNAPPY STARTED

RecordsBatchReaderTest > [3] SNAPPY PASSED

RecordsBatchReaderTest > [4] LZ4 STARTED

RecordsBatchReaderTest > [4] LZ4 PASSED

RecordsBatchReaderTest > [5] ZSTD STARTED

RecordsBatchReaderTest > [5] ZSTD PASSED

RecordsBatchReaderTest > [1] NONE STARTED

RecordsBatchReaderTest > [1] NONE PASSED

RecordsBatchReaderTest > [2] GZIP STARTED

RecordsBatchReaderTest > [2] GZIP PASSED

RecordsBatchReaderTest > [3] SNAPPY STARTED

RecordsBatchReaderTest > [3] SNAPPY PASSED

RecordsBatchReaderTest > [4] LZ4 STARTED

RecordsBatchReaderTest > [4] LZ4 PASSED

RecordsBatchReaderTest > [5] ZSTD STARTED

RecordsBatchReaderTest > [5] ZSTD PASSED

BatchMemoryPoolTest > testOversizeAllocation() STARTED

BatchMemoryPoolTest > testOversizeAllocation() PASSED

BatchMemoryPoolTest > testReleaseBufferNotMatchingBatchSize() STARTED

BatchMemoryPoolTest > testReleaseBufferNotMatchingBatchSize() PASSED

BatchMemoryPoolTest > testAllocateAndRelease() STARTED

BatchMemoryPoolTest > testAllocateAndRelease() PASSED

BatchMemoryPoolTest > testMultipleAllocations() STARTED

BatchMemoryPoolTest > testMultipleAllocations() PASSED

BatchBuilderTest > [1] NONE STARTED

BatchBuilderTest > [1] NONE PASSED

BatchBuilderTest > [2] GZIP STARTED

BatchBuilderTest > [2] GZIP PASSED

BatchBuilderTest > [3] SNAPPY STARTED

BatchBuilderTest > [3] SNAPPY PASSED

BatchBuilderTest > [4] LZ4 STARTED

BatchBuilderTest > [4] LZ4 PASSED

BatchBuilderTest > [5] ZSTD STARTED

BatchBuilderTest > [5] ZSTD PASSED

BatchBuilderTest > [1] 128 STARTED

BatchBuilderTest > [1] 128 PASSED

BatchBuilderTest > [2] 157 STARTED

BatchBuilderTest > [2] 157 PASSED

BatchBuilderTest > [3] 256 STARTED

BatchBuilderTest > [3] 256 PASSED

BatchBuilderTest > [4] 433 STARTED

BatchBuilderTest > [4] 433 PASSED

BatchBuilderTest > [5] 512 STARTED

BatchBuilderTest > [5] 512 PASSED

BatchBuilderTest > [6] 777 STARTED

BatchBuilderTest > [6] 777 PASSED

BatchBuilderTest > [7] 1024 STARTED

BatchBuilderTest > [7] 1024 PASSED

ThresholdPurgatoryTest > testExpiration() STARTED

ThresholdPurgatoryTest > testExpiration() PASSED

ThresholdPurgatoryTest > testExternalCompletion() STARTED

ThresholdPurgatoryTest > testExternalCompletion() PASSED

ThresholdPurgatoryTest > testCompleteAllExceptionally() STARTED

ThresholdPurgatoryTest > testCompleteAllExceptionally() PASSED

ThresholdPurgatoryTest > testThresholdCompletion() STARTED

ThresholdPurgatoryTest > testThresholdCompletion() PASSED

ThresholdPurgatoryTest > testCompleteAll() STARTED

ThresholdPurgatoryTest > testCompleteAll() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 11m 40s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #28

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/28/display/redirect?page=changes>

Changes:

[Colin McCabe] MINOR: fix some ducktape test issues (#10181)


------------------------------------------
[...truncated 1.80 MB...]

KafkaConsumerTest > testClosingConsumerUnregistersConsumerMetrics() STARTED

KafkaConsumerTest > testClosingConsumerUnregistersConsumerMetrics() PASSED

KafkaConsumerTest > testSubscriptionOnInvalidTopic() STARTED

KafkaConsumerTest > testSubscriptionOnInvalidTopic() PASSED

KafkaConsumerTest > testAutoCommitSentBeforePositionUpdate() STARTED

KafkaConsumerTest > testAutoCommitSentBeforePositionUpdate() PASSED

KafkaConsumerTest > fetchResponseWithUnexpectedPartitionIsIgnored() STARTED

KafkaConsumerTest > fetchResponseWithUnexpectedPartitionIsIgnored() PASSED

KafkaConsumerTest > testPollThrowsInterruptExceptionIfInterrupted() STARTED

KafkaConsumerTest > testPollThrowsInterruptExceptionIfInterrupted() PASSED

KafkaConsumerTest > testSubscriptionOnNullPattern() STARTED

KafkaConsumerTest > testSubscriptionOnNullPattern() PASSED

KafkaConsumerTest > testEnforceRebalanceTriggersRebalanceOnNextPoll() STARTED

KafkaConsumerTest > testEnforceRebalanceTriggersRebalanceOnNextPoll() PASSED

KafkaConsumerTest > testEnforceRebalanceWithManualAssignment() STARTED

KafkaConsumerTest > testEnforceRebalanceWithManualAssignment() PASSED

KafkaConsumerTest > testShouldAttemptToRejoinGroupAfterSyncGroupFailed() STARTED

KafkaConsumerTest > testShouldAttemptToRejoinGroupAfterSyncGroupFailed() PASSED

KafkaConsumerTest > testCommitSyncAuthenticationFailure() STARTED

KafkaConsumerTest > testCommitSyncAuthenticationFailure() PASSED

KafkaConsumerTest > verifyHeartbeatSent() STARTED

KafkaConsumerTest > verifyHeartbeatSent() PASSED

KafkaConsumerTest > verifyHeartbeatSentWhenFetchedDataReady() STARTED

KafkaConsumerTest > verifyHeartbeatSentWhenFetchedDataReady() PASSED

KafkaConsumerTest > testResetUsingAutoResetPolicy() STARTED

KafkaConsumerTest > testResetUsingAutoResetPolicy() PASSED

KafkaConsumerTest > testNoCommittedOffsets() STARTED

KafkaConsumerTest > testNoCommittedOffsets() PASSED

KafkaConsumerTest > testOperationsByAssigningConsumerWithDefaultGroupId() STARTED

KafkaConsumerTest > testOperationsByAssigningConsumerWithDefaultGroupId() PASSED

KafkaConsumerTest > testAssignOnEmptyTopicPartition() STARTED

KafkaConsumerTest > testAssignOnEmptyTopicPartition() PASSED

KafkaConsumerTest > testFetchStableOffsetThrowInCommitted() STARTED

KafkaConsumerTest > testFetchStableOffsetThrowInCommitted() PASSED

KafkaConsumerTest > testUnsubscribeShouldTriggerPartitionsLostWithNoGeneration() STARTED

KafkaConsumerTest > testUnsubscribeShouldTriggerPartitionsLostWithNoGeneration() PASSED

KafkaConsumerTest > testUnusedConfigs() STARTED

KafkaConsumerTest > testUnusedConfigs() PASSED

KafkaConsumerTest > testSubscriptionOnNullTopic() STARTED

KafkaConsumerTest > testSubscriptionOnNullTopic() PASSED

KafkaConsumerTest > testSubscription() STARTED

KafkaConsumerTest > testSubscription() PASSED

KafkaConsumerTest > testInterceptorConstructorClose() STARTED

KafkaConsumerTest > testInterceptorConstructorClose() PASSED

KafkaConsumerTest > testSubscriptionOnEmptyTopic() STARTED

KafkaConsumerTest > testSubscriptionOnEmptyTopic() PASSED

KafkaConsumerTest > testWakeupWithFetchDataAvailable() STARTED

KafkaConsumerTest > testWakeupWithFetchDataAvailable() PASSED

KafkaConsumerTest > testReturnRecordsDuringRebalance() STARTED

KafkaConsumerTest > testReturnRecordsDuringRebalance() PASSED

KafkaConsumerTest > testLeaveGroupTimeout() STARTED

KafkaConsumerTest > testLeaveGroupTimeout() PASSED

KafkaConsumerTest > testFetchStableOffsetThrowInPoll() STARTED

KafkaConsumerTest > testFetchStableOffsetThrowInPoll() PASSED

KafkaConsumerTest > testPartitionsForAuthenticationFailure() STARTED

KafkaConsumerTest > testPartitionsForAuthenticationFailure() PASSED

KafkaConsumerTest > testSubscriptionOnNullTopicCollection() STARTED

KafkaConsumerTest > testSubscriptionOnNullTopicCollection() PASSED

KafkaConsumerTest > testCloseWithTimeUnit() STARTED

KafkaConsumerTest > testCloseWithTimeUnit() PASSED

ConsumerRecordTest > testNullChecksumInConstructor() STARTED

ConsumerRecordTest > testNullChecksumInConstructor() PASSED

ConsumerRecordTest > testOldConstructor() STARTED

ConsumerRecordTest > testOldConstructor() PASSED

ClientUtilsTest > testResolveDnsLookupResolveCanonicalBootstrapServers() STARTED

ClientUtilsTest > testResolveDnsLookupResolveCanonicalBootstrapServers() PASSED

ClientUtilsTest > testFilterPreferredAddresses() STARTED

ClientUtilsTest > testFilterPreferredAddresses() PASSED

ClientUtilsTest > testResolveUnknownHostException() STARTED

ClientUtilsTest > testResolveUnknownHostException() PASSED

ClientUtilsTest > testOnlyBadHostname() STARTED

ClientUtilsTest > testOnlyBadHostname() PASSED

ClientUtilsTest > testInvalidConfig() STARTED

ClientUtilsTest > testInvalidConfig() PASSED

ClientUtilsTest > testResolveDnsLookupAllIps() STARTED

ClientUtilsTest > testResolveDnsLookupAllIps() PASSED

ClientUtilsTest > testResolveDnsLookup() STARTED

ClientUtilsTest > testResolveDnsLookup() PASSED

ClientUtilsTest > testParseAndValidateAddresses() STARTED

ClientUtilsTest > testParseAndValidateAddresses() PASSED

ClientUtilsTest > testParseAndValidateAddressesWithReverseLookup() STARTED

ClientUtilsTest > testParseAndValidateAddressesWithReverseLookup() PASSED

ClientUtilsTest > testNoPort() STARTED

ClientUtilsTest > testNoPort() PASSED

> Task :raft:test

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeFiveAndThreeObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeThreeAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeThreeAndTwoObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderGracefulShutdownQuorumSizeThreeAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderGracefulShutdownQuorumSizeThreeAndTwoObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderFailureQuorumSizeThreeAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderFailureQuorumSizeThreeAndTwoObservers() PASSED

RaftEventSimulationTest > testBackToBackLeaderFailuresQuorumSizeFiveAndTwoObservers() STARTED

RaftEventSimulationTest > testBackToBackLeaderFailuresQuorumSizeFiveAndTwoObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeFourAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeFourAndTwoObservers() PASSED

MockExpirationServiceTest > testFailAfter() STARTED

MockExpirationServiceTest > testFailAfter() PASSED

FileRawSnapshotTest > testBatchWriteReadSnapshot() STARTED

FileRawSnapshotTest > testBatchWriteReadSnapshot() PASSED

FileRawSnapshotTest > testCreateSnapshotWithSameId() STARTED

FileRawSnapshotTest > testCreateSnapshotWithSameId() PASSED

FileRawSnapshotTest > testPartialWriteReadSnapshot() STARTED

FileRawSnapshotTest > testPartialWriteReadSnapshot() PASSED

FileRawSnapshotTest > testBufferWriteReadSnapshot() STARTED

FileRawSnapshotTest > testBufferWriteReadSnapshot() PASSED

FileRawSnapshotTest > testAbortedSnapshot() STARTED

FileRawSnapshotTest > testAbortedSnapshot() PASSED

FileRawSnapshotTest > testAppendToFrozenSnapshot() STARTED

FileRawSnapshotTest > testAppendToFrozenSnapshot() PASSED

FileRawSnapshotTest > testWritingSnapshot() STARTED

FileRawSnapshotTest > testWritingSnapshot() PASSED

FileRawSnapshotTest > testWriteReadSnapshot() STARTED

FileRawSnapshotTest > testWriteReadSnapshot() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 17m 17s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #27

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/27/display/redirect?page=changes>

Changes:

[Colin McCabe] MINOR: Test the new KIP-500 quorum mode in ducktape (#10105)


------------------------------------------
[...truncated 1.80 MB...]

QuorumStateTest > testVotedToInvalidLeaderOrResigned() STARTED

QuorumStateTest > testVotedToInvalidLeaderOrResigned() PASSED

QuorumStateTest > testUnattachedToUnattached() STARTED

QuorumStateTest > testUnattachedToUnattached() PASSED

QuorumStateTest > testCandidateToUnattached() STARTED

QuorumStateTest > testCandidateToUnattached() PASSED

QuorumStateTest > testObserverInitializationFailsIfElectionStateHasVotedCandidate() STARTED

QuorumStateTest > testObserverInitializationFailsIfElectionStateHasVotedCandidate() PASSED

QuorumStateTest > testUnattachedToVotedHigherEpoch() STARTED

QuorumStateTest > testUnattachedToVotedHigherEpoch() PASSED

QuorumStateTest > testFollowerToVotedHigherEpoch() STARTED

QuorumStateTest > testFollowerToVotedHigherEpoch() PASSED

QuorumStateTest > testCandidateToFollower() STARTED

QuorumStateTest > testCandidateToFollower() PASSED

QuorumStateTest > testVotedToFollowerSameEpoch() STARTED

QuorumStateTest > testVotedToFollowerSameEpoch() PASSED

QuorumStateTest > testLeaderToCandidate() STARTED

QuorumStateTest > testLeaderToCandidate() PASSED

QuorumStateTest > testUnattachedToLeaderOrResigned() STARTED

QuorumStateTest > testUnattachedToLeaderOrResigned() PASSED

QuorumStateTest > testFollowerToUnattachedHigherEpoch() STARTED

QuorumStateTest > testFollowerToUnattachedHigherEpoch() PASSED

QuorumStateTest > testFollowerToLeaderOrResigned() STARTED

QuorumStateTest > testFollowerToLeaderOrResigned() PASSED

QuorumStateTest > testFollowerToVotedSameEpoch() STARTED

QuorumStateTest > testFollowerToVotedSameEpoch() PASSED

QuorumStateTest > testObserverFollowerToUnattached() STARTED

QuorumStateTest > testObserverFollowerToUnattached() PASSED

QuorumStateTest > testFollowerToFollowerSameEpoch() STARTED

QuorumStateTest > testFollowerToFollowerSameEpoch() PASSED

QuorumStateTest > testCandidateToAnyStateLowerEpoch() STARTED

QuorumStateTest > testCandidateToAnyStateLowerEpoch() PASSED

QuorumStateTest > testVotedToUnattachedHigherEpoch() STARTED

QuorumStateTest > testVotedToUnattachedHigherEpoch() PASSED

QuorumStateTest > testUnattachedToVotedSameEpoch() STARTED

QuorumStateTest > testUnattachedToVotedSameEpoch() PASSED

QuorumStateTest > testVotedToAnyStateLowerEpoch() STARTED

QuorumStateTest > testVotedToAnyStateLowerEpoch() PASSED

QuorumStateTest > testCandidateToCandidate() STARTED

QuorumStateTest > testCandidateToCandidate() PASSED

QuorumStateTest > testLeaderToAnyStateLowerEpoch() STARTED

QuorumStateTest > testLeaderToAnyStateLowerEpoch() PASSED

QuorumStateTest > testFollowerToCandidate() STARTED

QuorumStateTest > testFollowerToCandidate() PASSED

QuorumStateTest > testLeaderToVoted() STARTED

QuorumStateTest > testLeaderToVoted() PASSED

QuorumStateTest > testLeaderToResigned() STARTED

QuorumStateTest > testLeaderToResigned() PASSED

QuorumStateTest > testInitializePrimordialEpoch() STARTED

QuorumStateTest > testInitializePrimordialEpoch() PASSED

QuorumStateTest > testFollowerToAnyStateLowerEpoch() STARTED

QuorumStateTest > testFollowerToAnyStateLowerEpoch() PASSED

QuorumStateTest > testInitializeWithCorruptedStore() STARTED

QuorumStateTest > testInitializeWithCorruptedStore() PASSED

QuorumStateTest > testObserverUnattachedToFollower() STARTED

QuorumStateTest > testObserverUnattachedToFollower() PASSED

QuorumStateTest > testCannotBecomeFollowerOfNonVoter() STARTED

QuorumStateTest > testCannotBecomeFollowerOfNonVoter() PASSED

QuorumStateTest > testObserverCannotBecomeCandidateOrLeaderOrVoted() STARTED

QuorumStateTest > testObserverCannotBecomeCandidateOrLeaderOrVoted() PASSED

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() STARTED

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() PASSED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() STARTED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() PASSED

QuorumStateTest > testCandidateToLeader() STARTED

QuorumStateTest > testCandidateToLeader() PASSED

QuorumStateTest > testVotedToFollowerHigherEpoch() STARTED

QuorumStateTest > testVotedToFollowerHigherEpoch() PASSED

QuorumStateTest > testLeaderToFollower() STARTED

QuorumStateTest > testLeaderToFollower() PASSED

QuorumStateTest > testInitializeAsFollower() STARTED

QuorumStateTest > testInitializeAsFollower() PASSED

QuorumStateTest > testInitializeAsResignedCandidate() STARTED

QuorumStateTest > testInitializeAsResignedCandidate() PASSED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() STARTED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() PASSED

QuorumStateTest > testFollowerToFollowerHigherEpoch() STARTED

QuorumStateTest > testFollowerToFollowerHigherEpoch() PASSED

QuorumStateTest > testHighWatermarkRetained() STARTED

QuorumStateTest > testHighWatermarkRetained() PASSED

QuorumStateTest > testVotedToVotedSameEpoch() STARTED

QuorumStateTest > testVotedToVotedSameEpoch() PASSED

QuorumStateTest > testLeaderToLeader() STARTED

QuorumStateTest > testLeaderToLeader() PASSED

QuorumStateTest > testHasRemoteLeader() STARTED

QuorumStateTest > testHasRemoteLeader() PASSED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() PASSED

QuorumStateTest > testVotedToUnattachedSameEpoch() STARTED

QuorumStateTest > testVotedToUnattachedSameEpoch() PASSED

QuorumStateTest > testLeaderToUnattached() STARTED

QuorumStateTest > testLeaderToUnattached() PASSED

QuorumStateTest > testInitializeAsVoted() STARTED

QuorumStateTest > testInitializeAsVoted() PASSED

QuorumStateTest > testUnattachedToCandidate() STARTED

QuorumStateTest > testUnattachedToCandidate() PASSED

QuorumStateTest > testUnattachedToFollowerSameEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerSameEpoch() PASSED

QuorumStateTest > testFollowerToUnattachedSameEpoch() STARTED

QuorumStateTest > testFollowerToUnattachedSameEpoch() PASSED

QuorumStateTest > testInitializeAsResignedLeader() STARTED

QuorumStateTest > testInitializeAsResignedLeader() PASSED

QuorumStateTest > testCandidateToVoted() STARTED

QuorumStateTest > testCandidateToVoted() PASSED

QuorumStateTest > testInitializeWithEmptyLocalId() STARTED

QuorumStateTest > testInitializeWithEmptyLocalId() PASSED

QuorumStateTest > testCandidateToResigned() STARTED

QuorumStateTest > testCandidateToResigned() PASSED

QuorumStateTest > testCannotFollowOrVoteForSelf() STARTED

QuorumStateTest > testCannotFollowOrVoteForSelf() PASSED

FileBasedStateStoreTest > testReadElectionState() STARTED

FileBasedStateStoreTest > testReadElectionState() PASSED

FileBasedStateStoreTest > testWriteElectionState() STARTED

FileBasedStateStoreTest > testWriteElectionState() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 10m 48s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #26

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/26/display/redirect?page=changes>

Changes:

[Jason Gustafson] MINOR: Raft request thread should discover api versions (#10157)


------------------------------------------
[...truncated 1.80 MB...]

QuorumStateTest > testInitializePrimordialEpoch() STARTED

QuorumStateTest > testInitializePrimordialEpoch() PASSED

QuorumStateTest > testFollowerToAnyStateLowerEpoch() STARTED

QuorumStateTest > testFollowerToAnyStateLowerEpoch() PASSED

QuorumStateTest > testInitializeWithCorruptedStore() STARTED

QuorumStateTest > testInitializeWithCorruptedStore() PASSED

QuorumStateTest > testObserverUnattachedToFollower() STARTED

QuorumStateTest > testObserverUnattachedToFollower() PASSED

QuorumStateTest > testCannotBecomeFollowerOfNonVoter() STARTED

QuorumStateTest > testCannotBecomeFollowerOfNonVoter() PASSED

QuorumStateTest > testObserverCannotBecomeCandidateOrLeaderOrVoted() STARTED

QuorumStateTest > testObserverCannotBecomeCandidateOrLeaderOrVoted() PASSED

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() STARTED

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() PASSED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() STARTED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() PASSED

QuorumStateTest > testCandidateToLeader() STARTED

QuorumStateTest > testCandidateToLeader() PASSED

QuorumStateTest > testVotedToFollowerHigherEpoch() STARTED

QuorumStateTest > testVotedToFollowerHigherEpoch() PASSED

QuorumStateTest > testLeaderToFollower() STARTED

QuorumStateTest > testLeaderToFollower() PASSED

QuorumStateTest > testInitializeAsFollower() STARTED

QuorumStateTest > testInitializeAsFollower() PASSED

QuorumStateTest > testInitializeAsResignedCandidate() STARTED

QuorumStateTest > testInitializeAsResignedCandidate() PASSED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() STARTED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() PASSED

QuorumStateTest > testFollowerToFollowerHigherEpoch() STARTED

QuorumStateTest > testFollowerToFollowerHigherEpoch() PASSED

QuorumStateTest > testHighWatermarkRetained() STARTED

QuorumStateTest > testHighWatermarkRetained() PASSED

QuorumStateTest > testVotedToVotedSameEpoch() STARTED

QuorumStateTest > testVotedToVotedSameEpoch() PASSED

QuorumStateTest > testLeaderToLeader() STARTED

QuorumStateTest > testLeaderToLeader() PASSED

QuorumStateTest > testHasRemoteLeader() STARTED

QuorumStateTest > testHasRemoteLeader() PASSED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() PASSED

QuorumStateTest > testVotedToUnattachedSameEpoch() STARTED

QuorumStateTest > testVotedToUnattachedSameEpoch() PASSED

QuorumStateTest > testLeaderToUnattached() STARTED

QuorumStateTest > testLeaderToUnattached() PASSED

QuorumStateTest > testInitializeAsVoted() STARTED

QuorumStateTest > testInitializeAsVoted() PASSED

QuorumStateTest > testUnattachedToCandidate() STARTED

QuorumStateTest > testUnattachedToCandidate() PASSED

QuorumStateTest > testUnattachedToFollowerSameEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerSameEpoch() PASSED

QuorumStateTest > testFollowerToUnattachedSameEpoch() STARTED

QuorumStateTest > testFollowerToUnattachedSameEpoch() PASSED

QuorumStateTest > testInitializeAsResignedLeader() STARTED

QuorumStateTest > testInitializeAsResignedLeader() PASSED

QuorumStateTest > testCandidateToVoted() STARTED

QuorumStateTest > testCandidateToVoted() PASSED

QuorumStateTest > testInitializeWithEmptyLocalId() STARTED

QuorumStateTest > testInitializeWithEmptyLocalId() PASSED

QuorumStateTest > testCandidateToResigned() STARTED

QuorumStateTest > testCandidateToResigned() PASSED

QuorumStateTest > testCannotFollowOrVoteForSelf() STARTED

QuorumStateTest > testCannotFollowOrVoteForSelf() PASSED

FollowerStateTest > testFetchTimeoutExpiration() STARTED

FollowerStateTest > testFetchTimeoutExpiration() PASSED

FollowerStateTest > testMonotonicHighWatermark() STARTED

FollowerStateTest > testMonotonicHighWatermark() PASSED

RequestManagerTest > testResetAllConnections() STARTED

RequestManagerTest > testResetAllConnections() PASSED

RequestManagerTest > testSuccessfulResponse() STARTED

RequestManagerTest > testSuccessfulResponse() PASSED

RequestManagerTest > testRequestTimeout() STARTED

RequestManagerTest > testRequestTimeout() PASSED

RequestManagerTest > testBackoffAfterFailure() STARTED

RequestManagerTest > testBackoffAfterFailure() PASSED

RequestManagerTest > testIgnoreUnexpectedResponse() STARTED

RequestManagerTest > testIgnoreUnexpectedResponse() PASSED

ThresholdPurgatoryTest > testExpiration() STARTED

ThresholdPurgatoryTest > testExpiration() PASSED

ThresholdPurgatoryTest > testExternalCompletion() STARTED

ThresholdPurgatoryTest > testExternalCompletion() PASSED

ThresholdPurgatoryTest > testCompleteAllExceptionally() STARTED

ThresholdPurgatoryTest > testCompleteAllExceptionally() PASSED

ThresholdPurgatoryTest > testThresholdCompletion() STARTED

ThresholdPurgatoryTest > testThresholdCompletion() PASSED

ThresholdPurgatoryTest > testCompleteAll() STARTED

ThresholdPurgatoryTest > testCompleteAll() PASSED

KafkaRaftMetricsTest > shouldRecordVoterQuorumState() STARTED

KafkaRaftMetricsTest > shouldRecordVoterQuorumState() PASSED

KafkaRaftMetricsTest > shouldRecordNonVoterQuorumState() STARTED

KafkaRaftMetricsTest > shouldRecordNonVoterQuorumState() PASSED

KafkaRaftMetricsTest > shouldRecordRate() STARTED

KafkaRaftMetricsTest > shouldRecordRate() PASSED

KafkaRaftMetricsTest > shouldRecordLogEnd() STARTED

KafkaRaftMetricsTest > shouldRecordLogEnd() PASSED

KafkaRaftMetricsTest > shouldRecordNumUnknownVoterConnections() STARTED

KafkaRaftMetricsTest > shouldRecordNumUnknownVoterConnections() PASSED

KafkaRaftMetricsTest > shouldRecordLatency() STARTED

KafkaRaftMetricsTest > shouldRecordLatency() PASSED

KafkaRaftMetricsTest > shouldRecordPollIdleRatio() STARTED

KafkaRaftMetricsTest > shouldRecordPollIdleRatio() PASSED

BlockingMessageQueueTest > testOfferAndPoll() STARTED

BlockingMessageQueueTest > testOfferAndPoll() PASSED

BlockingMessageQueueTest > testWakeupFromPoll() STARTED

BlockingMessageQueueTest > testWakeupFromPoll() PASSED

BatchMemoryPoolTest > testOversizeAllocation() STARTED

BatchMemoryPoolTest > testOversizeAllocation() PASSED

BatchMemoryPoolTest > testReleaseBufferNotMatchingBatchSize() STARTED

BatchMemoryPoolTest > testReleaseBufferNotMatchingBatchSize() PASSED

BatchMemoryPoolTest > testAllocateAndRelease() STARTED

BatchMemoryPoolTest > testAllocateAndRelease() PASSED

BatchMemoryPoolTest > testMultipleAllocations() STARTED

BatchMemoryPoolTest > testMultipleAllocations() PASSED

VotedStateTest > testElectionTimeout() STARTED

VotedStateTest > testElectionTimeout() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 10m 54s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #25

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/25/display/redirect?page=changes>

Changes:

[Manikumar Reddy] KAFKA-12324: Upgrade jetty to fix CVE-2020-27218


------------------------------------------
[...truncated 1.80 MB...]

QuorumStateTest > testFollowerToLeaderOrResigned() STARTED

QuorumStateTest > testFollowerToLeaderOrResigned() PASSED

QuorumStateTest > testFollowerToVotedSameEpoch() STARTED

QuorumStateTest > testFollowerToVotedSameEpoch() PASSED

QuorumStateTest > testObserverFollowerToUnattached() STARTED

QuorumStateTest > testObserverFollowerToUnattached() PASSED

QuorumStateTest > testFollowerToFollowerSameEpoch() STARTED

QuorumStateTest > testFollowerToFollowerSameEpoch() PASSED

QuorumStateTest > testCandidateToAnyStateLowerEpoch() STARTED

QuorumStateTest > testCandidateToAnyStateLowerEpoch() PASSED

QuorumStateTest > testVotedToUnattachedHigherEpoch() STARTED

QuorumStateTest > testVotedToUnattachedHigherEpoch() PASSED

QuorumStateTest > testUnattachedToVotedSameEpoch() STARTED

QuorumStateTest > testUnattachedToVotedSameEpoch() PASSED

QuorumStateTest > testVotedToAnyStateLowerEpoch() STARTED

QuorumStateTest > testVotedToAnyStateLowerEpoch() PASSED

QuorumStateTest > testCandidateToCandidate() STARTED

QuorumStateTest > testCandidateToCandidate() PASSED

QuorumStateTest > testLeaderToAnyStateLowerEpoch() STARTED

QuorumStateTest > testLeaderToAnyStateLowerEpoch() PASSED

QuorumStateTest > testFollowerToCandidate() STARTED

QuorumStateTest > testFollowerToCandidate() PASSED

QuorumStateTest > testLeaderToVoted() STARTED

QuorumStateTest > testLeaderToVoted() PASSED

QuorumStateTest > testLeaderToResigned() STARTED

QuorumStateTest > testLeaderToResigned() PASSED

QuorumStateTest > testInitializePrimordialEpoch() STARTED

QuorumStateTest > testInitializePrimordialEpoch() PASSED

QuorumStateTest > testFollowerToAnyStateLowerEpoch() STARTED

QuorumStateTest > testFollowerToAnyStateLowerEpoch() PASSED

QuorumStateTest > testInitializeWithCorruptedStore() STARTED

QuorumStateTest > testInitializeWithCorruptedStore() PASSED

QuorumStateTest > testObserverUnattachedToFollower() STARTED

QuorumStateTest > testObserverUnattachedToFollower() PASSED

QuorumStateTest > testCannotBecomeFollowerOfNonVoter() STARTED

QuorumStateTest > testCannotBecomeFollowerOfNonVoter() PASSED

QuorumStateTest > testObserverCannotBecomeCandidateOrLeaderOrVoted() STARTED

QuorumStateTest > testObserverCannotBecomeCandidateOrLeaderOrVoted() PASSED

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() STARTED

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() PASSED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() STARTED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() PASSED

QuorumStateTest > testCandidateToLeader() STARTED

QuorumStateTest > testCandidateToLeader() PASSED

QuorumStateTest > testVotedToFollowerHigherEpoch() STARTED

QuorumStateTest > testVotedToFollowerHigherEpoch() PASSED

QuorumStateTest > testLeaderToFollower() STARTED

QuorumStateTest > testLeaderToFollower() PASSED

QuorumStateTest > testInitializeAsFollower() STARTED

QuorumStateTest > testInitializeAsFollower() PASSED

QuorumStateTest > testInitializeAsResignedCandidate() STARTED

QuorumStateTest > testInitializeAsResignedCandidate() PASSED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() STARTED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() PASSED

QuorumStateTest > testFollowerToFollowerHigherEpoch() STARTED

QuorumStateTest > testFollowerToFollowerHigherEpoch() PASSED

QuorumStateTest > testHighWatermarkRetained() STARTED

QuorumStateTest > testHighWatermarkRetained() PASSED

QuorumStateTest > testVotedToVotedSameEpoch() STARTED

QuorumStateTest > testVotedToVotedSameEpoch() PASSED

QuorumStateTest > testLeaderToLeader() STARTED

QuorumStateTest > testLeaderToLeader() PASSED

QuorumStateTest > testHasRemoteLeader() STARTED

QuorumStateTest > testHasRemoteLeader() PASSED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() PASSED

QuorumStateTest > testVotedToUnattachedSameEpoch() STARTED

QuorumStateTest > testVotedToUnattachedSameEpoch() PASSED

QuorumStateTest > testLeaderToUnattached() STARTED

QuorumStateTest > testLeaderToUnattached() PASSED

QuorumStateTest > testInitializeAsVoted() STARTED

QuorumStateTest > testInitializeAsVoted() PASSED

QuorumStateTest > testUnattachedToCandidate() STARTED

QuorumStateTest > testUnattachedToCandidate() PASSED

QuorumStateTest > testUnattachedToFollowerSameEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerSameEpoch() PASSED

QuorumStateTest > testFollowerToUnattachedSameEpoch() STARTED

QuorumStateTest > testFollowerToUnattachedSameEpoch() PASSED

QuorumStateTest > testInitializeAsResignedLeader() STARTED

QuorumStateTest > testInitializeAsResignedLeader() PASSED

QuorumStateTest > testCandidateToVoted() STARTED

QuorumStateTest > testCandidateToVoted() PASSED

QuorumStateTest > testInitializeWithEmptyLocalId() STARTED

QuorumStateTest > testInitializeWithEmptyLocalId() PASSED

QuorumStateTest > testCandidateToResigned() STARTED

QuorumStateTest > testCandidateToResigned() PASSED

QuorumStateTest > testCannotFollowOrVoteForSelf() STARTED

QuorumStateTest > testCannotFollowOrVoteForSelf() PASSED

LeaderStateTest > testUpdateHighWatermarkMetadata() STARTED

LeaderStateTest > testUpdateHighWatermarkMetadata() PASSED

LeaderStateTest > testNonFollowerAcknowledgement() STARTED

LeaderStateTest > testNonFollowerAcknowledgement() PASSED

LeaderStateTest > testUpdateHighWatermarkQuorumSizeOne() STARTED

LeaderStateTest > testUpdateHighWatermarkQuorumSizeOne() PASSED

LeaderStateTest > testUpdateHighWatermarkQuorumSizeTwo() STARTED

LeaderStateTest > testUpdateHighWatermarkQuorumSizeTwo() PASSED

LeaderStateTest > testNoOpForNegativeRemoteNodeId() STARTED

LeaderStateTest > testNoOpForNegativeRemoteNodeId() PASSED

LeaderStateTest > testGetObserverStatesWithObserver() STARTED

LeaderStateTest > testGetObserverStatesWithObserver() PASSED

LeaderStateTest > testUpdateHighWatermarkQuorumSizeThree() STARTED

LeaderStateTest > testUpdateHighWatermarkQuorumSizeThree() PASSED

LeaderStateTest > testFollowerAcknowledgement() STARTED

LeaderStateTest > testFollowerAcknowledgement() PASSED

LeaderStateTest > testHighWatermarkUnknownUntilStartOfLeaderEpoch() STARTED

LeaderStateTest > testHighWatermarkUnknownUntilStartOfLeaderEpoch() PASSED

LeaderStateTest > testIdempotentEndOffsetUpdate() STARTED

LeaderStateTest > testIdempotentEndOffsetUpdate() PASSED

LeaderStateTest > testNonMonotonicEndOffsetUpdate() STARTED

LeaderStateTest > testNonMonotonicEndOffsetUpdate() PASSED

LeaderStateTest > testGetVoterStates() STARTED

LeaderStateTest > testGetVoterStates() PASSED

LeaderStateTest > testGetNonLeaderFollowersByFetchOffsetDescending() STARTED

LeaderStateTest > testGetNonLeaderFollowersByFetchOffsetDescending() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 10m 47s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #24

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/24/display/redirect?page=changes>

Changes:

[Randall Hauch] KAFKA-12340: Fix potential resource leak in Kafka*BackingStore (#10153)

[Randall Hauch] KAFKA-12339: Add retry to admin client's listOffsets (#10152)


------------------------------------------
[...truncated 1.80 MB...]

QuorumStateTest > testInitializePrimordialEpoch() STARTED

QuorumStateTest > testInitializePrimordialEpoch() PASSED

QuorumStateTest > testFollowerToAnyStateLowerEpoch() STARTED

QuorumStateTest > testFollowerToAnyStateLowerEpoch() PASSED

QuorumStateTest > testInitializeWithCorruptedStore() STARTED

QuorumStateTest > testInitializeWithCorruptedStore() PASSED

QuorumStateTest > testObserverUnattachedToFollower() STARTED

QuorumStateTest > testObserverUnattachedToFollower() PASSED

QuorumStateTest > testCannotBecomeFollowerOfNonVoter() STARTED

QuorumStateTest > testCannotBecomeFollowerOfNonVoter() PASSED

QuorumStateTest > testObserverCannotBecomeCandidateOrLeaderOrVoted() STARTED

QuorumStateTest > testObserverCannotBecomeCandidateOrLeaderOrVoted() PASSED

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() STARTED

QuorumStateTest > testUnattachedToAnyStateLowerEpoch() PASSED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() STARTED

QuorumStateTest > testInconsistentVotersBetweenConfigAndState() PASSED

QuorumStateTest > testCandidateToLeader() STARTED

QuorumStateTest > testCandidateToLeader() PASSED

QuorumStateTest > testVotedToFollowerHigherEpoch() STARTED

QuorumStateTest > testVotedToFollowerHigherEpoch() PASSED

QuorumStateTest > testLeaderToFollower() STARTED

QuorumStateTest > testLeaderToFollower() PASSED

QuorumStateTest > testInitializeAsFollower() STARTED

QuorumStateTest > testInitializeAsFollower() PASSED

QuorumStateTest > testInitializeAsResignedCandidate() STARTED

QuorumStateTest > testInitializeAsResignedCandidate() PASSED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() STARTED

QuorumStateTest > testCandidateToLeaderWithoutGrantedVote() PASSED

QuorumStateTest > testFollowerToFollowerHigherEpoch() STARTED

QuorumStateTest > testFollowerToFollowerHigherEpoch() PASSED

QuorumStateTest > testHighWatermarkRetained() STARTED

QuorumStateTest > testHighWatermarkRetained() PASSED

QuorumStateTest > testVotedToVotedSameEpoch() STARTED

QuorumStateTest > testVotedToVotedSameEpoch() PASSED

QuorumStateTest > testLeaderToLeader() STARTED

QuorumStateTest > testLeaderToLeader() PASSED

QuorumStateTest > testHasRemoteLeader() STARTED

QuorumStateTest > testHasRemoteLeader() PASSED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerHigherEpoch() PASSED

QuorumStateTest > testVotedToUnattachedSameEpoch() STARTED

QuorumStateTest > testVotedToUnattachedSameEpoch() PASSED

QuorumStateTest > testLeaderToUnattached() STARTED

QuorumStateTest > testLeaderToUnattached() PASSED

QuorumStateTest > testInitializeAsVoted() STARTED

QuorumStateTest > testInitializeAsVoted() PASSED

QuorumStateTest > testUnattachedToCandidate() STARTED

QuorumStateTest > testUnattachedToCandidate() PASSED

QuorumStateTest > testUnattachedToFollowerSameEpoch() STARTED

QuorumStateTest > testUnattachedToFollowerSameEpoch() PASSED

QuorumStateTest > testFollowerToUnattachedSameEpoch() STARTED

QuorumStateTest > testFollowerToUnattachedSameEpoch() PASSED

QuorumStateTest > testInitializeAsResignedLeader() STARTED

QuorumStateTest > testInitializeAsResignedLeader() PASSED

QuorumStateTest > testCandidateToVoted() STARTED

QuorumStateTest > testCandidateToVoted() PASSED

QuorumStateTest > testInitializeWithEmptyLocalId() STARTED

QuorumStateTest > testInitializeWithEmptyLocalId() PASSED

QuorumStateTest > testCandidateToResigned() STARTED

QuorumStateTest > testCandidateToResigned() PASSED

QuorumStateTest > testCannotFollowOrVoteForSelf() STARTED

QuorumStateTest > testCannotFollowOrVoteForSelf() PASSED

FollowerStateTest > testFetchTimeoutExpiration() STARTED

FollowerStateTest > testFetchTimeoutExpiration() PASSED

FollowerStateTest > testMonotonicHighWatermark() STARTED

FollowerStateTest > testMonotonicHighWatermark() PASSED

RequestManagerTest > testResetAllConnections() STARTED

RequestManagerTest > testResetAllConnections() PASSED

RequestManagerTest > testSuccessfulResponse() STARTED

RequestManagerTest > testSuccessfulResponse() PASSED

RequestManagerTest > testRequestTimeout() STARTED

RequestManagerTest > testRequestTimeout() PASSED

RequestManagerTest > testBackoffAfterFailure() STARTED

RequestManagerTest > testBackoffAfterFailure() PASSED

RequestManagerTest > testIgnoreUnexpectedResponse() STARTED

RequestManagerTest > testIgnoreUnexpectedResponse() PASSED

ThresholdPurgatoryTest > testExpiration() STARTED

ThresholdPurgatoryTest > testExpiration() PASSED

ThresholdPurgatoryTest > testExternalCompletion() STARTED

ThresholdPurgatoryTest > testExternalCompletion() PASSED

ThresholdPurgatoryTest > testCompleteAllExceptionally() STARTED

ThresholdPurgatoryTest > testCompleteAllExceptionally() PASSED

ThresholdPurgatoryTest > testThresholdCompletion() STARTED

ThresholdPurgatoryTest > testThresholdCompletion() PASSED

ThresholdPurgatoryTest > testCompleteAll() STARTED

ThresholdPurgatoryTest > testCompleteAll() PASSED

KafkaRaftMetricsTest > shouldRecordVoterQuorumState() STARTED

KafkaRaftMetricsTest > shouldRecordVoterQuorumState() PASSED

KafkaRaftMetricsTest > shouldRecordNonVoterQuorumState() STARTED

KafkaRaftMetricsTest > shouldRecordNonVoterQuorumState() PASSED

KafkaRaftMetricsTest > shouldRecordRate() STARTED

KafkaRaftMetricsTest > shouldRecordRate() PASSED

KafkaRaftMetricsTest > shouldRecordLogEnd() STARTED

KafkaRaftMetricsTest > shouldRecordLogEnd() PASSED

KafkaRaftMetricsTest > shouldRecordNumUnknownVoterConnections() STARTED

KafkaRaftMetricsTest > shouldRecordNumUnknownVoterConnections() PASSED

KafkaRaftMetricsTest > shouldRecordLatency() STARTED

KafkaRaftMetricsTest > shouldRecordLatency() PASSED

KafkaRaftMetricsTest > shouldRecordPollIdleRatio() STARTED

KafkaRaftMetricsTest > shouldRecordPollIdleRatio() PASSED

BlockingMessageQueueTest > testOfferAndPoll() STARTED

BlockingMessageQueueTest > testOfferAndPoll() PASSED

BlockingMessageQueueTest > testWakeupFromPoll() STARTED

BlockingMessageQueueTest > testWakeupFromPoll() PASSED

BatchMemoryPoolTest > testOversizeAllocation() STARTED

BatchMemoryPoolTest > testOversizeAllocation() PASSED

BatchMemoryPoolTest > testReleaseBufferNotMatchingBatchSize() STARTED

BatchMemoryPoolTest > testReleaseBufferNotMatchingBatchSize() PASSED

BatchMemoryPoolTest > testAllocateAndRelease() STARTED

BatchMemoryPoolTest > testAllocateAndRelease() PASSED

BatchMemoryPoolTest > testMultipleAllocations() STARTED

BatchMemoryPoolTest > testMultipleAllocations() PASSED

VotedStateTest > testElectionTimeout() STARTED

VotedStateTest > testElectionTimeout() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 9m 50s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #23

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/23/display/redirect?page=changes>

Changes:

[Jason Gustafson] MINOR: Remove redundant log close in `KafkaRaftClient` (#10168)


------------------------------------------
[...truncated 1.80 MB...]

KafkaConsumerTest > testClosingConsumerUnregistersConsumerMetrics() STARTED

KafkaConsumerTest > testClosingConsumerUnregistersConsumerMetrics() PASSED

KafkaConsumerTest > testSubscriptionOnInvalidTopic() STARTED

KafkaConsumerTest > testSubscriptionOnInvalidTopic() PASSED

KafkaConsumerTest > testAutoCommitSentBeforePositionUpdate() STARTED

KafkaConsumerTest > testAutoCommitSentBeforePositionUpdate() PASSED

KafkaConsumerTest > fetchResponseWithUnexpectedPartitionIsIgnored() STARTED

KafkaConsumerTest > fetchResponseWithUnexpectedPartitionIsIgnored() PASSED

KafkaConsumerTest > testPollThrowsInterruptExceptionIfInterrupted() STARTED

KafkaConsumerTest > testPollThrowsInterruptExceptionIfInterrupted() PASSED

KafkaConsumerTest > testSubscriptionOnNullPattern() STARTED

KafkaConsumerTest > testSubscriptionOnNullPattern() PASSED

KafkaConsumerTest > testEnforceRebalanceTriggersRebalanceOnNextPoll() STARTED

KafkaConsumerTest > testEnforceRebalanceTriggersRebalanceOnNextPoll() PASSED

KafkaConsumerTest > testEnforceRebalanceWithManualAssignment() STARTED

KafkaConsumerTest > testEnforceRebalanceWithManualAssignment() PASSED

KafkaConsumerTest > testShouldAttemptToRejoinGroupAfterSyncGroupFailed() STARTED

KafkaConsumerTest > testShouldAttemptToRejoinGroupAfterSyncGroupFailed() PASSED

KafkaConsumerTest > testCommitSyncAuthenticationFailure() STARTED

KafkaConsumerTest > testCommitSyncAuthenticationFailure() PASSED

KafkaConsumerTest > verifyHeartbeatSent() STARTED

KafkaConsumerTest > verifyHeartbeatSent() PASSED

KafkaConsumerTest > verifyHeartbeatSentWhenFetchedDataReady() STARTED

KafkaConsumerTest > verifyHeartbeatSentWhenFetchedDataReady() PASSED

KafkaConsumerTest > testResetUsingAutoResetPolicy() STARTED

KafkaConsumerTest > testResetUsingAutoResetPolicy() PASSED

KafkaConsumerTest > testNoCommittedOffsets() STARTED

KafkaConsumerTest > testNoCommittedOffsets() PASSED

KafkaConsumerTest > testOperationsByAssigningConsumerWithDefaultGroupId() STARTED

KafkaConsumerTest > testOperationsByAssigningConsumerWithDefaultGroupId() PASSED

KafkaConsumerTest > testAssignOnEmptyTopicPartition() STARTED

KafkaConsumerTest > testAssignOnEmptyTopicPartition() PASSED

KafkaConsumerTest > testFetchStableOffsetThrowInCommitted() STARTED

KafkaConsumerTest > testFetchStableOffsetThrowInCommitted() PASSED

KafkaConsumerTest > testUnsubscribeShouldTriggerPartitionsLostWithNoGeneration() STARTED

KafkaConsumerTest > testUnsubscribeShouldTriggerPartitionsLostWithNoGeneration() PASSED

KafkaConsumerTest > testUnusedConfigs() STARTED

KafkaConsumerTest > testUnusedConfigs() PASSED

KafkaConsumerTest > testSubscriptionOnNullTopic() STARTED

KafkaConsumerTest > testSubscriptionOnNullTopic() PASSED

KafkaConsumerTest > testSubscription() STARTED

KafkaConsumerTest > testSubscription() PASSED

KafkaConsumerTest > testInterceptorConstructorClose() STARTED

KafkaConsumerTest > testInterceptorConstructorClose() PASSED

KafkaConsumerTest > testSubscriptionOnEmptyTopic() STARTED

KafkaConsumerTest > testSubscriptionOnEmptyTopic() PASSED

KafkaConsumerTest > testWakeupWithFetchDataAvailable() STARTED

KafkaConsumerTest > testWakeupWithFetchDataAvailable() PASSED

KafkaConsumerTest > testReturnRecordsDuringRebalance() STARTED

KafkaConsumerTest > testReturnRecordsDuringRebalance() PASSED

KafkaConsumerTest > testLeaveGroupTimeout() STARTED

KafkaConsumerTest > testLeaveGroupTimeout() PASSED

KafkaConsumerTest > testFetchStableOffsetThrowInPoll() STARTED

KafkaConsumerTest > testFetchStableOffsetThrowInPoll() PASSED

KafkaConsumerTest > testPartitionsForAuthenticationFailure() STARTED

KafkaConsumerTest > testPartitionsForAuthenticationFailure() PASSED

KafkaConsumerTest > testSubscriptionOnNullTopicCollection() STARTED

KafkaConsumerTest > testSubscriptionOnNullTopicCollection() PASSED

KafkaConsumerTest > testCloseWithTimeUnit() STARTED

KafkaConsumerTest > testCloseWithTimeUnit() PASSED

ConsumerRecordTest > testNullChecksumInConstructor() STARTED

ConsumerRecordTest > testNullChecksumInConstructor() PASSED

ConsumerRecordTest > testOldConstructor() STARTED

ConsumerRecordTest > testOldConstructor() PASSED

ClientUtilsTest > testResolveDnsLookupResolveCanonicalBootstrapServers() STARTED

ClientUtilsTest > testResolveDnsLookupResolveCanonicalBootstrapServers() PASSED

ClientUtilsTest > testFilterPreferredAddresses() STARTED

ClientUtilsTest > testFilterPreferredAddresses() PASSED

ClientUtilsTest > testResolveUnknownHostException() STARTED

ClientUtilsTest > testResolveUnknownHostException() PASSED

ClientUtilsTest > testOnlyBadHostname() STARTED

ClientUtilsTest > testOnlyBadHostname() PASSED

ClientUtilsTest > testInvalidConfig() STARTED

ClientUtilsTest > testInvalidConfig() PASSED

ClientUtilsTest > testResolveDnsLookupAllIps() STARTED

ClientUtilsTest > testResolveDnsLookupAllIps() PASSED

ClientUtilsTest > testResolveDnsLookup() STARTED

ClientUtilsTest > testResolveDnsLookup() PASSED

ClientUtilsTest > testParseAndValidateAddresses() STARTED

ClientUtilsTest > testParseAndValidateAddresses() PASSED

ClientUtilsTest > testParseAndValidateAddressesWithReverseLookup() STARTED

ClientUtilsTest > testParseAndValidateAddressesWithReverseLookup() PASSED

ClientUtilsTest > testNoPort() STARTED

ClientUtilsTest > testNoPort() PASSED

> Task :raft:test

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeFiveAndThreeObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeThreeAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeThreeAndTwoObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderGracefulShutdownQuorumSizeThreeAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderGracefulShutdownQuorumSizeThreeAndTwoObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderFailureQuorumSizeThreeAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderFailureQuorumSizeThreeAndTwoObservers() PASSED

RaftEventSimulationTest > testBackToBackLeaderFailuresQuorumSizeFiveAndTwoObservers() STARTED

RaftEventSimulationTest > testBackToBackLeaderFailuresQuorumSizeFiveAndTwoObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeFourAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeFourAndTwoObservers() PASSED

MockExpirationServiceTest > testFailAfter() STARTED

MockExpirationServiceTest > testFailAfter() PASSED

FileRawSnapshotTest > testBatchWriteReadSnapshot() STARTED

FileRawSnapshotTest > testBatchWriteReadSnapshot() PASSED

FileRawSnapshotTest > testCreateSnapshotWithSameId() STARTED

FileRawSnapshotTest > testCreateSnapshotWithSameId() PASSED

FileRawSnapshotTest > testPartialWriteReadSnapshot() STARTED

FileRawSnapshotTest > testPartialWriteReadSnapshot() PASSED

FileRawSnapshotTest > testBufferWriteReadSnapshot() STARTED

FileRawSnapshotTest > testBufferWriteReadSnapshot() PASSED

FileRawSnapshotTest > testAbortedSnapshot() STARTED

FileRawSnapshotTest > testAbortedSnapshot() PASSED

FileRawSnapshotTest > testAppendToFrozenSnapshot() STARTED

FileRawSnapshotTest > testAppendToFrozenSnapshot() PASSED

FileRawSnapshotTest > testWritingSnapshot() STARTED

FileRawSnapshotTest > testWritingSnapshot() PASSED

FileRawSnapshotTest > testWriteReadSnapshot() STARTED

FileRawSnapshotTest > testWriteReadSnapshot() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 16m 55s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #22

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/22/display/redirect?page=changes>

Changes:

[Colin McCabe] KAFKA-12276: Add the quorum controller code (#10070)

[Colin McCabe] HOTFIX: fix cherry-pick to 2.8


------------------------------------------
[...truncated 1.80 MB...]

QuorumStateTest > testCannotFollowOrVoteForSelf() STARTED

QuorumStateTest > testCannotFollowOrVoteForSelf() PASSED

MetadataRecordSerdeTest > testDeserializeWithUnhandledFrameVersion() STARTED

MetadataRecordSerdeTest > testDeserializeWithUnhandledFrameVersion() PASSED

MetadataRecordSerdeTest > testSerde() STARTED

MetadataRecordSerdeTest > testSerde() PASSED

BatchBuilderTest > [1] NONE STARTED

BatchBuilderTest > [1] NONE PASSED

BatchBuilderTest > [2] GZIP STARTED

BatchBuilderTest > [2] GZIP PASSED

BatchBuilderTest > [3] SNAPPY STARTED

BatchBuilderTest > [3] SNAPPY PASSED

BatchBuilderTest > [4] LZ4 STARTED

BatchBuilderTest > [4] LZ4 PASSED

BatchBuilderTest > [5] ZSTD STARTED

BatchBuilderTest > [5] ZSTD PASSED

BatchBuilderTest > [1] 128 STARTED

BatchBuilderTest > [1] 128 PASSED

BatchBuilderTest > [2] 157 STARTED

BatchBuilderTest > [2] 157 PASSED

BatchBuilderTest > [3] 256 STARTED

BatchBuilderTest > [3] 256 PASSED

BatchBuilderTest > [4] 433 STARTED

BatchBuilderTest > [4] 433 PASSED

BatchBuilderTest > [5] 512 STARTED

BatchBuilderTest > [5] 512 PASSED

BatchBuilderTest > [6] 777 STARTED

BatchBuilderTest > [6] 777 PASSED

BatchBuilderTest > [7] 1024 STARTED

BatchBuilderTest > [7] 1024 PASSED

ThresholdPurgatoryTest > testExpiration() STARTED

ThresholdPurgatoryTest > testExpiration() PASSED

ThresholdPurgatoryTest > testExternalCompletion() STARTED

ThresholdPurgatoryTest > testExternalCompletion() PASSED

ThresholdPurgatoryTest > testCompleteAllExceptionally() STARTED

ThresholdPurgatoryTest > testCompleteAllExceptionally() PASSED

ThresholdPurgatoryTest > testThresholdCompletion() STARTED

ThresholdPurgatoryTest > testThresholdCompletion() PASSED

ThresholdPurgatoryTest > testCompleteAll() STARTED

ThresholdPurgatoryTest > testCompleteAll() PASSED

BatchMemoryPoolTest > testOversizeAllocation() STARTED

BatchMemoryPoolTest > testOversizeAllocation() PASSED

BatchMemoryPoolTest > testReleaseBufferNotMatchingBatchSize() STARTED

BatchMemoryPoolTest > testReleaseBufferNotMatchingBatchSize() PASSED

BatchMemoryPoolTest > testAllocateAndRelease() STARTED

BatchMemoryPoolTest > testAllocateAndRelease() PASSED

BatchMemoryPoolTest > testMultipleAllocations() STARTED

BatchMemoryPoolTest > testMultipleAllocations() PASSED

RecordsBatchReaderTest > [1] NONE STARTED

RecordsBatchReaderTest > [1] NONE PASSED

RecordsBatchReaderTest > [2] GZIP STARTED

RecordsBatchReaderTest > [2] GZIP PASSED

RecordsBatchReaderTest > [3] SNAPPY STARTED

RecordsBatchReaderTest > [3] SNAPPY PASSED

RecordsBatchReaderTest > [4] LZ4 STARTED

RecordsBatchReaderTest > [4] LZ4 PASSED

RecordsBatchReaderTest > [5] ZSTD STARTED

RecordsBatchReaderTest > [5] ZSTD PASSED

RecordsBatchReaderTest > [1] NONE STARTED

RecordsBatchReaderTest > [1] NONE PASSED

RecordsBatchReaderTest > [2] GZIP STARTED

RecordsBatchReaderTest > [2] GZIP PASSED

RecordsBatchReaderTest > [3] SNAPPY STARTED

RecordsBatchReaderTest > [3] SNAPPY PASSED

RecordsBatchReaderTest > [4] LZ4 STARTED

RecordsBatchReaderTest > [4] LZ4 PASSED

RecordsBatchReaderTest > [5] ZSTD STARTED

RecordsBatchReaderTest > [5] ZSTD PASSED

KafkaRaftClientSnapshotTest > testPartialFetchSnapshotRequestAsLeader() STARTED

KafkaRaftClientSnapshotTest > testPartialFetchSnapshotRequestAsLeader() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponsePartialData() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponsePartialData() PASSED

KafkaRaftClientSnapshotTest > testFetchRequestOffsetLessThanLogStart() STARTED

KafkaRaftClientSnapshotTest > testFetchRequestOffsetLessThanLogStart() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestWithNewerEpoch() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestWithNewerEpoch() PASSED

KafkaRaftClientSnapshotTest > testFetchRequestTruncateToLogStart() STARTED

KafkaRaftClientSnapshotTest > testFetchRequestTruncateToLogStart() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseToNotFollower() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseToNotFollower() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseFromOlderEpoch() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseFromOlderEpoch() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestUnknownPartition() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestUnknownPartition() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseFromNewerEpochNotLeader() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseFromNewerEpochNotLeader() PASSED

KafkaRaftClientSnapshotTest > testFetchRequestWithLastFetchedEpochLessThanOldestSnapshot() STARTED

KafkaRaftClientSnapshotTest > testFetchRequestWithLastFetchedEpochLessThanOldestSnapshot() PASSED

KafkaRaftClientSnapshotTest > testFetchResponseWithSnapshotId() STARTED

KafkaRaftClientSnapshotTest > testFetchResponseWithSnapshotId() PASSED

KafkaRaftClientSnapshotTest > testFetchRequestAtLogStartOffsetWithValidEpoch() STARTED

KafkaRaftClientSnapshotTest > testFetchRequestAtLogStartOffsetWithValidEpoch() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestWithOlderEpoch() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestWithOlderEpoch() PASSED

KafkaRaftClientSnapshotTest > testFetchRequestAtLogStartOffsetWithInvalidEpoch() STARTED

KafkaRaftClientSnapshotTest > testFetchRequestAtLogStartOffsetWithInvalidEpoch() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestAsFollower() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestAsFollower() PASSED

KafkaRaftClientSnapshotTest > testFetchRequestWithLargerLastFetchedEpoch() STARTED

KafkaRaftClientSnapshotTest > testFetchRequestWithLargerLastFetchedEpoch() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestAsLeader() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestAsLeader() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseFromNewerEpochLeader() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseFromNewerEpochLeader() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseMissingSnapshot() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseMissingSnapshot() PASSED

KafkaRaftClientSnapshotTest > testFetchResponseWithInvalidSnapshotId() STARTED

KafkaRaftClientSnapshotTest > testFetchResponseWithInvalidSnapshotId() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestMissingSnapshot() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestMissingSnapshot() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseWithInvalidId() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotResponseWithInvalidId() PASSED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestWithInvalidPosition() STARTED

KafkaRaftClientSnapshotTest > testFetchSnapshotRequestWithInvalidPosition() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 20m 6s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #21

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/21/display/redirect?page=changes>

Changes:

[Colin McCabe] MINOR: Fix Raft broker restart issue when offset partitions are deferred #10155

[Jason Gustafson] KAFKA-12258; Add support for splitting appending records (#10063)

[Jason Gustafson] KAFKA-12332; Error partitions from topics with invalid IDs in LISR requests (#10143)

[Matthias J. Sax] KAFKA-9274: Throw TaskCorruptedException instead of TimeoutException when TX commit times out (#10072)

[Randall Hauch] KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException (#10158)

[Jason Gustafson] KAFKA-10817; Add clusterId validation to raft Fetch handling (#10129)

[Colin McCabe] KAFKA-12334: Add the KIP-500 metadata shell


------------------------------------------
[...truncated 1.79 MB...]

CooperativeStickyAssignorTest > testNoExceptionThrownWhenOnlySubscribedTopicDeleted() STARTED

CooperativeStickyAssignorTest > testNoExceptionThrownWhenOnlySubscribedTopicDeleted() PASSED

CooperativeStickyAssignorTest > testStickiness() STARTED

CooperativeStickyAssignorTest > testStickiness() PASSED

CooperativeStickyAssignorTest > testOneConsumerNoTopic() STARTED

CooperativeStickyAssignorTest > testOneConsumerNoTopic() PASSED

CooperativeStickyAssignorTest > testAddRemoveConsumerOneTopic() STARTED

CooperativeStickyAssignorTest > testAddRemoveConsumerOneTopic() PASSED

CooperativeStickyAssignorTest > testTwoConsumersTwoTopicsSixPartitions() STARTED

CooperativeStickyAssignorTest > testTwoConsumersTwoTopicsSixPartitions() PASSED

CooperativeStickyAssignorTest > testAssignmentUpdatedForDeletedTopic() STARTED

CooperativeStickyAssignorTest > testAssignmentUpdatedForDeletedTopic() PASSED

CooperativeStickyAssignorTest > testReassignmentWithRandomSubscriptionsAndChanges() STARTED

CooperativeStickyAssignorTest > testReassignmentWithRandomSubscriptionsAndChanges() PASSED

CooperativeStickyAssignorTest > testNewSubscription() STARTED

CooperativeStickyAssignorTest > testNewSubscription() PASSED

CooperativeStickyAssignorTest > testAddRemoveTopicTwoConsumers() STARTED

CooperativeStickyAssignorTest > testAddRemoveTopicTwoConsumers() PASSED

CooperativeStickyAssignorTest > testMoveExistingAssignments() STARTED

CooperativeStickyAssignorTest > testMoveExistingAssignments() PASSED

CooperativeStickyAssignorTest > testMultipleConsumersMixedTopicSubscriptions() STARTED

CooperativeStickyAssignorTest > testMultipleConsumersMixedTopicSubscriptions() PASSED

CooperativeStickyAssignorTest > testOneConsumerOneTopic() STARTED

CooperativeStickyAssignorTest > testOneConsumerOneTopic() PASSED

CooperativeStickyAssignorTest > testPoorRoundRobinAssignmentScenario() STARTED

CooperativeStickyAssignorTest > testPoorRoundRobinAssignmentScenario() PASSED

CooperativeStickyAssignorTest > testReassignmentAfterOneConsumerLeaves() STARTED

CooperativeStickyAssignorTest > testReassignmentAfterOneConsumerLeaves() PASSED

CooperativeStickyAssignorTest > testLargeAssignmentWithMultipleConsumersLeavingAndRandomSubscription() STARTED

CooperativeStickyAssignorTest > testLargeAssignmentWithMultipleConsumersLeavingAndRandomSubscription() PASSED

CooperativeStickyAssignorTest > testSameSubscriptions() STARTED

CooperativeStickyAssignorTest > testSameSubscriptions() PASSED

CooperativeStickyAssignorTest > testReassignmentAfterOneConsumerAdded() STARTED

CooperativeStickyAssignorTest > testReassignmentAfterOneConsumerAdded() PASSED

CooperativeStickyAssignorTest > testTwoConsumersOneTopicOnePartition() STARTED

CooperativeStickyAssignorTest > testTwoConsumersOneTopicOnePartition() PASSED

CooperativeStickyAssignorTest > testLargeAssignmentAndGroupWithUniformSubscription() STARTED

CooperativeStickyAssignorTest > testLargeAssignmentAndGroupWithUniformSubscription() PASSED

CooperativeStickyAssignorTest > testOneConsumerMultipleTopics() STARTED

CooperativeStickyAssignorTest > testOneConsumerMultipleTopics() PASSED

CooperativeStickyAssignorTest > testOnlyAssignsPartitionsFromSubscribedTopics() STARTED

CooperativeStickyAssignorTest > testOnlyAssignsPartitionsFromSubscribedTopics() PASSED

CooperativeStickyAssignorTest > testTwoConsumersOneTopicTwoPartitions() STARTED

CooperativeStickyAssignorTest > testTwoConsumersOneTopicTwoPartitions() PASSED

CooperativeStickyAssignorTest > testOneConsumerNonexistentTopic() STARTED

CooperativeStickyAssignorTest > testOneConsumerNonexistentTopic() PASSED

ConsumerRecordsTest > iterator() STARTED

ConsumerRecordsTest > iterator() PASSED

MetadataCacheTest > testMissingLeaderEndpoint() STARTED

MetadataCacheTest > testMissingLeaderEndpoint() PASSED

NodeApiVersionsTest > [1] ZK_BROKER STARTED

NodeApiVersionsTest > [1] ZK_BROKER PASSED

NodeApiVersionsTest > [2] BROKER STARTED

NodeApiVersionsTest > [2] BROKER PASSED

NodeApiVersionsTest > [3] CONTROLLER STARTED

NodeApiVersionsTest > [3] CONTROLLER PASSED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeHigh() STARTED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeHigh() PASSED

NodeApiVersionsTest > testLatestUsableVersion() STARTED

NodeApiVersionsTest > testLatestUsableVersion() PASSED

NodeApiVersionsTest > testUsableVersionCalculationNoKnownVersions() STARTED

NodeApiVersionsTest > testUsableVersionCalculationNoKnownVersions() PASSED

NodeApiVersionsTest > testVersionsToString() STARTED

NodeApiVersionsTest > testVersionsToString() PASSED

NodeApiVersionsTest > testUnsupportedVersionsToString() STARTED

NodeApiVersionsTest > testUnsupportedVersionsToString() PASSED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeLow() STARTED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeLow() PASSED

NodeApiVersionsTest > testLatestUsableVersionOutOfRange() STARTED

NodeApiVersionsTest > testLatestUsableVersionOutOfRange() PASSED

NodeApiVersionsTest > testUnknownApiVersionsToString() STARTED

NodeApiVersionsTest > testUnknownApiVersionsToString() PASSED

NodeApiVersionsTest > [1] ZK_BROKER STARTED

NodeApiVersionsTest > [1] ZK_BROKER PASSED

NodeApiVersionsTest > [2] BROKER STARTED

NodeApiVersionsTest > [2] BROKER PASSED

NodeApiVersionsTest > [3] CONTROLLER STARTED

NodeApiVersionsTest > [3] CONTROLLER PASSED

> Task :raft:test

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeFiveAndThreeObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeThreeAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeThreeAndTwoObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderGracefulShutdownQuorumSizeThreeAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderGracefulShutdownQuorumSizeThreeAndTwoObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderFailureQuorumSizeThreeAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderFailureQuorumSizeThreeAndTwoObservers() PASSED

RaftEventSimulationTest > testBackToBackLeaderFailuresQuorumSizeFiveAndTwoObservers() STARTED

RaftEventSimulationTest > testBackToBackLeaderFailuresQuorumSizeFiveAndTwoObservers() PASSED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeFourAndTwoObservers() STARTED

RaftEventSimulationTest > testElectionAfterLeaderNetworkPartitionQuorumSizeFourAndTwoObservers() PASSED

VotedStateTest > testElectionTimeout() STARTED

VotedStateTest > testElectionTimeout() PASSED

CandidateStateTest > testCannotRejectVoteFromLocalId() STARTED

CandidateStateTest > testCannotRejectVoteFromLocalId() PASSED

CandidateStateTest > testSingleNodeQuorum() STARTED

CandidateStateTest > testSingleNodeQuorum() PASSED

CandidateStateTest > testThreeNodeQuorumVoteGranted() STARTED

CandidateStateTest > testThreeNodeQuorumVoteGranted() PASSED

CandidateStateTest > testTwoNodeQuorumVoteRejected() STARTED

CandidateStateTest > testTwoNodeQuorumVoteRejected() PASSED

CandidateStateTest > testTwoNodeQuorumVoteGranted() STARTED

CandidateStateTest > testTwoNodeQuorumVoteGranted() PASSED

CandidateStateTest > testCannotChangeVoteRejectedToGranted() STARTED

CandidateStateTest > testCannotChangeVoteRejectedToGranted() PASSED

CandidateStateTest > testIdempotentGrant() STARTED

CandidateStateTest > testIdempotentGrant() PASSED

CandidateStateTest > testCannotGrantOrRejectNonVoters() STARTED

CandidateStateTest > testCannotGrantOrRejectNonVoters() PASSED

CandidateStateTest > testIdempotentReject() STARTED

CandidateStateTest > testIdempotentReject() PASSED

CandidateStateTest > testThreeNodeQuorumVoteRejected() STARTED

CandidateStateTest > testThreeNodeQuorumVoteRejected() PASSED

CandidateStateTest > testCannotChangeVoteGrantedToRejected() STARTED

CandidateStateTest > testCannotChangeVoteGrantedToRejected() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 17m 37s
218 actionable tasks: 181 executed, 37 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-2.8-jdk8 #20

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/20/display/redirect?page=changes>

Changes:

[Colin McCabe] MINOR: Add KIP-500 BrokerServer and ControllerServer (#10113)

[Matthias J. Sax] TRIVIAL: fix JavaDocs formatting (#10134)

[Colin McCabe] Fixed README and added clearer error message. (#10133)

[Colin McCabe] KAFKA-12278; Ensure exposed api versions are consistent within listener (#10666)

[Jason Gustafson] KAFKA-12331: Use LEO for the base offset of LeaderChangeMessage batch (#10138)

[Matthias J. Sax] KAFKA-9524: increase retention time for window and grace periods longer than one day (#10091)

[github] MINOR: Added missing import (KafkaVersion) to kafka.py (#10154)


------------------------------------------
[...truncated 1.79 MB...]

KafkaAdminClientTest > testUpdateFeaturesTopLevelError() STARTED

KafkaAdminClientTest > testUpdateFeaturesTopLevelError() PASSED

KafkaAdminClientTest > testUnregisterBrokerTimeoutMaxRetry() STARTED

KafkaAdminClientTest > testUnregisterBrokerTimeoutMaxRetry() PASSED

KafkaAdminClientTest > testSuccessfulRetryAfterRequestTimeout() STARTED

KafkaAdminClientTest > testSuccessfulRetryAfterRequestTimeout() PASSED

KafkaAdminClientTest > testUpdateFeaturesHandleNotControllerException() STARTED

KafkaAdminClientTest > testUpdateFeaturesHandleNotControllerException() PASSED

KafkaAdminClientTest > testOffsetCommitRetryBackoff() STARTED

KafkaAdminClientTest > testOffsetCommitRetryBackoff() PASSED

KafkaAdminClientTest > testDeleteTopicsRetryThrottlingExceptionWhenEnabledUntilRequestTimeOut() STARTED

KafkaAdminClientTest > testDeleteTopicsRetryThrottlingExceptionWhenEnabledUntilRequestTimeOut() PASSED

KafkaAdminClientTest > testDeleteTopicsPartialResponse() STARTED

KafkaAdminClientTest > testDeleteTopicsPartialResponse() PASSED

KafkaAdminClientTest > testRemoveMembersFromGroup() STARTED

KafkaAdminClientTest > testRemoveMembersFromGroup() PASSED

KafkaAdminClientTest > testListOffsetsPartialResponse() STARTED

KafkaAdminClientTest > testListOffsetsPartialResponse() PASSED

KafkaAdminClientTest > testCalcTimeoutMsRemainingAsInt() STARTED

KafkaAdminClientTest > testCalcTimeoutMsRemainingAsInt() PASSED

KafkaAdminClientTest > testUnreachableBootstrapServer() STARTED

KafkaAdminClientTest > testUnreachableBootstrapServer() PASSED

KafkaAdminClientTest > testDeleteConsumerGroupOffsetsNonRetriableErrors() STARTED

KafkaAdminClientTest > testDeleteConsumerGroupOffsetsNonRetriableErrors() PASSED

RemoveMembersFromConsumerGroupResultTest > testMemberLevelErrorInResponseConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testMemberLevelErrorInResponseConstructor() PASSED

RemoveMembersFromConsumerGroupResultTest > testTopLevelErrorConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testTopLevelErrorConstructor() PASSED

RemoveMembersFromConsumerGroupResultTest > testMemberMissingErrorInRequestConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testMemberMissingErrorInRequestConstructor() PASSED

RemoveMembersFromConsumerGroupResultTest > testMemberLevelErrorConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testMemberLevelErrorConstructor() PASSED

RemoveMembersFromConsumerGroupResultTest > testNoErrorConstructor() STARTED

RemoveMembersFromConsumerGroupResultTest > testNoErrorConstructor() PASSED

AdminMetadataManagerTest > testAuthenticationFailure() STARTED

AdminMetadataManagerTest > testAuthenticationFailure() PASSED

AdminMetadataManagerTest > testMetadataReady() STARTED

AdminMetadataManagerTest > testMetadataReady() PASSED

AdminMetadataManagerTest > testMetadataRefreshBackoff() STARTED

AdminMetadataManagerTest > testMetadataRefreshBackoff() PASSED

CommonClientConfigsTest > testExponentialBackoffDefaults() STARTED

CommonClientConfigsTest > testExponentialBackoffDefaults() PASSED

NodeApiVersionsTest > [1] ZK_BROKER STARTED

NodeApiVersionsTest > [1] ZK_BROKER PASSED

NodeApiVersionsTest > [2] BROKER STARTED

NodeApiVersionsTest > [2] BROKER PASSED

NodeApiVersionsTest > [3] CONTROLLER STARTED

NodeApiVersionsTest > [3] CONTROLLER PASSED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeHigh() STARTED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeHigh() PASSED

NodeApiVersionsTest > testLatestUsableVersion() STARTED

NodeApiVersionsTest > testLatestUsableVersion() PASSED

NodeApiVersionsTest > testUsableVersionCalculationNoKnownVersions() STARTED

NodeApiVersionsTest > testUsableVersionCalculationNoKnownVersions() PASSED

NodeApiVersionsTest > testVersionsToString() STARTED

NodeApiVersionsTest > testVersionsToString() PASSED

NodeApiVersionsTest > testUnsupportedVersionsToString() STARTED

NodeApiVersionsTest > testUnsupportedVersionsToString() PASSED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeLow() STARTED

NodeApiVersionsTest > testLatestUsableVersionOutOfRangeLow() PASSED

NodeApiVersionsTest > testLatestUsableVersionOutOfRange() STARTED

NodeApiVersionsTest > testLatestUsableVersionOutOfRange() PASSED

NodeApiVersionsTest > testUnknownApiVersionsToString() STARTED

NodeApiVersionsTest > testUnknownApiVersionsToString() PASSED

NodeApiVersionsTest > [1] ZK_BROKER STARTED

NodeApiVersionsTest > [1] ZK_BROKER PASSED

NodeApiVersionsTest > [2] BROKER STARTED

NodeApiVersionsTest > [2] BROKER PASSED

NodeApiVersionsTest > [3] CONTROLLER STARTED

NodeApiVersionsTest > [3] CONTROLLER PASSED

ClusterConnectionStatesTest > testIsPreparingConnection() STARTED

ClusterConnectionStatesTest > testIsPreparingConnection() PASSED

ClusterConnectionStatesTest > testNodeWithNewHostname() STARTED

ClusterConnectionStatesTest > testNodeWithNewHostname() PASSED

ClusterConnectionStatesTest > testHostResolveChange() STARTED

ClusterConnectionStatesTest > testHostResolveChange() PASSED

ClusterConnectionStatesTest > testAuthorizationFailed() STARTED

ClusterConnectionStatesTest > testAuthorizationFailed() PASSED

ClusterConnectionStatesTest > testMultipleIPsWithDefault() STARTED

ClusterConnectionStatesTest > testMultipleIPsWithDefault() PASSED

ClusterConnectionStatesTest > testTimedOutConnections() STARTED

ClusterConnectionStatesTest > testTimedOutConnections() PASSED

ClusterConnectionStatesTest > testThrottled() STARTED

ClusterConnectionStatesTest > testThrottled() PASSED

ClusterConnectionStatesTest > testExponentialReconnectBackoff() STARTED

ClusterConnectionStatesTest > testExponentialReconnectBackoff() PASSED

ClusterConnectionStatesTest > testRemoveNode() STARTED

ClusterConnectionStatesTest > testRemoveNode() PASSED

ClusterConnectionStatesTest > testExponentialConnectionSetupTimeout() STARTED

ClusterConnectionStatesTest > testExponentialConnectionSetupTimeout() PASSED

ClusterConnectionStatesTest > testSingleIPWithUseAll() STARTED

ClusterConnectionStatesTest > testSingleIPWithUseAll() PASSED

ClusterConnectionStatesTest > testMultipleIPsWithUseAll() STARTED

ClusterConnectionStatesTest > testMultipleIPsWithUseAll() PASSED

ClusterConnectionStatesTest > testMultipleNodeConnectionStates() STARTED

ClusterConnectionStatesTest > testMultipleNodeConnectionStates() PASSED

ClusterConnectionStatesTest > testClusterConnectionStateChanges() STARTED

ClusterConnectionStatesTest > testClusterConnectionStateChanges() PASSED

ClusterConnectionStatesTest > testMaxReconnectBackoff() STARTED

ClusterConnectionStatesTest > testMaxReconnectBackoff() PASSED

ClusterConnectionStatesTest > testSingleIPWithDefault() STARTED

ClusterConnectionStatesTest > testSingleIPWithDefault() PASSED

FetchSessionHandlerTest > testSessionless() STARTED

FetchSessionHandlerTest > testSessionless() PASSED

FetchSessionHandlerTest > testVerifyFullFetchResponsePartitions() STARTED

FetchSessionHandlerTest > testVerifyFullFetchResponsePartitions() PASSED

FetchSessionHandlerTest > testIncrementals() STARTED

FetchSessionHandlerTest > testIncrementals() PASSED

FetchSessionHandlerTest > testIncrementalPartitionRemoval() STARTED

FetchSessionHandlerTest > testIncrementalPartitionRemoval() PASSED

FetchSessionHandlerTest > testFindMissing() STARTED

FetchSessionHandlerTest > testFindMissing() PASSED

FetchSessionHandlerTest > testDoubleBuild() STARTED

FetchSessionHandlerTest > testDoubleBuild() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:compileTestScala'.
> Compilation failed

* 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 11m 37s
211 actionable tasks: 175 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-2.8-jdk8 #19

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/19/display/redirect?page=changes>

Changes:

[github] MINOR: Add note about topic IDs to upgrade doc (#10125)


------------------------------------------
[...truncated 6.93 MB...]

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

KafkaTimerTest > testKafkaTimer() STARTED

KafkaTimerTest > testKafkaTimer() PASSED

LinuxIoMetricsCollectorTest > testReadProcFile() STARTED

LinuxIoMetricsCollectorTest > testReadProcFile() PASSED

LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() STARTED

LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() PASSED

TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED

TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() 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@16a253b, value = [B@294f3ed0), 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@16a253b, value = [B@294f3ed0), 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@5a9f85dc, value = [B@a7699e1), 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@5a9f85dc, value = [B@a7699e1), 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@47946215, value = [B@2c21565e), 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@47946215, value = [B@2c21565e), 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@ab68763, value = [B@3431ae45), 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@ab68763, value = [B@3431ae45), 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@5051e61c, value = [B@76e4c9ee), 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@5051e61c, value = [B@76e4c9ee), 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@48d7c5ce, value = [B@712d0917), 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@48d7c5ce, value = [B@712d0917), 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@2e137028, value = [B@7e6877bd), 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@2e137028, value = [B@7e6877bd), 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@867340b, value = [B@119bf1a1), 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@867340b, value = [B@119bf1a1), 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@243c518a, value = [B@19d41f2f), 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@243c518a, value = [B@19d41f2f), 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@200cf07a, value = [B@1998ae33), 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@200cf07a, value = [B@1998ae33), 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@243c9355, value = [B@109b2951), properties=HashMap(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@243c9355, value = [B@109b2951), properties=HashMap(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@57d38418, value = [B@be641e7), properties=HashMap(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@57d38418, value = [B@be641e7), properties=HashMap(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@4b00ddf5, value = [B@218a465), 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@4b00ddf5, value = [B@218a465), 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@49a0037a, value = [B@70708ad0), 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@49a0037a, value = [B@70708ad0), 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@3dd20e5e, value = [B@7aaeae0d), 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@3dd20e5e, value = [B@7aaeae0d), 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@33dcd9f1, value = [B@478ef350), 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@33dcd9f1, value = [B@478ef350), 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@3094ee80, value = [B@b08fb1), 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@3094ee80, value = [B@b08fb1), 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@77ec090b, 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@77ec090b, 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@74a319c, 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@74a319c, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey	NULL
 PASSED

AuthorizerIntegrationTest > shouldSuccessfullyAbortTransactionAfterTopicAuthorizationException() SKIPPED

> Task :core:test FAILED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:test'.
> Process 'Gradle Test Executor 69' 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 10m 39s
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-2.8-jdk8 #18

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/18/display/redirect?page=changes>

Changes:

[Matthias J. Sax] KAFKA-12272: Fix commit-interval metrics (#10102)

[Matthias J. Sax] MINOR: Clarify config names for EOS versions 1 and 2 (#9670)


------------------------------------------
[...truncated 3.41 MB...]

ZkAuthorizationTest > testChroot() PASSED

ZkAuthorizationTest > testDelete() STARTED

ZkAuthorizationTest > testDelete() PASSED

ZkAuthorizationTest > testDeleteRecursive() STARTED

ZkAuthorizationTest > testDeleteRecursive() PASSED

ResourceTypeTest > testJavaConversions() STARTED

ResourceTypeTest > testJavaConversions() PASSED

ResourceTypeTest > testFromString() STARTED

ResourceTypeTest > testFromString() PASSED

OperationTest > testJavaConversions() STARTED

OperationTest > testJavaConversions() PASSED

SimpleAclAuthorizerTest > testAuthorizeWithPrefixedResource() STARTED

SimpleAclAuthorizerTest > testAuthorizeWithPrefixedResource() PASSED

SimpleAclAuthorizerTest > testAllowAllAccess() STARTED

SimpleAclAuthorizerTest > testAllowAllAccess() PASSED

SimpleAclAuthorizerTest > testLocalConcurrentModificationOfResourceAcls() STARTED

SimpleAclAuthorizerTest > testLocalConcurrentModificationOfResourceAcls() PASSED

SimpleAclAuthorizerTest > testDeleteAllAclOnWildcardResource() STARTED

SimpleAclAuthorizerTest > testDeleteAllAclOnWildcardResource() PASSED

SimpleAclAuthorizerTest > testHighConcurrencyDeletionOfResourceAcls() STARTED

SimpleAclAuthorizerTest > testHighConcurrencyDeletionOfResourceAcls() PASSED

SimpleAclAuthorizerTest > testNoAclFound() STARTED

SimpleAclAuthorizerTest > testNoAclFound() PASSED

SimpleAclAuthorizerTest > testAclInheritance() STARTED

SimpleAclAuthorizerTest > testAclInheritance() PASSED

SimpleAclAuthorizerTest > testDistributedConcurrentModificationOfResourceAcls() STARTED

SimpleAclAuthorizerTest > testDistributedConcurrentModificationOfResourceAcls() PASSED

SimpleAclAuthorizerTest > testAddAclsOnWildcardResource() STARTED

SimpleAclAuthorizerTest > testAddAclsOnWildcardResource() PASSED

SimpleAclAuthorizerTest > testWritesExtendedAclChangeEventWhenInterBrokerProtocolAtLeastKafkaV2() STARTED

SimpleAclAuthorizerTest > testWritesExtendedAclChangeEventWhenInterBrokerProtocolAtLeastKafkaV2() PASSED

SimpleAclAuthorizerTest > testAclManagementAPIs() STARTED

SimpleAclAuthorizerTest > testAclManagementAPIs() PASSED

SimpleAclAuthorizerTest > testWildCardAcls() STARTED

SimpleAclAuthorizerTest > testWildCardAcls() PASSED

SimpleAclAuthorizerTest > testWritesLiteralAclChangeEventWhenInterBrokerProtocolIsKafkaV2() STARTED

SimpleAclAuthorizerTest > testWritesLiteralAclChangeEventWhenInterBrokerProtocolIsKafkaV2() PASSED

SimpleAclAuthorizerTest > testTopicAcl() STARTED

SimpleAclAuthorizerTest > testTopicAcl() PASSED

SimpleAclAuthorizerTest > testSuperUserHasAccess() STARTED

SimpleAclAuthorizerTest > testSuperUserHasAccess() PASSED

SimpleAclAuthorizerTest > testDeleteAclOnPrefixedResource() STARTED

SimpleAclAuthorizerTest > testDeleteAclOnPrefixedResource() PASSED

SimpleAclAuthorizerTest > testDenyTakesPrecedence() STARTED

SimpleAclAuthorizerTest > testDenyTakesPrecedence() PASSED

SimpleAclAuthorizerTest > testSingleCharacterResourceAcls() STARTED

SimpleAclAuthorizerTest > testSingleCharacterResourceAcls() PASSED

SimpleAclAuthorizerTest > testNoAclFoundOverride() STARTED

SimpleAclAuthorizerTest > testNoAclFoundOverride() PASSED

SimpleAclAuthorizerTest > testEmptyAclThrowsException() STARTED

SimpleAclAuthorizerTest > testEmptyAclThrowsException() PASSED

SimpleAclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() STARTED

SimpleAclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() PASSED

SimpleAclAuthorizerTest > testAllowAccessWithCustomPrincipal() STARTED

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

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllHostAce() STARTED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllHostAce() PASSED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() STARTED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() STARTED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() PASSED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllOperationAce() STARTED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED

AuthorizerInterfaceDefaultTest > testAuthorzeByResourceTypeSuperUserHasAccess() STARTED

AuthorizerInterfaceDefaultTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() STARTED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() PASSED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeMultipleAddAndRemove() STARTED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeMultipleAddAndRemove() PASSED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeDenyTakesPrecedence() STARTED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllPrincipalAce() STARTED

AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllPrincipalAce() PASSED

AclAuthorizerWithZkSaslTest > testAclUpdateWithSessionExpiration() STARTED

AclAuthorizerWithZkSaslTest > testAclUpdateWithSessionExpiration() PASSED

AclAuthorizerWithZkSaslTest > testAclUpdateWithAuthFailure() STARTED

AclAuthorizerWithZkSaslTest > testAclUpdateWithAuthFailure() 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 ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-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.
==============================================================================

2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':core:test'.
> Process 'Gradle Test Executor 69' 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 20m 5s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #17

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/17/display/redirect?page=changes>

Changes:

[Rajini Sivaram] MINOR: Remove unused LeaderAndIsrResponse.partitions() since it has been replaced with partitionErrors() (#10127)


------------------------------------------
[...truncated 7.05 MB...]

PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElection() STARTED

PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElection() PASSED

PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithEmptyIsr() STARTED

PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithEmptyIsr() PASSED

PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionAllIsrSimultaneouslyShutdown() STARTED

PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionAllIsrSimultaneouslyShutdown() PASSED

PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionEnabled() STARTED

PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionEnabled() PASSED

PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrNotLive() STARTED

PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrNotLive() PASSED

PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionDisabled() STARTED

PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionDisabled() PASSED

TopicDeletionManagerTest > testBrokerFailureAfterDeletionStarted() STARTED

TopicDeletionManagerTest > testBrokerFailureAfterDeletionStarted() PASSED

TopicDeletionManagerTest > testInitialization() STARTED

TopicDeletionManagerTest > testInitialization() PASSED

TopicDeletionManagerTest > testBasicDeletion() STARTED

TopicDeletionManagerTest > testBasicDeletion() PASSED

TopicDeletionManagerTest > testDeletionWithBrokerOffline() STARTED

TopicDeletionManagerTest > testDeletionWithBrokerOffline() PASSED

ControllerFailoverTest > testHandleIllegalStateException() STARTED

ControllerFailoverTest > testHandleIllegalStateException() PASSED

ZkNodeChangeNotificationListenerTest > testProcessNotification() STARTED

ZkNodeChangeNotificationListenerTest > testProcessNotification() PASSED

ZkNodeChangeNotificationListenerTest > testSwallowsProcessorException() STARTED

ZkNodeChangeNotificationListenerTest > testSwallowsProcessorException() PASSED

InterBrokerSendThreadTest > shouldCreateClientRequestAndSendWhenNodeIsReady() STARTED

InterBrokerSendThreadTest > shouldCreateClientRequestAndSendWhenNodeIsReady() PASSED

InterBrokerSendThreadTest > testFailingExpiredRequests() STARTED

InterBrokerSendThreadTest > testFailingExpiredRequests() PASSED

InterBrokerSendThreadTest > shouldCallCompletionHandlerWithDisconnectedResponseWhenNodeNotReady() STARTED

InterBrokerSendThreadTest > shouldCallCompletionHandlerWithDisconnectedResponseWhenNodeNotReady() PASSED

InterBrokerSendThreadTest > shouldNotSendAnythingWhenNoRequests() STARTED

InterBrokerSendThreadTest > shouldNotSendAnythingWhenNoRequests() 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

RaftManagerTest > testShutdownIoThread() STARTED

RaftManagerTest > testShutdownIoThread() PASSED

RaftManagerTest > testUncaughtExceptionInIoThread() STARTED

RaftManagerTest > testUncaughtExceptionInIoThread() 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@47b0684c, value = [B@747db78), 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@47b0684c, value = [B@747db78), 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@29cbb0b9, value = [B@106e22e3), 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@29cbb0b9, value = [B@106e22e3), 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@4f8f8ff4, value = [B@48cf1610), 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@4f8f8ff4, value = [B@48cf1610), 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@3c7539c8, value = [B@5ded7d9f), 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@3c7539c8, value = [B@5ded7d9f), 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@6e2eb9f9, value = [B@5ee14dba), 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@6e2eb9f9, value = [B@5ee14dba), 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@4bcf84d7, value = [B@7d7819b4), 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@4bcf84d7, value = [B@7d7819b4), 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@66028693, value = [B@32da8b74), 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@66028693, value = [B@32da8b74), 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@58448c4, value = [B@388c4479), 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@58448c4, value = [B@388c4479), 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@4a487be5, value = [B@2cafd8f3), 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@4a487be5, value = [B@2cafd8f3), 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@58a18bc7, value = [B@a9bb860), 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@58a18bc7, value = [B@a9bb860), 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@52377ade, value = [B@7989102b), properties=HashMap(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@52377ade, value = [B@7989102b), properties=HashMap(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@2da2436e, value = [B@7aada602), properties=HashMap(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@2da2436e, value = [B@7aada602), properties=HashMap(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@1325c203, value = [B@229c8004), 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@1325c203, value = [B@229c8004), 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@a90261d, value = [B@3798d896), 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@a90261d, value = [B@3798d896), 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@7142f2c1, value = [B@3ce548ad), 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@7142f2c1, value = [B@3ce548ad), 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@374e31e2, value = [B@466313f5), 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@374e31e2, value = [B@466313f5), 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@7060578a, value = [B@2e421ec8), 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@7060578a, value = [B@2e421ec8), 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@7924737, 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@7924737, 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@c72a5c9, 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@c72a5c9, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey	NULL
 PASSED

TransactionsTest > testFailureToFenceEpoch() SKIPPED

> Task :core:test FAILED

FAILURE: Build completed with 2 failures.

1: 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-2.8-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.
==============================================================================

2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':core:test'.
> Process 'Gradle Test Executor 69' 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 20m 0s
250 actionable tasks: 243 executed, 7 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results