See
<https://ci-builds.apache.org/job/Kafka/job/kafka/job/3.4/168/display/redirect>
Changes:
------------------------------------------
[...truncated 524055 lines...]
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=true] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.doJoinFromRightThenDeleteRightEntity[leftJoin=true,
optimization=all, materialized=true, rejoin=true] PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldUnsubscribeOldForeignKeyIfLeftSideIsUpdated[leftJoin=true,
optimization=all, materialized=true, rejoin=false] STARTED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldUnsubscribeOldForeignKeyIfLeftSideIsUpdated[leftJoin=true,
optimization=all, materialized=true, rejoin=false] PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldNotEmitTombstonesWhenDeletingNonExistingRecords[leftJoin=true,
optimization=all, materialized=true, rejoin=false] STARTED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldNotEmitTombstonesWhenDeletingNonExistingRecords[leftJoin=true,
optimization=all, materialized=true, rejoin=false] PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldEmitTombstoneWhenDeletingNonJoiningRecords[leftJoin=true,
optimization=all, materialized=true, rejoin=false] STARTED
> Task :core:integrationTest
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testDeleteConsumerGroupOffsets(String) >
kafka.api.PlaintextAdminIntegrationTest.testDeleteConsumerGroupOffsets(String)[2]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testListReassignmentsDoesNotShowNonReassigningPartitions(String) >
kafka.api.PlaintextAdminIntegrationTest.testListReassignmentsDoesNotShowNonReassigningPartitions(String)[1]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testListReassignmentsDoesNotShowNonReassigningPartitions(String) >
kafka.api.PlaintextAdminIntegrationTest.testListReassignmentsDoesNotShowNonReassigningPartitions(String)[1]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testListReassignmentsDoesNotShowNonReassigningPartitions(String) >
kafka.api.PlaintextAdminIntegrationTest.testListReassignmentsDoesNotShowNonReassigningPartitions(String)[2]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testListReassignmentsDoesNotShowNonReassigningPartitions(String) >
kafka.api.PlaintextAdminIntegrationTest.testListReassignmentsDoesNotShowNonReassigningPartitions(String)[2]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testConsumeAfterDeleteRecords(String) >
kafka.api.PlaintextAdminIntegrationTest.testConsumeAfterDeleteRecords(String)[1]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testConsumeAfterDeleteRecords(String) >
kafka.api.PlaintextAdminIntegrationTest.testConsumeAfterDeleteRecords(String)[1]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testConsumeAfterDeleteRecords(String) >
kafka.api.PlaintextAdminIntegrationTest.testConsumeAfterDeleteRecords(String)[2]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testConsumeAfterDeleteRecords(String) >
kafka.api.PlaintextAdminIntegrationTest.testConsumeAfterDeleteRecords(String)[2]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testClose(String) >
kafka.api.PlaintextAdminIntegrationTest.testClose(String)[1] STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 180 >
SaslSslAdminIntegrationTest > testAuthorizedOperations() PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 180 >
SaslSslAdminIntegrationTest > testAclDescribe() STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testClose(String) >
kafka.api.PlaintextAdminIntegrationTest.testClose(String)[1] PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testClose(String) >
kafka.api.PlaintextAdminIntegrationTest.testClose(String)[2] STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testClose(String) >
kafka.api.PlaintextAdminIntegrationTest.testClose(String)[2] PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String) >
kafka.api.PlaintextAdminIntegrationTest.testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String)[1]
STARTED
> Task :streams:integrationTest
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldEmitTombstoneWhenDeletingNonJoiningRecords[leftJoin=true,
optimization=all, materialized=true, rejoin=false] PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.joinShouldProduceNullsWhenValueHasNonMatchingForeignKey[leftJoin=true,
optimization=all, materialized=true, rejoin=false] STARTED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
RocksDBMetricsIntegrationTest > [exactly_once] >
org.apache.kafka.streams.integration.RocksDBMetricsIntegrationTest.shouldExposeRocksDBMetricsBeforeAndAfterFailureWithEmptyStateDir[exactly_once]
PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
RocksDBMetricsIntegrationTest > [exactly_once_v2] >
org.apache.kafka.streams.integration.RocksDBMetricsIntegrationTest.shouldExposeRocksDBMetricsBeforeAndAfterFailureWithEmptyStateDir[exactly_once_v2]
STARTED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.joinShouldProduceNullsWhenValueHasNonMatchingForeignKey[leftJoin=true,
optimization=all, materialized=true, rejoin=false] PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.doJoinFromLeftThenDeleteLeftEntity[leftJoin=true,
optimization=all, materialized=true, rejoin=false] STARTED
> Task :core:integrationTest
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String) >
kafka.api.PlaintextAdminIntegrationTest.testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String)[1]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String) >
kafka.api.PlaintextAdminIntegrationTest.testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String)[2]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 180 >
SaslSslAdminIntegrationTest > testAclDescribe() PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 180 >
SaslSslAdminIntegrationTest > testLegacyAclOpsNeverAffectOrReturnPrefixed()
STARTED
> Task :streams:integrationTest
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.doJoinFromLeftThenDeleteLeftEntity[leftJoin=true,
optimization=all, materialized=true, rejoin=false] PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.doJoinFromRightThenDeleteRightEntity[leftJoin=true,
optimization=all, materialized=true, rejoin=false] STARTED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
RocksDBMetricsIntegrationTest > [exactly_once_v2] >
org.apache.kafka.streams.integration.RocksDBMetricsIntegrationTest.shouldExposeRocksDBMetricsBeforeAndAfterFailureWithEmptyStateDir[exactly_once_v2]
PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
SlidingWindowedKStreamIntegrationTest > [ON_WINDOW_UPDATE_cache:true] >
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldAggregateWindowedWithNoGrace[ON_WINDOW_UPDATE_cache:true]
STARTED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=true, rejoin=false] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.doJoinFromRightThenDeleteRightEntity[leftJoin=true,
optimization=all, materialized=true, rejoin=false] PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=false, rejoin=true] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldUnsubscribeOldForeignKeyIfLeftSideIsUpdated[leftJoin=true,
optimization=all, materialized=false, rejoin=true] STARTED
> Task :core:integrationTest
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String) >
kafka.api.PlaintextAdminIntegrationTest.testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords(String)[2]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testDescribeConfigsForLog4jLogLevels(String) >
kafka.api.PlaintextAdminIntegrationTest.testDescribeConfigsForLog4jLogLevels(String)[1]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testDescribeConfigsForLog4jLogLevels(String) >
kafka.api.PlaintextAdminIntegrationTest.testDescribeConfigsForLog4jLogLevels(String)[1]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testDescribeConfigsForLog4jLogLevels(String) >
kafka.api.PlaintextAdminIntegrationTest.testDescribeConfigsForLog4jLogLevels(String)[2]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testDescribeConfigsForLog4jLogLevels(String) >
kafka.api.PlaintextAdminIntegrationTest.testDescribeConfigsForLog4jLogLevels(String)[2]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testMinimumRequestTimeouts(String) >
kafka.api.PlaintextAdminIntegrationTest.testMinimumRequestTimeouts(String)[1]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testMinimumRequestTimeouts(String) >
kafka.api.PlaintextAdminIntegrationTest.testMinimumRequestTimeouts(String)[1]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testMinimumRequestTimeouts(String) >
kafka.api.PlaintextAdminIntegrationTest.testMinimumRequestTimeouts(String)[2]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testMinimumRequestTimeouts(String) >
kafka.api.PlaintextAdminIntegrationTest.testMinimumRequestTimeouts(String)[2]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testIncrementalAlterConfigsDeleteAndSetBrokerConfigs(String) >
kafka.api.PlaintextAdminIntegrationTest.testIncrementalAlterConfigsDeleteAndSetBrokerConfigs(String)[1]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 180 >
SaslSslAdminIntegrationTest > testLegacyAclOpsNeverAffectOrReturnPrefixed()
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 180 >
SaslSslAdminIntegrationTest > testCreateTopicsResponseMetadataAndConfig()
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testIncrementalAlterConfigsDeleteAndSetBrokerConfigs(String) >
kafka.api.PlaintextAdminIntegrationTest.testIncrementalAlterConfigsDeleteAndSetBrokerConfigs(String)[1]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testIncrementalAlterConfigsDeleteAndSetBrokerConfigs(String) >
kafka.api.PlaintextAdminIntegrationTest.testIncrementalAlterConfigsDeleteAndSetBrokerConfigs(String)[2]
STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest >
testIncrementalAlterConfigsDeleteAndSetBrokerConfigs(String) >
kafka.api.PlaintextAdminIntegrationTest.testIncrementalAlterConfigsDeleteAndSetBrokerConfigs(String)[2]
PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testForceClose(String) >
kafka.api.PlaintextAdminIntegrationTest.testForceClose(String)[1] STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testForceClose(String) >
kafka.api.PlaintextAdminIntegrationTest.testForceClose(String)[1] PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testForceClose(String) >
kafka.api.PlaintextAdminIntegrationTest.testForceClose(String)[2] STARTED
> Task :streams:integrationTest
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
SlidingWindowedKStreamIntegrationTest > [ON_WINDOW_UPDATE_cache:true] >
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldAggregateWindowedWithNoGrace[ON_WINDOW_UPDATE_cache:true]
PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
SlidingWindowedKStreamIntegrationTest > [ON_WINDOW_UPDATE_cache:true] >
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldAggregateWindowedWithGrace[ON_WINDOW_UPDATE_cache:true]
STARTED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
SlidingWindowedKStreamIntegrationTest > [ON_WINDOW_UPDATE_cache:true] >
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldAggregateWindowedWithGrace[ON_WINDOW_UPDATE_cache:true]
PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
SlidingWindowedKStreamIntegrationTest > [ON_WINDOW_UPDATE_cache:true] >
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldRestoreAfterJoinRestart[ON_WINDOW_UPDATE_cache:true]
STARTED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=false, rejoin=true] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldUnsubscribeOldForeignKeyIfLeftSideIsUpdated[leftJoin=true,
optimization=all, materialized=false, rejoin=true] PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=false, rejoin=true] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldNotEmitTombstonesWhenDeletingNonExistingRecords[leftJoin=true,
optimization=all, materialized=false, rejoin=true] STARTED
> Task :core:integrationTest
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testForceClose(String) >
kafka.api.PlaintextAdminIntegrationTest.testForceClose(String)[2] PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testListNodes(String) >
kafka.api.PlaintextAdminIntegrationTest.testListNodes(String)[1] STARTED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testListNodes(String) >
kafka.api.PlaintextAdminIntegrationTest.testListNodes(String)[1] PASSED
Gradle Test Run :core:integrationTest > Gradle Test Executor 179 >
PlaintextAdminIntegrationTest > testListNodes(String) >
kafka.api.PlaintextAdminIntegrationTest.testListNodes(String)[2] STARTED
Cancelling nested steps due to timeout
Sending interrupt signal to process
> Task :streams:integrationTest
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=false, rejoin=true] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldNotEmitTombstonesWhenDeletingNonExistingRecords[leftJoin=true,
optimization=all, materialized=false, rejoin=true] PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=false, rejoin=true] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldEmitTombstoneWhenDeletingNonJoiningRecords[leftJoin=true,
optimization=all, materialized=false, rejoin=true] STARTED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
SlidingWindowedKStreamIntegrationTest > [ON_WINDOW_UPDATE_cache:true] >
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldRestoreAfterJoinRestart[ON_WINDOW_UPDATE_cache:true]
PASSED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
SlidingWindowedKStreamIntegrationTest > [ON_WINDOW_UPDATE_cache:false] >
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldAggregateWindowedWithNoGrace[ON_WINDOW_UPDATE_cache:false]
STARTED
> Task :core:integrationTest FAILED
Could not stop
org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@59ec48b5.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message
[MethodInvocation method: stop()].
at
org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:35)
at
org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:32)
at
org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:87)
at
org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:36)
at
org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:71)
at
org.gradle.internal.concurrent.InterruptibleRunnable.run(InterruptibleRunnable.java:42)
at
org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
at
org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64)
at
org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:49)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test
Executor 180' finished with non-zero exit value 143
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/7.6/userguide/java_testing.html#sec:test_execution
at
org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:192)
at
org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
at
org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
at jdk.internal.reflect.GeneratedMethodAccessor394.invoke(Unknown
Source)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:30)
... 10 more
> Task :streams:integrationTest
Could not stop
org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@e752351.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message
[MethodInvocation method: stop()].
at
org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:35)
at
org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:32)
at
org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:87)
at
org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:36)
at
org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:71)
at
org.gradle.internal.concurrent.InterruptibleRunnable.run(InterruptibleRunnable.java:42)
at
org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
at
org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64)
at
org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:49)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test
Executor 181' finished with non-zero exit value 143
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/7.6/userguide/java_testing.html#sec:test_execution
at
org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:192)
at
org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
at
org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
at jdk.internal.reflect.GeneratedMethodAccessor394.invoke(Unknown
Source)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:30)
... 10 more
Gradle Test Run :streams:integrationTest > Gradle Test Executor 181 >
KTableKTableForeignKeyJoinIntegrationTest > [leftJoin=true, optimization=all,
materialized=false, rejoin=true] >
org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest.shouldEmitTombstoneWhenDeletingNonJoiningRecords[leftJoin=true,
optimization=all, materialized=false, rejoin=true] SKIPPED
Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >
SlidingWindowedKStreamIntegrationTest > [ON_WINDOW_UPDATE_cache:false] >
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldAggregateWindowedWithNoGrace[ON_WINDOW_UPDATE_cache:false]
SKIPPED
> Task :streams:integrationTest FAILED
script returned exit code 143
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // timestamps
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
Failed in branch JDK 17 and Scala 2.13
[Pipeline] // parallel
[Pipeline] }
[Pipeline] // stage
[Pipeline] stage
[Pipeline] { (Declarative: Post Actions)
[Pipeline] script
[Pipeline] {
[Pipeline] node
Running on builds42 in /home/jenkins/workspace/Kafka_kafka_3.4
[Pipeline] {
[Pipeline] step
