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

Changes:


------------------------------------------
[...truncated 777180 lines...]
[2023-03-27T13:28:29.253Z] 
[2023-03-27T13:28:29.253Z]             Caused by:
[2023-03-27T13:28:29.253Z]             java.lang.NullPointerException
[2023-03-27T13:28:29.253Z] 
[2023-03-27T13:28:29.253Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean)[2]
 STARTED
[2023-03-27T13:29:32.121Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean)[2]
 failed, log available in 
/home/jenkins/workspace/Kafka_kafka_trunk/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean)[2].test.stdout
[2023-03-27T13:29:32.121Z] 
[2023-03-27T13:29:32.121Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(boolean)[2]
 FAILED
[2023-03-27T13:29:32.121Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-27T13:29:32.121Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-27T13:29:32.121Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-27T13:29:32.121Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-27T13:29:32.121Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-27T13:29:32.121Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-27T13:29:32.121Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeKafkaStreamsWithNamedTopologies(PauseResumeIntegrationTest.java:218)
[2023-03-27T13:29:32.121Z] 
[2023-03-27T13:29:32.121Z]         Caused by:
[2023-03-27T13:29:32.121Z]         
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-27T13:29:32.121Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-27T13:29:32.121Z]             at 
app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-27T13:29:32.121Z]             ... 5 more
[2023-03-27T13:29:32.121Z] 
[2023-03-27T13:29:32.121Z]             Caused by:
[2023-03-27T13:29:32.121Z]             java.lang.NullPointerException
[2023-03-27T13:29:32.121Z] 
[2023-03-27T13:29:32.121Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[1]
 STARTED
[2023-03-27T13:30:38.634Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[1]
 failed, log available in 
/home/jenkins/workspace/Kafka_kafka_trunk/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[1].test.stdout
[2023-03-27T13:30:38.634Z] 
[2023-03-27T13:30:38.634Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[1]
 FAILED
[2023-03-27T13:30:38.634Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-27T13:30:38.634Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-27T13:30:38.634Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-27T13:30:38.635Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-27T13:30:38.635Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-27T13:30:38.635Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-27T13:30:38.635Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(PauseResumeIntegrationTest.java:252)
[2023-03-27T13:30:38.635Z] 
[2023-03-27T13:30:38.635Z]         Caused by:
[2023-03-27T13:30:38.635Z]         
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-27T13:30:38.635Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-27T13:30:38.635Z]             at 
app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-27T13:30:38.635Z]             ... 5 more
[2023-03-27T13:30:38.635Z] 
[2023-03-27T13:30:38.635Z]             Caused by:
[2023-03-27T13:30:38.635Z]             java.lang.NullPointerException
[2023-03-27T13:30:38.635Z] 
[2023-03-27T13:30:38.635Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[2]
 STARTED
[2023-03-27T13:31:37.654Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[2]
 failed, log available in 
/home/jenkins/workspace/Kafka_kafka_trunk/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[2].test.stdout
[2023-03-27T13:31:37.654Z] 
[2023-03-27T13:31:37.654Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(boolean)[2]
 FAILED
[2023-03-27T13:31:37.654Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-27T13:31:37.654Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-27T13:31:37.654Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-27T13:31:37.654Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-27T13:31:37.654Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-27T13:31:37.654Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-27T13:31:37.654Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies(PauseResumeIntegrationTest.java:252)
[2023-03-27T13:31:37.654Z] 
[2023-03-27T13:31:37.654Z]         Caused by:
[2023-03-27T13:31:37.654Z]         
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-27T13:31:37.654Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-27T13:31:37.654Z]             at 
app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-27T13:31:37.654Z]             ... 5 more
[2023-03-27T13:31:37.654Z] 
[2023-03-27T13:31:37.654Z]             Caused by:
[2023-03-27T13:31:37.654Z]             java.lang.NullPointerException
[2023-03-27T13:31:37.654Z] 
[2023-03-27T13:31:37.654Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldAllowForNamedTopologiesToStartPaused(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[1]
 STARTED
[2023-03-27T13:32:42.989Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[1]
 failed, log available in 
/home/jenkins/workspace/Kafka_kafka_trunk/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[1].test.stdout
[2023-03-27T13:32:42.989Z] 
[2023-03-27T13:32:42.989Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldAllowForNamedTopologiesToStartPaused(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[1]
 FAILED
[2023-03-27T13:32:42.989Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-27T13:32:42.989Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-27T13:32:42.989Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-27T13:32:42.989Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-27T13:32:42.989Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-27T13:32:42.989Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-27T13:32:42.989Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(PauseResumeIntegrationTest.java:294)
[2023-03-27T13:32:42.989Z] 
[2023-03-27T13:32:42.989Z]         Caused by:
[2023-03-27T13:32:42.989Z]         
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-27T13:32:42.989Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-27T13:32:42.989Z]             at 
app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-27T13:32:42.989Z]             ... 5 more
[2023-03-27T13:32:42.989Z] 
[2023-03-27T13:32:42.989Z]             Caused by:
[2023-03-27T13:32:42.989Z]             java.lang.NullPointerException
[2023-03-27T13:32:42.989Z] 
[2023-03-27T13:32:42.989Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldAllowForNamedTopologiesToStartPaused(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[2]
 STARTED
[2023-03-27T13:33:46.281Z] 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[2]
 failed, log available in 
/home/jenkins/workspace/Kafka_kafka_trunk/streams/build/reports/testOutput/org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[2].test.stdout
[2023-03-27T13:33:46.281Z] 
[2023-03-27T13:33:46.281Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > PauseResumeIntegrationTest > 
shouldAllowForNamedTopologiesToStartPaused(boolean) > 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(boolean)[2]
 FAILED
[2023-03-27T13:33:46.281Z]     java.lang.AssertionError: Assertion failed with 
an exception after 60000 ms
[2023-03-27T13:33:46.281Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:395)
[2023-03-27T13:33:46.281Z]         at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:353)
[2023-03-27T13:33:46.281Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
[2023-03-27T13:33:46.281Z]         at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
[2023-03-27T13:33:46.281Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.awaitOutput(PauseResumeIntegrationTest.java:416)
[2023-03-27T13:33:46.281Z]         at 
org.apache.kafka.streams.integration.PauseResumeIntegrationTest.shouldAllowForNamedTopologiesToStartPaused(PauseResumeIntegrationTest.java:294)
[2023-03-27T13:33:46.281Z] 
[2023-03-27T13:33:46.281Z]         Caused by:
[2023-03-27T13:33:46.281Z]         
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-27T13:33:46.281Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.parseRecord(CompletedFetch.java:312)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.clients.consumer.internals.CompletedFetch.fetchRecords(CompletedFetch.java:264)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.fetchRecords(AbstractFetch.java:340)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.clients.consumer.internals.AbstractFetch.collectFetch(AbstractFetch.java:306)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1251)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1224)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readRecords(IntegrationTestUtils.java:1301)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.readKeyValues(IntegrationTestUtils.java:1259)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:728)
[2023-03-27T13:33:46.281Z]             at 
app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
[2023-03-27T13:33:46.281Z]             ... 5 more
[2023-03-27T13:33:46.281Z] 
[2023-03-27T13:33:46.281Z]             Caused by:
[2023-03-27T13:33:46.281Z]             java.lang.NullPointerException
[2023-03-27T13:33:48.376Z] 
[2023-03-27T13:33:48.376Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQuerySpecificActivePartitionStores() STARTED
[2023-03-27T13:33:50.647Z] 
[2023-03-27T13:33:50.647Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQuerySpecificActivePartitionStores() PASSED
[2023-03-27T13:33:50.647Z] 
[2023-03-27T13:33:50.647Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldFailWithIllegalArgumentExceptionWhenIQPartitionerReturnsMultiplePartitions()
 STARTED
[2023-03-27T13:33:52.190Z] 
[2023-03-27T13:33:52.191Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldFailWithIllegalArgumentExceptionWhenIQPartitionerReturnsMultiplePartitions()
 PASSED
[2023-03-27T13:33:52.191Z] 
[2023-03-27T13:33:52.191Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQueryAllStalePartitionStores() STARTED
[2023-03-27T13:33:57.953Z] 
[2023-03-27T13:33:57.953Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQueryAllStalePartitionStores() PASSED
[2023-03-27T13:33:57.953Z] 
[2023-03-27T13:33:57.953Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStoresMultiStreamThreads() STARTED
[2023-03-27T13:34:00.609Z] 
[2023-03-27T13:34:00.609Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStoresMultiStreamThreads() PASSED
[2023-03-27T13:34:00.609Z] 
[2023-03-27T13:34:00.609Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStores() STARTED
[2023-03-27T13:34:03.395Z] 
[2023-03-27T13:34:03.395Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStores() PASSED
[2023-03-27T13:34:03.395Z] 
[2023-03-27T13:34:03.395Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQueryOnlyActivePartitionStoresByDefault() STARTED
[2023-03-27T13:34:09.145Z] 
[2023-03-27T13:34:09.145Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQueryOnlyActivePartitionStoresByDefault() PASSED
[2023-03-27T13:34:09.145Z] 
[2023-03-27T13:34:09.145Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQueryStoresAfterAddingAndRemovingStreamThread() STARTED
[2023-03-27T13:34:14.402Z] 
[2023-03-27T13:34:14.402Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQueryStoresAfterAddingAndRemovingStreamThread() PASSED
[2023-03-27T13:34:14.402Z] 
[2023-03-27T13:34:14.402Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStoresMultiStreamThreadsNamedTopology() STARTED
[2023-03-27T13:34:17.575Z] 
[2023-03-27T13:34:17.575Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 183 > StoreQueryIntegrationTest > 
shouldQuerySpecificStalePartitionStoresMultiStreamThreadsNamedTopology() PASSED
[2023-03-27T13:34:19.409Z] 
[2023-03-27T13:34:19.409Z] 619 tests completed, 151 failed
[2023-03-27T13:34:21.876Z] There were failing tests. See the report at: 
file:///home/jenkins/workspace/Kafka_kafka_trunk/streams/build/reports/tests/integrationTest/index.html
[2023-03-27T13:34:24.856Z] 
[2023-03-27T13:34:24.856Z] Deprecated Gradle features were used in this build, 
making it incompatible with Gradle 9.0.
[2023-03-27T13:34:24.856Z] 
[2023-03-27T13:34:24.856Z] 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-27T13:34:24.856Z] 
[2023-03-27T13:34:24.856Z] See 
https://docs.gradle.org/8.0.2/userguide/command_line_interface.html#sec:command_line_warnings
[2023-03-27T13:34:24.856Z] 
[2023-03-27T13:34:24.856Z] BUILD SUCCESSFUL in 4h 33m 15s
[2023-03-27T13:34:24.856Z] 224 actionable tasks: 120 executed, 104 up-to-date
[2023-03-27T13:34:24.856Z] 
[2023-03-27T13:34:24.856Z] See the profiling report at: 
file:///home/jenkins/workspace/Kafka_kafka_trunk/build/reports/profile/profile-2023-03-27-09-01-17.html
[2023-03-27T13:34:24.856Z] A fine-grained performance profile is available: use 
the --scan option.
[Pipeline] junit
[2023-03-27T13:34:28.567Z] Recording test results
Cancelling nested steps due to timeout
[2023-03-27T16:49:26.891Z] null
[Pipeline] }
Cancelling nested steps due to timeout
[Pipeline] // withEnv
[2023-03-27T16:49:26.897Z] null
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] }
[Pipeline] // node
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] }
[Pipeline] // timestamps
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] }
[Pipeline] // timeout
[Pipeline] // node
[Pipeline] }
[Pipeline] }
[Pipeline] // stage
[Pipeline] // timestamps
[Pipeline] }
Failed in branch JDK 11 and Scala 2.13
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
Failed in branch JDK 11 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