See 
<https://ci-builds.apache.org/job/Kafka/job/kafka/job/trunk/1707/display/redirect>

Changes:


------------------------------------------
[...truncated 2040803 lines...]
[2023-03-25T17:45:20.590Z]             Caused by:
[2023-03-25T17:45:20.590Z]             java.lang.NullPointerException
[2023-03-25T17:45:20.590Z] 
[2023-03-25T17:45:20.590Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean)[2]
 STARTED
[2023-03-25T17:46:21.082Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean)[2]
 failed, log available in 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean)[2].test.stdout
[2023-03-25T17:46:21.082Z] 
[2023-03-25T17:46:21.082Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean)[2]
 FAILED
[2023-03-25T17:46:21.082Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-25T17:46:21.082Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-25T17:46:21.082Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-25T17:46:21.082Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-25T17:46:21.082Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-25T17:46:21.082Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-25T17:46:21.082Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(PauseResumeIntegrationTest.java:218)
[2023-03-25T17:46:21.082Z] 
[2023-03-25T17:46:21.082Z]         Caused by:
[2023-03-25T17:46:21.082Z]         
org.apache.kafka.common.errors.RecordDeserializationException: Error 
deserializing key/value for partition output-stream-1-0 at offset 0. If needed, 
please seek past the record to continue consumption.
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-25T17:46:21.082Z]             at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-25T17:46:21.082Z]             ... 5 more
[2023-03-25T17:46:21.082Z] 
[2023-03-25T17:46:21.082Z]             Caused by:
[2023-03-25T17:46:21.082Z]             java.lang.NullPointerException
[2023-03-25T17:46:21.082Z] 
[2023-03-25T17:46:21.082Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[1]
 STARTED
[2023-03-25T17:47:30.934Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[1]
 failed, log available in 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[1].test.stdout
[2023-03-25T17:47:30.934Z] 
[2023-03-25T17:47:30.934Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[1]
 FAILED
[2023-03-25T17:47:30.934Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-25T17:47:30.934Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-25T17:47:30.934Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-25T17:47:30.934Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-25T17:47:30.934Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-25T17:47:30.934Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-25T17:47:30.934Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(PauseResumeIntegrationTest.java:252)
[2023-03-25T17:47:30.934Z] 
[2023-03-25T17:47:30.934Z]         Caused by:
[2023-03-25T17:47:30.934Z]         
org.apache.kafka.common.errors.RecordDeserializationException: Error 
deserializing key/value for partition output-stream-1-0 at offset 0. If needed, 
please seek past the record to continue consumption.
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-25T17:47:30.934Z]             at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-25T17:47:30.934Z]             ... 5 more
[2023-03-25T17:47:30.934Z] 
[2023-03-25T17:47:30.934Z]             Caused by:
[2023-03-25T17:47:30.934Z]             java.lang.NullPointerException
[2023-03-25T17:47:30.934Z] 
[2023-03-25T17:47:30.934Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[2]
 STARTED
[2023-03-25T17:48:30.422Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[2]
 failed, log available in 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[2].test.stdout
[2023-03-25T17:48:30.422Z] 
[2023-03-25T17:48:30.422Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[2]
 FAILED
[2023-03-25T17:48:30.422Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-25T17:48:30.422Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-25T17:48:30.422Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-25T17:48:30.422Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-25T17:48:30.423Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-25T17:48:30.423Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-25T17:48:30.423Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(PauseResumeIntegrationTest.java:252)
[2023-03-25T17:48:30.423Z] 
[2023-03-25T17:48:30.423Z]         Caused by:
[2023-03-25T17:48:30.423Z]         
org.apache.kafka.common.errors.RecordDeserializationException: Error 
deserializing key/value for partition output-stream-1-0 at offset 0. If needed, 
please seek past the record to continue consumption.
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-25T17:48:30.423Z]             at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-25T17:48:30.423Z]             ... 5 more
[2023-03-25T17:48:30.423Z] 
[2023-03-25T17:48:30.423Z]             Caused by:
[2023-03-25T17:48:30.423Z]             java.lang.NullPointerException
[2023-03-25T17:48:30.423Z] 
[2023-03-25T17:48:30.423Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldAllowForNamedTopologiesToStartPaused(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[1]
 STARTED
[2023-03-25T17:49:30.664Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[1]
 failed, log available in 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[1].test.stdout
[2023-03-25T17:49:30.664Z] 
[2023-03-25T17:49:30.664Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldAllowForNamedTopologiesToStartPaused(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[1]
 FAILED
[2023-03-25T17:49:30.664Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-25T17:49:30.664Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-25T17:49:30.664Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-25T17:49:30.664Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-25T17:49:30.664Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-25T17:49:30.664Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-25T17:49:30.664Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(PauseResumeIntegrationTest.java:294)
[2023-03-25T17:49:30.664Z] 
[2023-03-25T17:49:30.664Z]         Caused by:
[2023-03-25T17:49:30.664Z]         
org.apache.kafka.common.errors.RecordDeserializationException: Error 
deserializing key/value for partition output-stream-2-0 at offset 0. If needed, 
please seek past the record to continue consumption.
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-25T17:49:30.664Z]             at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-25T17:49:30.664Z]             ... 5 more
[2023-03-25T17:49:30.664Z] 
[2023-03-25T17:49:30.664Z]             Caused by:
[2023-03-25T17:49:30.664Z]             java.lang.NullPointerException
[2023-03-25T17:49:30.664Z] 
[2023-03-25T17:49:30.664Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldAllowForNamedTopologiesToStartPaused(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[2]
 STARTED
[2023-03-25T17:50:41.461Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[2]
 failed, log available in 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[2].test.stdout
[2023-03-25T17:50:41.461Z] 
[2023-03-25T17:50:41.461Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > PauseResumeIntegrationTest > 
shouldAllowForNamedTopologiesToStartPaused(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[2]
 FAILED
[2023-03-25T17:50:41.461Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-25T17:50:41.461Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-25T17:50:41.461Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-25T17:50:41.461Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-25T17:50:41.461Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-25T17:50:41.461Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-25T17:50:41.462Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(PauseResumeIntegrationTest.java:294)
[2023-03-25T17:50:41.462Z] 
[2023-03-25T17:50:41.462Z]         Caused by:
[2023-03-25T17:50:41.462Z]         
org.apache.kafka.common.errors.RecordDeserializationException: Error 
deserializing key/value for partition output-stream-2-0 at offset 0. If needed, 
please seek past the record to continue consumption.
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-25T17:50:41.462Z]             at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-25T17:50:41.462Z]             ... 5 more
[2023-03-25T17:50:41.462Z] 
[2023-03-25T17:50:41.462Z]             Caused by:
[2023-03-25T17:50:41.462Z]             java.lang.NullPointerException
[2023-03-25T17:50:41.462Z] 
[2023-03-25T17:50:41.462Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQuerySpecificActivePartitionStores() STARTED
[2023-03-25T17:50:42.575Z] 
[2023-03-25T17:50:42.575Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQuerySpecificActivePartitionStores() PASSED
[2023-03-25T17:50:42.575Z] 
[2023-03-25T17:50:42.575Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldFailWithIllegalArgumentExceptionWhenIQPartitionerReturnsMultiplePartitions()
 STARTED
[2023-03-25T17:50:44.339Z] 
[2023-03-25T17:50:44.339Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldFailWithIllegalArgumentExceptionWhenIQPartitionerReturnsMultiplePartitions()
 PASSED
[2023-03-25T17:50:44.339Z] 
[2023-03-25T17:50:44.339Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQueryAllStalePartitionStores() STARTED
[2023-03-25T17:50:47.449Z] 
[2023-03-25T17:50:47.449Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQueryAllStalePartitionStores() PASSED
[2023-03-25T17:50:47.449Z] 
[2023-03-25T17:50:47.449Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStoresMultiStreamThreads() STARTED
[2023-03-25T17:50:51.959Z] 
[2023-03-25T17:50:51.959Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStoresMultiStreamThreads() PASSED
[2023-03-25T17:50:51.959Z] 
[2023-03-25T17:50:51.959Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStores() STARTED
[2023-03-25T17:50:54.991Z] 
[2023-03-25T17:50:54.991Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStores() PASSED
[2023-03-25T17:50:54.991Z] 
[2023-03-25T17:50:54.991Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQueryOnlyActivePartitionStoresByDefault() STARTED
[2023-03-25T17:51:00.046Z] 
[2023-03-25T17:51:00.046Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQueryOnlyActivePartitionStoresByDefault() PASSED
[2023-03-25T17:51:00.046Z] 
[2023-03-25T17:51:00.046Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQueryStoresAfterAddingAndRemovingStreamThread() STARTED
[2023-03-25T17:51:06.299Z] 
[2023-03-25T17:51:06.299Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQueryStoresAfterAddingAndRemovingStreamThread() PASSED
[2023-03-25T17:51:06.299Z] 
[2023-03-25T17:51:06.299Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStoresMultiStreamThreadsNamedTopology() STARTED
[2023-03-25T17:51:09.437Z] 
[2023-03-25T17:51:09.437Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 180 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStoresMultiStreamThreadsNamedTopology() PASSED
[2023-03-25T17:51:11.699Z] 
[2023-03-25T17:51:11.699Z] 619 tests completed, 152 failed
[2023-03-25T17:51:13.973Z] There were failing tests. See the report at: 
file:///home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/build/reports/tests/integrationTest/index.html
[2023-03-25T17:51:18.022Z] 
[2023-03-25T17:51:18.022Z] Deprecated Gradle features were used in this build, 
making it incompatible with Gradle 9.0.
[2023-03-25T17:51:18.022Z] 
[2023-03-25T17:51:18.022Z] You can use '--warning-mode all' to show the 
individual deprecation warnings and determine if they come from your own 
scripts or plugins.
[2023-03-25T17:51:18.022Z] 
[2023-03-25T17:51:18.022Z] See 
https://docs.gradle.org/8.0.2/userguide/command_line_interface.html#sec:command_line_warnings
[2023-03-25T17:51:18.022Z] 
[2023-03-25T17:51:18.022Z] BUILD SUCCESSFUL in 4h 12m 29s
[2023-03-25T17:51:18.022Z] 224 actionable tasks: 120 executed, 104 up-to-date
[2023-03-25T17:51:18.022Z] 
[2023-03-25T17:51:18.022Z] See the profiling report at: 
file:///home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/build/reports/profile/profile-2023-03-25-13-38-54.html
[2023-03-25T17:51:18.022Z] A fine-grained performance profile is available: use 
the --scan option.
[Pipeline] junit
[2023-03-25T17:51:18.887Z] Recording test results
Cancelling nested steps due to timeout
[2023-03-25T21:27:21.045Z] null
Cancelling nested steps due to timeout
[Pipeline] }
[2023-03-25T21:27:21.213Z] Sending interrupt signal to process
[2023-03-25T21:27:41.213Z] After 20s process did not stop
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] }
[Pipeline] // node
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] }
[Pipeline] // timestamps
[Pipeline] // node
[Pipeline] }
[Pipeline] }
[Pipeline] // timeout
[Pipeline] // timestamps
[Pipeline] }
[Pipeline] }
[Pipeline] // stage
[Pipeline] // timeout
[Pipeline] }
Failed in branch JDK 8 and Scala 2.13
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
Failed in branch JDK 17 and Scala 2.12
[Pipeline] // parallel
[Pipeline] }
[Pipeline] // stage
[Pipeline] stage
[Pipeline] { (Declarative: Post Actions)
[Pipeline] script
[Pipeline] {
[Pipeline] node
Running on builds35 in /home/jenkins/workspace/Kafka_kafka_trunk
[Pipeline] {
[Pipeline] step

Reply via email to