You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2021/02/17 06:00:44 UTC
Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #522
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/522/display/redirect?page=changes>
Changes:
[github] MINOR: use 'mapKey' to avoid unnecessary grouped data (#10082)
[github] MINOR: Fix typo (thread -> threads) in MirrorMaker (#10130)
------------------------------------------
[...truncated 3.61 MB...]
ControllerEventManagerTest > testMetricsCleanedOnClose() PASSED
ControllerChannelManagerTest > testStopReplicaRequestWithAlreadyDefinedDeletedPartition() STARTED
ControllerChannelManagerTest > testStopReplicaRequestWithAlreadyDefinedDeletedPartition() PASSED
ControllerChannelManagerTest > testUpdateMetadataInterBrokerProtocolVersion() STARTED
ControllerChannelManagerTest > testUpdateMetadataInterBrokerProtocolVersion() PASSED
ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() STARTED
ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() PASSED
ControllerChannelManagerTest > testStopReplicaRequestsWhileTopicQueuedForDeletion() STARTED
ControllerChannelManagerTest > testStopReplicaRequestsWhileTopicQueuedForDeletion() PASSED
ControllerChannelManagerTest > testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() STARTED
ControllerChannelManagerTest > testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() PASSED
ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() STARTED
ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() PASSED
ControllerChannelManagerTest > testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() STARTED
ControllerChannelManagerTest > testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() PASSED
ControllerChannelManagerTest > testStopReplicaGroupsByBroker() STARTED
ControllerChannelManagerTest > testStopReplicaGroupsByBroker() PASSED
ControllerChannelManagerTest > testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() STARTED
ControllerChannelManagerTest > testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() PASSED
ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() STARTED
ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() PASSED
ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() STARTED
ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() PASSED
ControllerChannelManagerTest > testUpdateMetadataRequestSent() STARTED
ControllerChannelManagerTest > testUpdateMetadataRequestSent() PASSED
ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() STARTED
ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() PASSED
ControllerChannelManagerTest > testUpdateMetadataIncludesLiveOrShuttingDownBrokers() STARTED
ControllerChannelManagerTest > testUpdateMetadataIncludesLiveOrShuttingDownBrokers() PASSED
ControllerChannelManagerTest > testStopReplicaRequestSent() STARTED
ControllerChannelManagerTest > testStopReplicaRequestSent() PASSED
ControllerChannelManagerTest > testStopReplicaRequestsWhileTopicDeletionStarted() STARTED
ControllerChannelManagerTest > testStopReplicaRequestsWhileTopicDeletionStarted() PASSED
ControllerChannelManagerTest > testLeaderAndIsrRequestSent() STARTED
ControllerChannelManagerTest > testLeaderAndIsrRequestSent() PASSED
ControllerChannelManagerTest > testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() STARTED
ControllerChannelManagerTest > testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() PASSED
FeatureZNodeTest > testDecodeFailOnInvalidFeatures() STARTED
FeatureZNodeTest > testDecodeFailOnInvalidFeatures() PASSED
FeatureZNodeTest > testEncodeDecode() STARTED
FeatureZNodeTest > testEncodeDecode() PASSED
FeatureZNodeTest > testDecodeSuccess() STARTED
FeatureZNodeTest > testDecodeSuccess() PASSED
FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() STARTED
FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() PASSED
ExtendedAclStoreTest > shouldHaveCorrectPaths() STARTED
ExtendedAclStoreTest > shouldHaveCorrectPaths() PASSED
ExtendedAclStoreTest > shouldRoundTripChangeNode() STARTED
ExtendedAclStoreTest > shouldRoundTripChangeNode() PASSED
ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() STARTED
ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() PASSED
ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() STARTED
ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() PASSED
ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() STARTED
ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() PASSED
ExtendedAclStoreTest > shouldHaveCorrectPatternType() STARTED
ExtendedAclStoreTest > shouldHaveCorrectPatternType() 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@35e63e7b, value = [B@4c084416), 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@35e63e7b, value = [B@4c084416), 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@3e20f4bb, value = [B@74c48ccc), 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@3e20f4bb, value = [B@74c48ccc), 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@35422359, value = [B@4cddc5f8), 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@35422359, value = [B@4cddc5f8), 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@756175f4, value = [B@25932578), 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@756175f4, value = [B@25932578), 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@1ef8278, value = [B@233f65b8), 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@1ef8278, value = [B@233f65b8), 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@5d0f6afe, value = [B@618b3cc2), 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@5d0f6afe, value = [B@618b3cc2), 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@1c8a8ec9, value = [B@44c02a45), 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@1c8a8ec9, value = [B@44c02a45), 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@62bef0b9, value = [B@5aebad00), 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@62bef0b9, value = [B@5aebad00), 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@12df8c52, value = [B@57881e4e), 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@12df8c52, value = [B@57881e4e), 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@4e71f629, value = [B@1a09ca29), 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@4e71f629, value = [B@1a09ca29), 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@3d1e9925, value = [B@6511d864), 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@3d1e9925, value = [B@6511d864), 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@2490aa51, value = [B@701c7468), 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@2490aa51, value = [B@701c7468), 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@39820cff, value = [B@52bb3153), 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@39820cff, value = [B@52bb3153), 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@49384355, value = [B@4282d288), 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@49384355, value = [B@4282d288), 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@77b4aacc, value = [B@35f07ca4), 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@77b4aacc, value = [B@35f07ca4), 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@3e59a3a4, value = [B@6a9b2075), 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@3e59a3a4, value = [B@6a9b2075), 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@2e761c86, value = [B@62ecfc36), 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@2e761c86, value = [B@62ecfc36), 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@633be315, 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@633be315, 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@9d6f209, 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@9d6f209, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
PASSED
3401 tests completed, 1 failed, 7 skipped
> Task :core:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':core:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/ws/core/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 28m 0s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #531
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/531/display/redirect?page=changes>
Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #530
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/530/display/redirect?page=changes>
Changes:
[github] MINOR: fix some ducktape test issues (#10181)
------------------------------------------
[...truncated 3.66 MB...]
KafkaZkClientTest > testSetGetAndDeletePartitionReassignment() STARTED
KafkaZkClientTest > testSetGetAndDeletePartitionReassignment() PASSED
KafkaZkClientTest > testIsrChangeNotificationsDeletion() STARTED
KafkaZkClientTest > testIsrChangeNotificationsDeletion() PASSED
KafkaZkClientTest > testGetDataAndVersion() STARTED
KafkaZkClientTest > testGetDataAndVersion() PASSED
KafkaZkClientTest > testGetChildren() STARTED
KafkaZkClientTest > testGetChildren() PASSED
KafkaZkClientTest > testSetAndGetConsumerOffset() STARTED
KafkaZkClientTest > testSetAndGetConsumerOffset() PASSED
KafkaZkClientTest > testClusterIdMethods() STARTED
KafkaZkClientTest > testClusterIdMethods() PASSED
KafkaZkClientTest > testEntityConfigManagementMethods() STARTED
KafkaZkClientTest > testEntityConfigManagementMethods() PASSED
KafkaZkClientTest > testUpdateLeaderAndIsr() STARTED
KafkaZkClientTest > testUpdateLeaderAndIsr() PASSED
KafkaZkClientTest > testUpdateBrokerInfo() STARTED
KafkaZkClientTest > testUpdateBrokerInfo() PASSED
KafkaZkClientTest > testCreateRecursive() STARTED
KafkaZkClientTest > testCreateRecursive() PASSED
KafkaZkClientTest > testGetConsumerOffsetNoData() STARTED
KafkaZkClientTest > testGetConsumerOffsetNoData() PASSED
KafkaZkClientTest > testDeleteTopicPathMethods() STARTED
KafkaZkClientTest > testDeleteTopicPathMethods() PASSED
KafkaZkClientTest > testSetTopicPartitionStatesRaw() STARTED
KafkaZkClientTest > testSetTopicPartitionStatesRaw() PASSED
KafkaZkClientTest > testAclManagementMethods() STARTED
KafkaZkClientTest > testAclManagementMethods() PASSED
KafkaZkClientTest > testPreferredReplicaElectionMethods() STARTED
KafkaZkClientTest > testPreferredReplicaElectionMethods() PASSED
KafkaZkClientTest > testPropagateLogDir() STARTED
KafkaZkClientTest > testPropagateLogDir() PASSED
KafkaZkClientTest > testGetDataAndStat() STARTED
KafkaZkClientTest > testGetDataAndStat() PASSED
KafkaZkClientTest > testReassignPartitionsInProgress() STARTED
KafkaZkClientTest > testReassignPartitionsInProgress() PASSED
KafkaZkClientTest > testCreateTopLevelPaths() STARTED
KafkaZkClientTest > testCreateTopLevelPaths() PASSED
KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() STARTED
KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() PASSED
KafkaZkClientTest > testIsrChangeNotificationGetters() STARTED
KafkaZkClientTest > testIsrChangeNotificationGetters() PASSED
KafkaZkClientTest > testLogDirEventNotificationsDeletion() STARTED
KafkaZkClientTest > testLogDirEventNotificationsDeletion() PASSED
KafkaZkClientTest > testGetLogConfigs() STARTED
KafkaZkClientTest > testGetLogConfigs() PASSED
KafkaZkClientTest > testBrokerSequenceIdMethods() STARTED
KafkaZkClientTest > testBrokerSequenceIdMethods() PASSED
KafkaZkClientTest > testAclMethods() STARTED
KafkaZkClientTest > testAclMethods() PASSED
KafkaZkClientTest > testCreateSequentialPersistentPath() STARTED
KafkaZkClientTest > testCreateSequentialPersistentPath() PASSED
KafkaZkClientTest > testConditionalUpdatePath() STARTED
KafkaZkClientTest > testConditionalUpdatePath() PASSED
KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() STARTED
KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() PASSED
KafkaZkClientTest > testDeleteTopicZNode() STARTED
KafkaZkClientTest > testDeleteTopicZNode() PASSED
KafkaZkClientTest > testDeletePath() STARTED
KafkaZkClientTest > testDeletePath() PASSED
KafkaZkClientTest > testGetBrokerMethods() STARTED
KafkaZkClientTest > testGetBrokerMethods() PASSED
KafkaZkClientTest > testCreateTokenChangeNotification() STARTED
KafkaZkClientTest > testCreateTokenChangeNotification() PASSED
KafkaZkClientTest > testGetTopicsAndPartitions() STARTED
KafkaZkClientTest > testGetTopicsAndPartitions() PASSED
KafkaZkClientTest > testRegisterBrokerInfo() STARTED
KafkaZkClientTest > testRegisterBrokerInfo() PASSED
KafkaZkClientTest > testRetryRegisterBrokerInfo() STARTED
KafkaZkClientTest > testRetryRegisterBrokerInfo() PASSED
KafkaZkClientTest > testConsumerOffsetPath() STARTED
KafkaZkClientTest > testConsumerOffsetPath() PASSED
KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() STARTED
KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() PASSED
KafkaZkClientTest > testTopicAssignments() STARTED
KafkaZkClientTest > testTopicAssignments() PASSED
KafkaZkClientTest > testControllerManagementMethods() STARTED
KafkaZkClientTest > testControllerManagementMethods() PASSED
KafkaZkClientTest > testTopicAssignmentMethods() STARTED
KafkaZkClientTest > testTopicAssignmentMethods() PASSED
KafkaZkClientTest > testConnectionViaNettyClient() STARTED
KafkaZkClientTest > testConnectionViaNettyClient() PASSED
KafkaZkClientTest > testPropagateIsrChanges() STARTED
KafkaZkClientTest > testPropagateIsrChanges() PASSED
KafkaZkClientTest > testControllerEpochMethods() STARTED
KafkaZkClientTest > testControllerEpochMethods() PASSED
KafkaZkClientTest > testDeleteRecursive() STARTED
KafkaZkClientTest > testDeleteRecursive() PASSED
KafkaZkClientTest > testGetTopicPartitionStates() STARTED
KafkaZkClientTest > testGetTopicPartitionStates() PASSED
KafkaZkClientTest > testCreateConfigChangeNotification() STARTED
KafkaZkClientTest > testCreateConfigChangeNotification() PASSED
KafkaZkClientTest > testDelegationTokenMethods() STARTED
KafkaZkClientTest > testDelegationTokenMethods() PASSED
LiteralAclStoreTest > shouldHaveCorrectPaths() STARTED
LiteralAclStoreTest > shouldHaveCorrectPaths() PASSED
LiteralAclStoreTest > shouldRoundTripChangeNode() STARTED
LiteralAclStoreTest > shouldRoundTripChangeNode() PASSED
LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() STARTED
LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() PASSED
LiteralAclStoreTest > shouldWriteChangesToTheWritePath() STARTED
LiteralAclStoreTest > shouldWriteChangesToTheWritePath() PASSED
LiteralAclStoreTest > shouldHaveCorrectPatternType() STARTED
LiteralAclStoreTest > shouldHaveCorrectPatternType() PASSED
LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() STARTED
LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() PASSED
ReassignPartitionsZNodeTest > testDecodeInvalidJson() STARTED
ReassignPartitionsZNodeTest > testDecodeInvalidJson() PASSED
ReassignPartitionsZNodeTest > testEncode() STARTED
ReassignPartitionsZNodeTest > testEncode() PASSED
ReassignPartitionsZNodeTest > testDecodeValidJson() STARTED
ReassignPartitionsZNodeTest > testDecodeValidJson() PASSED
ControllerApisTest > testBrokerRegistration() STARTED
ControllerApisTest > testBrokerRegistration() PASSED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/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 41m 44s
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-trunk-jdk11 #529
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/529/display/redirect?page=changes>
Changes:
[github] MINOR: Test the new KIP-500 quorum mode in ducktape (#10105)
------------------------------------------
[...truncated 3.67 MB...]
KafkaZkClientTest > testSetAndGetConsumerOffset() STARTED
KafkaZkClientTest > testSetAndGetConsumerOffset() PASSED
KafkaZkClientTest > testClusterIdMethods() STARTED
KafkaZkClientTest > testClusterIdMethods() PASSED
KafkaZkClientTest > testEntityConfigManagementMethods() STARTED
KafkaZkClientTest > testEntityConfigManagementMethods() PASSED
KafkaZkClientTest > testUpdateLeaderAndIsr() STARTED
KafkaZkClientTest > testUpdateLeaderAndIsr() PASSED
KafkaZkClientTest > testUpdateBrokerInfo() STARTED
KafkaZkClientTest > testUpdateBrokerInfo() PASSED
KafkaZkClientTest > testCreateRecursive() STARTED
KafkaZkClientTest > testCreateRecursive() PASSED
KafkaZkClientTest > testGetConsumerOffsetNoData() STARTED
KafkaZkClientTest > testGetConsumerOffsetNoData() PASSED
KafkaZkClientTest > testDeleteTopicPathMethods() STARTED
KafkaZkClientTest > testDeleteTopicPathMethods() PASSED
KafkaZkClientTest > testSetTopicPartitionStatesRaw() STARTED
KafkaZkClientTest > testSetTopicPartitionStatesRaw() PASSED
KafkaZkClientTest > testAclManagementMethods() STARTED
KafkaZkClientTest > testAclManagementMethods() PASSED
KafkaZkClientTest > testPreferredReplicaElectionMethods() STARTED
KafkaZkClientTest > testPreferredReplicaElectionMethods() PASSED
KafkaZkClientTest > testPropagateLogDir() STARTED
KafkaZkClientTest > testPropagateLogDir() PASSED
KafkaZkClientTest > testGetDataAndStat() STARTED
KafkaZkClientTest > testGetDataAndStat() PASSED
KafkaZkClientTest > testReassignPartitionsInProgress() STARTED
KafkaZkClientTest > testReassignPartitionsInProgress() PASSED
KafkaZkClientTest > testCreateTopLevelPaths() STARTED
KafkaZkClientTest > testCreateTopLevelPaths() PASSED
KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() STARTED
KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() PASSED
KafkaZkClientTest > testIsrChangeNotificationGetters() STARTED
KafkaZkClientTest > testIsrChangeNotificationGetters() PASSED
KafkaZkClientTest > testLogDirEventNotificationsDeletion() STARTED
KafkaZkClientTest > testLogDirEventNotificationsDeletion() PASSED
KafkaZkClientTest > testGetLogConfigs() STARTED
KafkaZkClientTest > testGetLogConfigs() PASSED
KafkaZkClientTest > testBrokerSequenceIdMethods() STARTED
KafkaZkClientTest > testBrokerSequenceIdMethods() PASSED
KafkaZkClientTest > testAclMethods() STARTED
KafkaZkClientTest > testAclMethods() PASSED
KafkaZkClientTest > testCreateSequentialPersistentPath() STARTED
KafkaZkClientTest > testCreateSequentialPersistentPath() PASSED
KafkaZkClientTest > testConditionalUpdatePath() STARTED
KafkaZkClientTest > testConditionalUpdatePath() PASSED
KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() STARTED
KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() PASSED
KafkaZkClientTest > testDeleteTopicZNode() STARTED
KafkaZkClientTest > testDeleteTopicZNode() PASSED
KafkaZkClientTest > testDeletePath() STARTED
KafkaZkClientTest > testDeletePath() PASSED
KafkaZkClientTest > testGetBrokerMethods() STARTED
KafkaZkClientTest > testGetBrokerMethods() PASSED
KafkaZkClientTest > testCreateTokenChangeNotification() STARTED
KafkaZkClientTest > testCreateTokenChangeNotification() PASSED
KafkaZkClientTest > testGetTopicsAndPartitions() STARTED
KafkaZkClientTest > testGetTopicsAndPartitions() PASSED
KafkaZkClientTest > testRegisterBrokerInfo() STARTED
KafkaZkClientTest > testRegisterBrokerInfo() PASSED
KafkaZkClientTest > testRetryRegisterBrokerInfo() STARTED
KafkaZkClientTest > testRetryRegisterBrokerInfo() PASSED
KafkaZkClientTest > testConsumerOffsetPath() STARTED
KafkaZkClientTest > testConsumerOffsetPath() PASSED
KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() STARTED
KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() PASSED
KafkaZkClientTest > testTopicAssignments() STARTED
KafkaZkClientTest > testTopicAssignments() PASSED
KafkaZkClientTest > testControllerManagementMethods() STARTED
KafkaZkClientTest > testControllerManagementMethods() PASSED
KafkaZkClientTest > testTopicAssignmentMethods() STARTED
KafkaZkClientTest > testTopicAssignmentMethods() PASSED
KafkaZkClientTest > testConnectionViaNettyClient() STARTED
KafkaZkClientTest > testConnectionViaNettyClient() PASSED
KafkaZkClientTest > testPropagateIsrChanges() STARTED
KafkaZkClientTest > testPropagateIsrChanges() PASSED
KafkaZkClientTest > testControllerEpochMethods() STARTED
KafkaZkClientTest > testControllerEpochMethods() PASSED
KafkaZkClientTest > testDeleteRecursive() STARTED
KafkaZkClientTest > testDeleteRecursive() PASSED
KafkaZkClientTest > testGetTopicPartitionStates() STARTED
KafkaZkClientTest > testGetTopicPartitionStates() PASSED
KafkaZkClientTest > testCreateConfigChangeNotification() STARTED
KafkaZkClientTest > testCreateConfigChangeNotification() PASSED
KafkaZkClientTest > testDelegationTokenMethods() STARTED
KafkaZkClientTest > testDelegationTokenMethods() PASSED
LiteralAclStoreTest > shouldHaveCorrectPaths() STARTED
LiteralAclStoreTest > shouldHaveCorrectPaths() PASSED
LiteralAclStoreTest > shouldRoundTripChangeNode() STARTED
LiteralAclStoreTest > shouldRoundTripChangeNode() PASSED
LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() STARTED
LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() PASSED
LiteralAclStoreTest > shouldWriteChangesToTheWritePath() STARTED
LiteralAclStoreTest > shouldWriteChangesToTheWritePath() PASSED
LiteralAclStoreTest > shouldHaveCorrectPatternType() STARTED
LiteralAclStoreTest > shouldHaveCorrectPatternType() PASSED
LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() STARTED
LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() PASSED
ReassignPartitionsZNodeTest > testDecodeInvalidJson() STARTED
ReassignPartitionsZNodeTest > testDecodeInvalidJson() PASSED
ReassignPartitionsZNodeTest > testEncode() STARTED
ReassignPartitionsZNodeTest > testEncode() PASSED
ReassignPartitionsZNodeTest > testDecodeValidJson() STARTED
ReassignPartitionsZNodeTest > testDecodeValidJson() PASSED
ControllerApisTest > testBrokerRegistration() STARTED
ControllerApisTest > testBrokerRegistration() PASSED
3425 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 ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/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'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/ws/core/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 49m 23s
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-trunk-jdk11 #528
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/528/display/redirect?page=changes>
Changes:
[Manikumar Reddy] KAFKA-12324: Upgrade jetty to fix CVE-2020-27218
[github] MINOR: Raft request thread should discover api versions (#10157)
------------------------------------------
[...truncated 3.67 MB...]
KafkaZkClientTest > testGetChildren() STARTED
KafkaZkClientTest > testGetChildren() PASSED
KafkaZkClientTest > testSetAndGetConsumerOffset() STARTED
KafkaZkClientTest > testSetAndGetConsumerOffset() PASSED
KafkaZkClientTest > testClusterIdMethods() STARTED
KafkaZkClientTest > testClusterIdMethods() PASSED
KafkaZkClientTest > testEntityConfigManagementMethods() STARTED
KafkaZkClientTest > testEntityConfigManagementMethods() PASSED
KafkaZkClientTest > testUpdateLeaderAndIsr() STARTED
KafkaZkClientTest > testUpdateLeaderAndIsr() PASSED
KafkaZkClientTest > testUpdateBrokerInfo() STARTED
KafkaZkClientTest > testUpdateBrokerInfo() PASSED
KafkaZkClientTest > testCreateRecursive() STARTED
KafkaZkClientTest > testCreateRecursive() PASSED
KafkaZkClientTest > testGetConsumerOffsetNoData() STARTED
KafkaZkClientTest > testGetConsumerOffsetNoData() PASSED
KafkaZkClientTest > testDeleteTopicPathMethods() STARTED
KafkaZkClientTest > testDeleteTopicPathMethods() PASSED
KafkaZkClientTest > testSetTopicPartitionStatesRaw() STARTED
KafkaZkClientTest > testSetTopicPartitionStatesRaw() PASSED
KafkaZkClientTest > testAclManagementMethods() STARTED
KafkaZkClientTest > testAclManagementMethods() PASSED
KafkaZkClientTest > testPreferredReplicaElectionMethods() STARTED
KafkaZkClientTest > testPreferredReplicaElectionMethods() PASSED
KafkaZkClientTest > testPropagateLogDir() STARTED
KafkaZkClientTest > testPropagateLogDir() PASSED
KafkaZkClientTest > testGetDataAndStat() STARTED
KafkaZkClientTest > testGetDataAndStat() PASSED
KafkaZkClientTest > testReassignPartitionsInProgress() STARTED
KafkaZkClientTest > testReassignPartitionsInProgress() PASSED
KafkaZkClientTest > testCreateTopLevelPaths() STARTED
KafkaZkClientTest > testCreateTopLevelPaths() PASSED
KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() STARTED
KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() PASSED
KafkaZkClientTest > testIsrChangeNotificationGetters() STARTED
KafkaZkClientTest > testIsrChangeNotificationGetters() PASSED
KafkaZkClientTest > testLogDirEventNotificationsDeletion() STARTED
KafkaZkClientTest > testLogDirEventNotificationsDeletion() PASSED
KafkaZkClientTest > testGetLogConfigs() STARTED
KafkaZkClientTest > testGetLogConfigs() PASSED
KafkaZkClientTest > testBrokerSequenceIdMethods() STARTED
KafkaZkClientTest > testBrokerSequenceIdMethods() PASSED
KafkaZkClientTest > testAclMethods() STARTED
KafkaZkClientTest > testAclMethods() PASSED
KafkaZkClientTest > testCreateSequentialPersistentPath() STARTED
KafkaZkClientTest > testCreateSequentialPersistentPath() PASSED
KafkaZkClientTest > testConditionalUpdatePath() STARTED
KafkaZkClientTest > testConditionalUpdatePath() PASSED
KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() STARTED
KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() PASSED
KafkaZkClientTest > testDeleteTopicZNode() STARTED
KafkaZkClientTest > testDeleteTopicZNode() PASSED
KafkaZkClientTest > testDeletePath() STARTED
KafkaZkClientTest > testDeletePath() PASSED
KafkaZkClientTest > testGetBrokerMethods() STARTED
KafkaZkClientTest > testGetBrokerMethods() PASSED
KafkaZkClientTest > testCreateTokenChangeNotification() STARTED
KafkaZkClientTest > testCreateTokenChangeNotification() PASSED
KafkaZkClientTest > testGetTopicsAndPartitions() STARTED
KafkaZkClientTest > testGetTopicsAndPartitions() PASSED
KafkaZkClientTest > testRegisterBrokerInfo() STARTED
KafkaZkClientTest > testRegisterBrokerInfo() PASSED
KafkaZkClientTest > testRetryRegisterBrokerInfo() STARTED
KafkaZkClientTest > testRetryRegisterBrokerInfo() PASSED
KafkaZkClientTest > testConsumerOffsetPath() STARTED
KafkaZkClientTest > testConsumerOffsetPath() PASSED
KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() STARTED
KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() PASSED
KafkaZkClientTest > testTopicAssignments() STARTED
KafkaZkClientTest > testTopicAssignments() PASSED
KafkaZkClientTest > testControllerManagementMethods() STARTED
KafkaZkClientTest > testControllerManagementMethods() PASSED
KafkaZkClientTest > testTopicAssignmentMethods() STARTED
KafkaZkClientTest > testTopicAssignmentMethods() PASSED
KafkaZkClientTest > testConnectionViaNettyClient() STARTED
KafkaZkClientTest > testConnectionViaNettyClient() PASSED
KafkaZkClientTest > testPropagateIsrChanges() STARTED
KafkaZkClientTest > testPropagateIsrChanges() PASSED
KafkaZkClientTest > testControllerEpochMethods() STARTED
KafkaZkClientTest > testControllerEpochMethods() PASSED
KafkaZkClientTest > testDeleteRecursive() STARTED
KafkaZkClientTest > testDeleteRecursive() PASSED
KafkaZkClientTest > testGetTopicPartitionStates() STARTED
KafkaZkClientTest > testGetTopicPartitionStates() PASSED
KafkaZkClientTest > testCreateConfigChangeNotification() STARTED
KafkaZkClientTest > testCreateConfigChangeNotification() PASSED
KafkaZkClientTest > testDelegationTokenMethods() STARTED
KafkaZkClientTest > testDelegationTokenMethods() PASSED
LiteralAclStoreTest > shouldHaveCorrectPaths() STARTED
LiteralAclStoreTest > shouldHaveCorrectPaths() PASSED
LiteralAclStoreTest > shouldRoundTripChangeNode() STARTED
LiteralAclStoreTest > shouldRoundTripChangeNode() PASSED
LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() STARTED
LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() PASSED
LiteralAclStoreTest > shouldWriteChangesToTheWritePath() STARTED
LiteralAclStoreTest > shouldWriteChangesToTheWritePath() PASSED
LiteralAclStoreTest > shouldHaveCorrectPatternType() STARTED
LiteralAclStoreTest > shouldHaveCorrectPatternType() PASSED
LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() STARTED
LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() PASSED
ReassignPartitionsZNodeTest > testDecodeInvalidJson() STARTED
ReassignPartitionsZNodeTest > testDecodeInvalidJson() PASSED
ReassignPartitionsZNodeTest > testEncode() STARTED
ReassignPartitionsZNodeTest > testEncode() PASSED
ReassignPartitionsZNodeTest > testDecodeValidJson() STARTED
ReassignPartitionsZNodeTest > testDecodeValidJson() PASSED
ControllerApisTest > testBrokerRegistration() STARTED
ControllerApisTest > testBrokerRegistration() PASSED
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-trunk-jdk11/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 ':streams:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/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.
==============================================================================
* 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 47m 27s
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-trunk-jdk11 #527
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/527/display/redirect?page=changes>
Changes:
[github] MINOR: Remove redundant log close in `KafkaRaftClient` (#10168)
------------------------------------------
[...truncated 3.64 MB...]
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
KafkaTest > testZookeeperKeyStorePassword() STARTED
KafkaTest > testZookeeperKeyStorePassword() PASSED
KafkaTest > testConnectionsMaxReauthMsExplicit() STARTED
KafkaTest > testConnectionsMaxReauthMsExplicit() PASSED
KafkaTest > testKafkaSslPasswordsWithSymbols() STARTED
KafkaTest > testKafkaSslPasswordsWithSymbols() PASSED
KafkaTest > testZkSslProtocol() STARTED
KafkaTest > testZkSslProtocol() PASSED
KafkaTest > testZkSslCipherSuites() STARTED
KafkaTest > testZkSslCipherSuites() PASSED
KafkaTest > testZkSslKeyStoreType() STARTED
KafkaTest > testZkSslKeyStoreType() PASSED
KafkaTest > testZkSslOcspEnable() STARTED
KafkaTest > testZkSslOcspEnable() PASSED
KafkaTest > testConnectionsMaxReauthMsDefault() STARTED
KafkaTest > testConnectionsMaxReauthMsDefault() PASSED
KafkaTest > testZkSslTrustStoreLocation() STARTED
KafkaTest > testZkSslTrustStoreLocation() PASSED
KafkaTest > testZkSslEnabledProtocols() STARTED
KafkaTest > testZkSslEnabledProtocols() PASSED
KafkaTest > testKafkaSslPasswords() STARTED
KafkaTest > testKafkaSslPasswords() PASSED
KafkaTest > testGetKafkaConfigFromArgs() STARTED
KafkaTest > testGetKafkaConfigFromArgs() PASSED
KafkaTest > testZkSslClientEnable() STARTED
KafkaTest > testZkSslClientEnable() PASSED
KafkaTest > testZookeeperTrustStorePassword() STARTED
KafkaTest > testZookeeperTrustStorePassword() PASSED
KafkaTest > testGetKafkaConfigFromArgsNonArgsAtTheEnd() STARTED
KafkaTest > testGetKafkaConfigFromArgsNonArgsAtTheEnd() PASSED
KafkaTest > testGetKafkaConfigFromArgsNonArgsOnly() STARTED
KafkaTest > testGetKafkaConfigFromArgsNonArgsOnly() PASSED
KafkaTest > testGetKafkaConfigFromArgsNonArgsAtTheBegging() STARTED
KafkaTest > testGetKafkaConfigFromArgsNonArgsAtTheBegging() PASSED
KafkaTest > testZkSslKeyStoreLocation() STARTED
KafkaTest > testZkSslKeyStoreLocation() PASSED
KafkaTest > testZkSslCrlEnable() STARTED
KafkaTest > testZkSslCrlEnable() PASSED
KafkaTest > testZkSslEndpointIdentificationAlgorithm() STARTED
KafkaTest > testZkSslEndpointIdentificationAlgorithm() PASSED
KafkaTest > testZkSslTrustStoreType() STARTED
KafkaTest > testZkSslTrustStoreType() 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@465a137e, value = [B@7ad9d403), 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@465a137e, value = [B@7ad9d403), 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@72167c8e, value = [B@46dbc703), 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@72167c8e, value = [B@46dbc703), 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@305027bf, value = [B@5e6b7e34), 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@305027bf, value = [B@5e6b7e34), 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@1f588b7b, value = [B@7a3a44c), 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@1f588b7b, value = [B@7a3a44c), 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@367f06d8, value = [B@33e044fd), 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@367f06d8, value = [B@33e044fd), 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@68b812a9, value = [B@72a35a36), 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@68b812a9, value = [B@72a35a36), 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@3c24cb7c, value = [B@dd2a7a9), 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@3c24cb7c, value = [B@dd2a7a9), 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@2557d1e0, value = [B@4dcd5d96), 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@2557d1e0, value = [B@4dcd5d96), 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@57a80078, value = [B@4fdf0acb), 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@57a80078, value = [B@4fdf0acb), 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@67e0ba5f, value = [B@42b8df5e), 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@67e0ba5f, value = [B@42b8df5e), 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@13060182, value = [B@3ffeccb), 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@13060182, value = [B@3ffeccb), 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@612f9ca9, value = [B@6569edfd), 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@612f9ca9, value = [B@6569edfd), 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@4640eac3, value = [B@3a25df74), 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@4640eac3, value = [B@3a25df74), 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@dded15b, value = [B@4c0934d1), 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@dded15b, value = [B@4c0934d1), 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@58c38c5b, value = [B@69b279a0), 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@58c38c5b, value = [B@69b279a0), 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@121d39c4, value = [B@173728ea), 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@121d39c4, value = [B@173728ea), 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@39cefcca, value = [B@2e13f200), 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@39cefcca, value = [B@2e13f200), 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@424ceb1, 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@424ceb1, 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@7005c561, 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@7005c561, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
PASSED
3418 tests completed, 1 failed, 7 skipped
> Task :core:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':core:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/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 17m 16s
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-trunk-jdk11 #526
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/526/display/redirect?page=changes>
Changes:
[github] KAFKA-12276: Add the quorum controller code (#10070)
[github] KAFKA-12335 Upgrade junit from 5.7.0 to 5.7.1 (#10145)
[github] MINOR: Enhance the documentation with the metric unit which is milliseconds (#10148)
[github] MINOR: AbstractCoordinator should log with its subclass (#10149)
[github] MINOR: apply Utils.isBlank to code base (#10124)
------------------------------------------
[...truncated 3.66 MB...]
SocketServerTest > testSaslReauthenticationFailureNoKip152SaslAuthenticate() STARTED
SocketServerTest > testSaslReauthenticationFailureNoKip152SaslAuthenticate() PASSED
SocketServerTest > testClientDisconnectionUpdatesRequestMetrics() STARTED
SocketServerTest > testClientDisconnectionUpdatesRequestMetrics() PASSED
SocketServerTest > testProcessorMetricsTags() STARTED
SocketServerTest > testProcessorMetricsTags() PASSED
SocketServerTest > remoteCloseWithBufferedReceivesFailedSend() STARTED
SocketServerTest > remoteCloseWithBufferedReceivesFailedSend() PASSED
SocketServerTest > testMaxConnectionsPerIp() STARTED
SocketServerTest > testMaxConnectionsPerIp() PASSED
SocketServerTest > testConnectionId() STARTED
SocketServerTest > testConnectionId() PASSED
SocketServerTest > remoteCloseSendFailure() STARTED
SocketServerTest > remoteCloseSendFailure() PASSED
SocketServerTest > testBrokerSendAfterChannelClosedUpdatesRequestMetrics() STARTED
SocketServerTest > testBrokerSendAfterChannelClosedUpdatesRequestMetrics() PASSED
SocketServerTest > testControlPlaneTakePrecedenceOverInterBrokerListenerAsPrivilegedListener() STARTED
SocketServerTest > testControlPlaneTakePrecedenceOverInterBrokerListenerAsPrivilegedListener() PASSED
SocketServerTest > testNoOpAction() STARTED
SocketServerTest > testNoOpAction() PASSED
SocketServerTest > simpleRequest() STARTED
SocketServerTest > simpleRequest() PASSED
SocketServerTest > testSendActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED
SocketServerTest > testSendActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED
SocketServerTest > testIdleConnection() STARTED
SocketServerTest > testIdleConnection() PASSED
SocketServerTest > remoteCloseWithoutBufferedReceives() STARTED
SocketServerTest > remoteCloseWithoutBufferedReceives() PASSED
SocketServerTest > remoteCloseWithCompleteAndIncompleteBufferedReceives() STARTED
SocketServerTest > remoteCloseWithCompleteAndIncompleteBufferedReceives() PASSED
SocketServerTest > testZeroMaxConnectionsPerIp() STARTED
SocketServerTest > testZeroMaxConnectionsPerIp() PASSED
SocketServerTest > testClientInformationWithLatestApiVersionsRequest() STARTED
SocketServerTest > testClientInformationWithLatestApiVersionsRequest() PASSED
SocketServerTest > testMetricCollectionAfterShutdown() STARTED
SocketServerTest > testMetricCollectionAfterShutdown() PASSED
SocketServerTest > testSessionPrincipal() STARTED
SocketServerTest > testSessionPrincipal() PASSED
SocketServerTest > configureNewConnectionException() STARTED
SocketServerTest > configureNewConnectionException() PASSED
SocketServerTest > testSaslReauthenticationFailureWithKip152SaslAuthenticate() STARTED
SocketServerTest > testSaslReauthenticationFailureWithKip152SaslAuthenticate() PASSED
SocketServerTest > testMaxConnectionsPerIpOverrides() STARTED
SocketServerTest > testMaxConnectionsPerIpOverrides() PASSED
SocketServerTest > processNewResponseException() STARTED
SocketServerTest > processNewResponseException() PASSED
SocketServerTest > remoteCloseWithIncompleteBufferedReceive() STARTED
SocketServerTest > remoteCloseWithIncompleteBufferedReceive() PASSED
SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() STARTED
SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() PASSED
SocketServerTest > testStagedListenerStartup() STARTED
SocketServerTest > testStagedListenerStartup() PASSED
SocketServerTest > testConnectionRateLimit() STARTED
SocketServerTest > testConnectionRateLimit() PASSED
SocketServerTest > testConnectionRatePerIp() STARTED
SocketServerTest > testConnectionRatePerIp() PASSED
SocketServerTest > processCompletedSendException() STARTED
SocketServerTest > processCompletedSendException() PASSED
SocketServerTest > processDisconnectedException() STARTED
SocketServerTest > processDisconnectedException() PASSED
SocketServerTest > closingChannelWithBufferedReceives() STARTED
SocketServerTest > closingChannelWithBufferedReceives() PASSED
SocketServerTest > sendCancelledKeyException() STARTED
SocketServerTest > sendCancelledKeyException() PASSED
SocketServerTest > processCompletedReceiveException() STARTED
SocketServerTest > processCompletedReceiveException() PASSED
SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED
SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED
SocketServerTest > closingChannelSendFailure() STARTED
SocketServerTest > closingChannelSendFailure() PASSED
SocketServerTest > idleExpiryWithBufferedReceives() STARTED
SocketServerTest > idleExpiryWithBufferedReceives() PASSED
SocketServerTest > testSocketsCloseOnShutdown() STARTED
SocketServerTest > testSocketsCloseOnShutdown() PASSED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED
SocketServerTest > pollException() STARTED
SocketServerTest > pollException() PASSED
SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED
SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED
SocketServerTest > remoteCloseWithBufferedReceives() STARTED
SocketServerTest > remoteCloseWithBufferedReceives() PASSED
SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED
SocketServerTest > testThrottledSocketsClosedOnShutdown() PASSED
SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() STARTED
SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() PASSED
SocketServerTest > testInterBrokerListenerAsPrivilegedListener() STARTED
SocketServerTest > testInterBrokerListenerAsPrivilegedListener() PASSED
SocketServerTest > testSslSocketServer() STARTED
SocketServerTest > testSslSocketServer() PASSED
SocketServerTest > testDisabledRequestIsRejected() STARTED
SocketServerTest > testDisabledRequestIsRejected() PASSED
SocketServerTest > tooBigRequestIsRejected() STARTED
SocketServerTest > tooBigRequestIsRejected() PASSED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED
SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED
KafkaTimerTest > testKafkaTimer() STARTED
KafkaTimerTest > testKafkaTimer() PASSED
LinuxIoMetricsCollectorTest > testReadProcFile() STARTED
LinuxIoMetricsCollectorTest > testReadProcFile() PASSED
LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() STARTED
LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() PASSED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED
ControllerApisTest > testBrokerRegistration() STARTED
ControllerApisTest > testBrokerRegistration() PASSED
3418 tests completed, 1 failed, 7 skipped
> Task :core:test FAILED
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/ws/streams/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':core:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/ws/core/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 49m 52s
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-trunk-jdk11 #525
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/525/display/redirect?page=changes>
Changes:
[Colin McCabe] MINOR: Fix Raft broker restart issue when offset partitions are deferred #10155
[github] KAFKA-12332; Error partitions from topics with invalid IDs in LISR requests (#10143)
[github] MINOR: Correct warning about increasing capacity when insufficient nodes to assign standby tasks (#10151)
[github] KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException (#10158)
[github] KAFKA-9274: Throw TaskCorruptedException instead of TimeoutException when TX commit times out (#10072)
[github] KAFKA-10817; Add clusterId validation to raft Fetch handling (#10129)
[github] KAFKA-12339: Add retry to admin client's listOffsets (#10152)
[Colin McCabe] KAFKA-12334: Add the KIP-500 metadata shell
[github] KAFKA-9672: Leader with ISR as a superset of replicas (#9631)
------------------------------------------
[...truncated 3.66 MB...]
ReplicaStateMachineTest > testInvalidOnlineReplicaToNewReplicaTransition() STARTED
ReplicaStateMachineTest > testInvalidOnlineReplicaToNewReplicaTransition() PASSED
ReplicaStateMachineTest > testReplicaDeletionStartedToReplicaDeletionIneligibleTransition() STARTED
ReplicaStateMachineTest > testReplicaDeletionStartedToReplicaDeletionIneligibleTransition() PASSED
ReplicaStateMachineTest > testInvalidReplicaDeletionSuccessfulToOfflineReplicaTransition() STARTED
ReplicaStateMachineTest > testInvalidReplicaDeletionSuccessfulToOfflineReplicaTransition() PASSED
ReplicaStateMachineTest > testInvalidReplicaDeletionIneligibleToNewReplicaTransition() STARTED
ReplicaStateMachineTest > testInvalidReplicaDeletionIneligibleToNewReplicaTransition() PASSED
ReplicaStateMachineTest > testReplicaDeletionIneligibleToOnlineReplicaTransition() STARTED
ReplicaStateMachineTest > testReplicaDeletionIneligibleToOnlineReplicaTransition() PASSED
ReplicaStateMachineTest > testInvalidReplicaDeletionStartedToNewReplicaTransition() STARTED
ReplicaStateMachineTest > testInvalidReplicaDeletionStartedToNewReplicaTransition() PASSED
ReplicaStateMachineTest > testInvalidNonexistentReplicaToReplicaDeletionSuccessfulTransition() STARTED
ReplicaStateMachineTest > testInvalidNonexistentReplicaToReplicaDeletionSuccessfulTransition() PASSED
ReplicaStateMachineTest > testNewReplicaToOnlineReplicaTransition() STARTED
ReplicaStateMachineTest > testNewReplicaToOnlineReplicaTransition() PASSED
ControllerEventManagerTest > testEventQueueTime() STARTED
ControllerEventManagerTest > testEventQueueTime() PASSED
ControllerEventManagerTest > testEventThatThrowsException() STARTED
ControllerEventManagerTest > testEventThatThrowsException() PASSED
ControllerEventManagerTest > testEventQueueTimeResetOnTimeout() STARTED
ControllerEventManagerTest > testEventQueueTimeResetOnTimeout() PASSED
ControllerEventManagerTest > testEventWithoutRateMetrics() STARTED
ControllerEventManagerTest > testEventWithoutRateMetrics() PASSED
ControllerEventManagerTest > testSuccessfulEvent() STARTED
ControllerEventManagerTest > testSuccessfulEvent() PASSED
ControllerEventManagerTest > testMetricsCleanedOnClose() STARTED
ControllerEventManagerTest > testMetricsCleanedOnClose() 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
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
KafkaTimerTest > testKafkaTimer() STARTED
KafkaTimerTest > testKafkaTimer() PASSED
LinuxIoMetricsCollectorTest > testReadProcFile() STARTED
LinuxIoMetricsCollectorTest > testReadProcFile() PASSED
LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() STARTED
LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() PASSED
ClusterToolTest > testClusterTooOldToHaveId() STARTED
ClusterToolTest > testClusterTooOldToHaveId() PASSED
ClusterToolTest > testPrintClusterId() STARTED
ClusterToolTest > testPrintClusterId() PASSED
ClusterToolTest > testLegacyModeClusterCannotUnregisterBroker() STARTED
ClusterToolTest > testLegacyModeClusterCannotUnregisterBroker() PASSED
ClusterToolTest > testUnregisterBroker() STARTED
ClusterToolTest > testUnregisterBroker() PASSED
ReplicaVerificationToolTest > testReplicaBufferVerifyChecksum() STARTED
ReplicaVerificationToolTest > testReplicaBufferVerifyChecksum() PASSED
MirrorMakerTest > testDefaultMirrorMakerMessageHandlerWithNoTimestampInSourceMessage() STARTED
MirrorMakerTest > testDefaultMirrorMakerMessageHandlerWithNoTimestampInSourceMessage() PASSED
MirrorMakerTest > testDefaultMirrorMakerMessageHandler() STARTED
MirrorMakerTest > testDefaultMirrorMakerMessageHandler() PASSED
MirrorMakerTest > testDefaultMirrorMakerMessageHandlerWithHeaders() STARTED
MirrorMakerTest > testDefaultMirrorMakerMessageHandlerWithHeaders() PASSED
CustomDeserializerTest > checkDeserializerTopicIsNotNull() STARTED
CustomDeserializerTest > checkDeserializerTopicIsNotNull() PASSED
CustomDeserializerTest > checkFormatterCallDeserializerWithHeaders() STARTED
CustomDeserializerTest > checkFormatterCallDeserializerWithHeaders() PASSED
GetOffsetShellTest > testTopicPartitionsFlagWithTopicFlagCauseExit() STARTED
GetOffsetShellTest > testTopicPartitionsFlagWithTopicFlagCauseExit() PASSED
GetOffsetShellTest > testTopicPatternArgWithPartitionsArg() STARTED
GetOffsetShellTest > testTopicPatternArgWithPartitionsArg() PASSED
GetOffsetShellTest > testTopicNameArg() STARTED
GetOffsetShellTest > testTopicNameArg() PASSED
GetOffsetShellTest > testTopicPatternArg() STARTED
GetOffsetShellTest > testTopicPatternArg() PASSED
GetOffsetShellTest > testTopicPartitionsNotFoundForNonExistentTopic() STARTED
GetOffsetShellTest > testTopicPartitionsNotFoundForNonExistentTopic() PASSED
GetOffsetShellTest > testPartitionsArg() STARTED
GetOffsetShellTest > testPartitionsArg() PASSED
GetOffsetShellTest > testTopicPartitionsArgWithInternalExcluded() STARTED
GetOffsetShellTest > testTopicPartitionsArgWithInternalExcluded() PASSED
GetOffsetShellTest > testNoFilterOptions() STARTED
GetOffsetShellTest > testNoFilterOptions() PASSED
GetOffsetShellTest > testTopicPartitionsFlagWithPartitionsFlagCauseExit() STARTED
GetOffsetShellTest > testTopicPartitionsFlagWithPartitionsFlagCauseExit() PASSED
GetOffsetShellTest > testTopicPartitionsArg() STARTED
GetOffsetShellTest > testTopicPartitionsArg() PASSED
GetOffsetShellTest > testInternalExcluded() STARTED
GetOffsetShellTest > testInternalExcluded() PASSED
GetOffsetShellTest > testTopicPartitionsNotFoundForNonMatchingTopicPartitionPattern() STARTED
GetOffsetShellTest > testTopicPartitionsNotFoundForNonMatchingTopicPartitionPattern() PASSED
GetOffsetShellTest > testTopicPartitionsNotFoundForExcludedInternalTopic() STARTED
GetOffsetShellTest > testTopicPartitionsNotFoundForExcludedInternalTopic() PASSED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/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 35m 39s
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-trunk-jdk11 #524
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/524/display/redirect?page=changes>
Changes:
[github] MINOR: Import classes that is used in docs to fix warnings. (#10136)
[github] KAFKA-10885 Refactor MemoryRecordsBuilderTest/MemoryRecordsTest to avoid a lot of… (#9906)
[github] MINOR: Add KIP-500 BrokerServer and ControllerServer (#10113)
[github] MINOR: Fix Typo in MirrorMaker README file (#10144)
[github] KAFKA-12303: Fix handling of null values by Flatten SMT (#10073)
[github] HOTFIX: Fix build error caused by ControllerApisTest.scala (#10146)
[github] TRIVIAL: fix JavaDocs formatting (#10134)
[Colin McCabe] KAFKA-12278; Ensure exposed api versions are consistent within listener (#10666)
[github] KAFKA-12331: Use LEO for the base offset of LeaderChangeMessage batch (#10138)
[github] KAFKA-9524: increase retention time for window and grace periods longer than one day (#10091)
[github] KAFKA-12258; Add support for splitting appending records (#10063)
[Chia-Ping Tsai] MINOR: Added missing import (KafkaVersion) to kafka.py (#10154)
[github] MINOR: Fix broken link in quickstart.html (#10161)
[github] KAFKA-12340: Fix potential resource leak in Kafka*BackingStore (#10153)
------------------------------------------
[...truncated 3.65 MB...]
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
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
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 > testUnexpectedAppendOffset() STARTED
KafkaMetadataLogTest > testUnexpectedAppendOffset() 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
ControllerApisTest > testBrokerRegistration() STARTED
ControllerApisTest > testBrokerRegistration() PASSED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/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 39m 22s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #523
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/523/display/redirect?page=changes>
Changes:
[Jun Rao] MINOR: Add note about topic IDs to upgrade doc (#10125)
------------------------------------------
[...truncated 3.44 MB...]
KafkaZkClientTest > testSetTopicPartitionStatesRaw() PASSED
KafkaZkClientTest > testAclManagementMethods() STARTED
KafkaZkClientTest > testAclManagementMethods() PASSED
KafkaZkClientTest > testPreferredReplicaElectionMethods() STARTED
KafkaZkClientTest > testPreferredReplicaElectionMethods() PASSED
KafkaZkClientTest > testPropagateLogDir() STARTED
KafkaZkClientTest > testPropagateLogDir() PASSED
KafkaZkClientTest > testGetDataAndStat() STARTED
KafkaZkClientTest > testGetDataAndStat() PASSED
KafkaZkClientTest > testReassignPartitionsInProgress() STARTED
KafkaZkClientTest > testReassignPartitionsInProgress() PASSED
KafkaZkClientTest > testCreateTopLevelPaths() STARTED
KafkaZkClientTest > testCreateTopLevelPaths() PASSED
KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() STARTED
KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() PASSED
KafkaZkClientTest > testIsrChangeNotificationGetters() STARTED
KafkaZkClientTest > testIsrChangeNotificationGetters() PASSED
KafkaZkClientTest > testLogDirEventNotificationsDeletion() STARTED
KafkaZkClientTest > testLogDirEventNotificationsDeletion() PASSED
KafkaZkClientTest > testGetLogConfigs() STARTED
KafkaZkClientTest > testGetLogConfigs() PASSED
KafkaZkClientTest > testBrokerSequenceIdMethods() STARTED
KafkaZkClientTest > testBrokerSequenceIdMethods() PASSED
KafkaZkClientTest > testAclMethods() STARTED
KafkaZkClientTest > testAclMethods() PASSED
KafkaZkClientTest > testCreateSequentialPersistentPath() STARTED
KafkaZkClientTest > testCreateSequentialPersistentPath() PASSED
KafkaZkClientTest > testConditionalUpdatePath() STARTED
KafkaZkClientTest > testConditionalUpdatePath() PASSED
KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() STARTED
KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() PASSED
KafkaZkClientTest > testDeleteTopicZNode() STARTED
KafkaZkClientTest > testDeleteTopicZNode() PASSED
KafkaZkClientTest > testDeletePath() STARTED
KafkaZkClientTest > testDeletePath() PASSED
KafkaZkClientTest > testGetBrokerMethods() STARTED
KafkaZkClientTest > testGetBrokerMethods() PASSED
KafkaZkClientTest > testCreateTokenChangeNotification() STARTED
KafkaZkClientTest > testCreateTokenChangeNotification() PASSED
KafkaZkClientTest > testGetTopicsAndPartitions() STARTED
KafkaZkClientTest > testGetTopicsAndPartitions() PASSED
KafkaZkClientTest > testRegisterBrokerInfo() STARTED
KafkaZkClientTest > testRegisterBrokerInfo() PASSED
KafkaZkClientTest > testRetryRegisterBrokerInfo() STARTED
KafkaZkClientTest > testRetryRegisterBrokerInfo() PASSED
KafkaZkClientTest > testConsumerOffsetPath() STARTED
KafkaZkClientTest > testConsumerOffsetPath() PASSED
KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() STARTED
KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() PASSED
KafkaZkClientTest > testTopicAssignments() STARTED
KafkaZkClientTest > testTopicAssignments() PASSED
KafkaZkClientTest > testControllerManagementMethods() STARTED
KafkaZkClientTest > testControllerManagementMethods() PASSED
KafkaZkClientTest > testTopicAssignmentMethods() STARTED
KafkaZkClientTest > testTopicAssignmentMethods() PASSED
KafkaZkClientTest > testConnectionViaNettyClient() STARTED
KafkaZkClientTest > testConnectionViaNettyClient() PASSED
KafkaZkClientTest > testPropagateIsrChanges() STARTED
KafkaZkClientTest > testPropagateIsrChanges() PASSED
KafkaZkClientTest > testControllerEpochMethods() STARTED
KafkaZkClientTest > testControllerEpochMethods() PASSED
KafkaZkClientTest > testDeleteRecursive() STARTED
KafkaZkClientTest > testDeleteRecursive() PASSED
KafkaZkClientTest > testGetTopicPartitionStates() STARTED
KafkaZkClientTest > testGetTopicPartitionStates() PASSED
KafkaZkClientTest > testCreateConfigChangeNotification() STARTED
KafkaZkClientTest > testCreateConfigChangeNotification() PASSED
KafkaZkClientTest > testDelegationTokenMethods() STARTED
KafkaZkClientTest > testDelegationTokenMethods() PASSED
LiteralAclStoreTest > shouldHaveCorrectPaths() STARTED
LiteralAclStoreTest > shouldHaveCorrectPaths() PASSED
LiteralAclStoreTest > shouldRoundTripChangeNode() STARTED
LiteralAclStoreTest > shouldRoundTripChangeNode() PASSED
LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() STARTED
LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() PASSED
LiteralAclStoreTest > shouldWriteChangesToTheWritePath() STARTED
LiteralAclStoreTest > shouldWriteChangesToTheWritePath() PASSED
LiteralAclStoreTest > shouldHaveCorrectPatternType() STARTED
LiteralAclStoreTest > shouldHaveCorrectPatternType() PASSED
LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() STARTED
LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() PASSED
ReassignPartitionsZNodeTest > testDecodeInvalidJson() STARTED
ReassignPartitionsZNodeTest > testDecodeInvalidJson() PASSED
ReassignPartitionsZNodeTest > testEncode() STARTED
ReassignPartitionsZNodeTest > testEncode() PASSED
ReassignPartitionsZNodeTest > testDecodeValidJson() STARTED
ReassignPartitionsZNodeTest > testDecodeValidJson() 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
TransactionsTest > testReadCommittedConsumerShouldNotSeeUndecidedData() 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-trunk-jdk11/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 75' 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 14m 15s
250 actionable tasks: 214 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de