2023-02-20T02:35:33.6571979Z Feb 20 02:35:33 [ERROR] org.apache.flink.tests.util.kafka.KafkaSourceE2ECase.testScaleDown(TestEnvironment, DataStreamSourceExternalContext, CheckpointingMode)[1] Time elapsed: 3.864 s <<< FAILURE!
2023-02-20T02:35:33.6601326Z Feb 20 02:35:33 java.lang.AssertionError:
2023-02-20T02:35:33.6604200Z Feb 20 02:35:33
2023-02-20T02:35:33.6609074Z Feb 20 02:35:33 Expecting
2023-02-20T02:35:33.6609502Z Feb 20 02:35:33 <CompletableFuture[Failed with the following stack trace:
2023-02-20T02:35:33.6612012Z Feb 20 02:35:33 java.lang.RuntimeException: Failed to fetch next result
2023-02-20T02:35:33.6619282Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
2023-02-20T02:35:33.6620147Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
2023-02-20T02:35:33.6623837Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.utils.CollectIteratorAssert.compareWithExactlyOnceSemantic(CollectIteratorAssert.java:116)
2023-02-20T02:35:33.6624650Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.utils.CollectIteratorAssert.matchesRecordsFromSource(CollectIteratorAssert.java:71)
2023-02-20T02:35:33.7035280Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.lambda$checkResultWithSemantic$3(SourceTestSuiteBase.java:739)
2023-02-20T02:35:33.7041843Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
2023-02-20T02:35:33.7048557Z Feb 20 02:35:33 at java.lang.Thread.run(Thread.java:750)
2023-02-20T02:35:33.7052749Z Feb 20 02:35:33 Caused by: java.io.IOException: Failed to fetch job execution result
2023-02-20T02:35:33.7058304Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
2023-02-20T02:35:33.7059262Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
2023-02-20T02:35:33.7060076Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
2023-02-20T02:35:33.7060620Z Feb 20 02:35:33 ... 6 more
2023-02-20T02:35:33.7061345Z Feb 20 02:35:33 Caused by: java.util.concurrent.ExecutionException: org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: deb052f89a69f00f2c8df55054c62136)
2023-02-20T02:35:33.7062049Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2023-02-20T02:35:33.7066005Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2023-02-20T02:35:33.7072200Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
2023-02-20T02:35:33.7077028Z Feb 20 02:35:33 ... 8 more
2023-02-20T02:35:33.7081588Z Feb 20 02:35:33 Caused by: org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: deb052f89a69f00f2c8df55054c62136)
2023-02-20T02:35:33.7088309Z Feb 20 02:35:33 at org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:130)
2023-02-20T02:35:33.7093780Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2023-02-20T02:35:33.7099183Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2023-02-20T02:35:33.7099867Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2023-02-20T02:35:33.7103374Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2023-02-20T02:35:33.7165354Z Feb 20 02:35:33 at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403)
2023-02-20T02:35:33.7171212Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2023-02-20T02:35:33.7175410Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2023-02-20T02:35:33.7180022Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2023-02-20T02:35:33.7184148Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2023-02-20T02:35:33.7185495Z Feb 20 02:35:33 at org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$26(RestClusterClient.java:708)
2023-02-20T02:35:33.7192096Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2023-02-20T02:35:33.7197730Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2023-02-20T02:35:33.7203549Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2023-02-20T02:35:33.7207460Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2023-02-20T02:35:33.7211377Z Feb 20 02:35:33 at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403)
2023-02-20T02:35:33.7216442Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2023-02-20T02:35:33.7217215Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2023-02-20T02:35:33.7221961Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2023-02-20T02:35:33.7226071Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
2023-02-20T02:35:33.7231583Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:943)
2023-02-20T02:35:33.7242894Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
2023-02-20T02:35:33.7248811Z Feb 20 02:35:33 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2023-02-20T02:35:33.7253454Z Feb 20 02:35:33 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2023-02-20T02:35:33.7254177Z Feb 20 02:35:33 ... 1 more
2023-02-20T02:35:33.7258240Z Feb 20 02:35:33 Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2023-02-20T02:35:33.7262591Z Feb 20 02:35:33 at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2023-02-20T02:35:33.7270403Z Feb 20 02:35:33 at org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:128)
2023-02-20T02:35:33.7276023Z Feb 20 02:35:33 ... 24 more
2023-02-20T02:35:33.7279492Z Feb 20 02:35:33 Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
2023-02-20T02:35:33.7280484Z Feb 20 02:35:33 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
2023-02-20T02:35:33.7284357Z Feb 20 02:35:33 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
2023-02-20T02:35:33.7289462Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
2023-02-20T02:35:33.7292875Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
2023-02-20T02:35:33.7299034Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
2023-02-20T02:35:33.7305815Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
2023-02-20T02:35:33.7315490Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78)
2023-02-20T02:35:33.7316250Z Feb 20 02:35:33 at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:443)
2023-02-20T02:35:33.7322640Z Feb 20 02:35:33 at sun.reflect.GeneratedMethodAccessor43.invoke(Unknown Source)
2023-02-20T02:35:33.7324728Z Feb 20 02:35:33 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2023-02-20T02:35:33.7330531Z Feb 20 02:35:33 at java.lang.reflect.Method.invoke(Method.java:498)
2023-02-20T02:35:33.7336350Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2023-02-20T02:35:33.7341911Z Feb 20 02:35:33 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2023-02-20T02:35:33.7357167Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2023-02-20T02:35:33.7359230Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2023-02-20T02:35:33.7363705Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2023-02-20T02:35:33.7370712Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2023-02-20T02:35:33.7375882Z Feb 20 02:35:33 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2023-02-20T02:35:33.7379972Z Feb 20 02:35:33 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2023-02-20T02:35:33.7384918Z Feb 20 02:35:33 at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2023-02-20T02:35:33.7385694Z Feb 20 02:35:33 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2023-02-20T02:35:33.7388858Z Feb 20 02:35:33 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2023-02-20T02:35:33.7393884Z Feb 20 02:35:33 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2023-02-20T02:35:33.7398005Z Feb 20 02:35:33 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-20T02:35:33.7403562Z Feb 20 02:35:33 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-20T02:35:33.7409240Z Feb 20 02:35:33 at akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-02-20T02:35:33.7413825Z Feb 20 02:35:33 at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-02-20T02:35:33.7415974Z Feb 20 02:35:33 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2023-02-20T02:35:33.7418540Z Feb 20 02:35:33 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2023-02-20T02:35:33.7427043Z Feb 20 02:35:33 at akka.actor.ActorCell.invoke(ActorCell.scala:548)
2023-02-20T02:35:33.7432180Z Feb 20 02:35:33 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-02-20T02:35:33.7438071Z Feb 20 02:35:33 at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-02-20T02:35:33.7438998Z Feb 20 02:35:33 at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-02-20T02:35:33.7444284Z Feb 20 02:35:33 at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2023-02-20T02:35:33.7449118Z Feb 20 02:35:33 at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2023-02-20T02:35:33.7467810Z Feb 20 02:35:33 at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2023-02-20T02:35:33.7474847Z Feb 20 02:35:33 at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2023-02-20T02:35:33.7481114Z Feb 20 02:35:33 Caused by: java.lang.RuntimeException: One or more fetchers have encountered exception
2023-02-20T02:35:33.7485476Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:225)
2023-02-20T02:35:33.7486278Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:169)
2023-02-20T02:35:33.7496774Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:130)
2023-02-20T02:35:33.7502745Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:385)
2023-02-20T02:35:33.7518007Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68)
2023-02-20T02:35:33.7563887Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
2023-02-20T02:35:33.7567884Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:519)
2023-02-20T02:35:33.7571624Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
2023-02-20T02:35:33.7572539Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:807)
2023-02-20T02:35:33.7576541Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:756)
2023-02-20T02:35:33.7580076Z Feb 20 02:35:33 at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)
2023-02-20T02:35:33.7585975Z Feb 20 02:35:33 at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
2023-02-20T02:35:33.7590344Z Feb 20 02:35:33 at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)
2023-02-20T02:35:33.7594197Z Feb 20 02:35:33 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
2023-02-20T02:35:33.7598104Z Feb 20 02:35:33 at java.lang.Thread.run(Thread.java:750)
2023-02-20T02:35:33.7598653Z Feb 20 02:35:33 Caused by: java.lang.OutOfMemoryError: Java heap space
2023-02-20T02:35:33.7605912Z Feb 20 02:35:33 at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57)
2023-02-20T02:35:33.7610463Z Feb 20 02:35:33 at java.nio.ByteBuffer.allocate(ByteBuffer.java:335)
2023-02-20T02:35:33.7640707Z Feb 20 02:35:33 at org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30)
2023-02-20T02:35:33.7645540Z Feb 20 02:35:33 at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:113)
2023-02-20T02:35:33.7721460Z Feb 20 02:35:33 at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:452)
2023-02-20T02:35:33.7722379Z Feb 20 02:35:33 at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:402)
2023-02-20T02:35:33.7761361Z Feb 20 02:35:33 at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:674)
2023-02-20T02:35:33.7785499Z Feb 20 02:35:33 at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:576)
2023-02-20T02:35:33.7789413Z Feb 20 02:35:33 at org.apache.kafka.common.network.Selector.poll(Selector.java:481)
2023-02-20T02:35:33.7793849Z Feb 20 02:35:33 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561)
2023-02-20T02:35:33.7798951Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265)
2023-02-20T02:35:33.7799705Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)
2023-02-20T02:35:33.7804180Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:227)
2023-02-20T02:35:33.7808929Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1746)
2023-02-20T02:35:33.7812802Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1704)
2023-02-20T02:35:33.7817983Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.lambda$removeEmptySplits$4(KafkaPartitionSplitReader.java:338)
2023-02-20T02:35:33.7823184Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader$$Lambda$1426/1494823239.get(Unknown Source)
2023-02-20T02:35:33.7827117Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.retryOnWakeup(KafkaPartitionSplitReader.java:439)
2023-02-20T02:35:33.7831473Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.removeEmptySplits(KafkaPartitionSplitReader.java:337)
2023-02-20T02:35:33.7887570Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.handleSplitsChanges(KafkaPartitionSplitReader.java:215)
2023-02-20T02:35:33.7918922Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.fetcher.AddSplitsTask.run(AddSplitsTask.java:51)
2023-02-20T02:35:33.7931450Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142)
2023-02-20T02:35:33.7934964Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105)
2023-02-20T02:35:33.7938991Z Feb 20 02:35:33 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
2023-02-20T02:35:33.7942734Z Feb 20 02:35:33 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
2023-02-20T02:35:33.7947863Z Feb 20 02:35:33 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2023-02-20T02:35:33.7948538Z Feb 20 02:35:33 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2023-02-20T02:35:33.7953567Z Feb 20 02:35:33 ... 1 more
2023-02-20T02:35:33.7960358Z Feb 20 02:35:33 ]>
2023-02-20T02:35:33.7966095Z Feb 20 02:35:33 to be completed within 2M.
2023-02-20T02:35:33.7970270Z Feb 20 02:35:33
2023-02-20T02:35:33.7970867Z Feb 20 02:35:33 exception caught while trying to get the future result: java.util.concurrent.ExecutionException: java.lang.RuntimeException: Failed to fetch next result
2023-02-20T02:35:33.7977783Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2023-02-20T02:35:33.7982225Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2023-02-20T02:35:33.7989134Z Feb 20 02:35:33 at org.assertj.core.internal.Futures.assertSucceededWithin(Futures.java:109)
2023-02-20T02:35:33.7993863Z Feb 20 02:35:33 at org.assertj.core.api.AbstractCompletableFutureAssert.internalSucceedsWithin(AbstractCompletableFutureAssert.java:400)
2023-02-20T02:35:33.8005460Z Feb 20 02:35:33 at org.assertj.core.api.AbstractCompletableFutureAssert.succeedsWithin(AbstractCompletableFutureAssert.java:396)
2023-02-20T02:35:33.8021207Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.checkResultWithSemantic(SourceTestSuiteBase.java:741)
2023-02-20T02:35:33.8022121Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.restartFromSavepoint(SourceTestSuiteBase.java:329)
2023-02-20T02:35:33.8039855Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testScaleDown(SourceTestSuiteBase.java:279)
2023-02-20T02:35:33.8047148Z Feb 20 02:35:33 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2023-02-20T02:35:33.8053834Z Feb 20 02:35:33 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2023-02-20T02:35:33.8057756Z Feb 20 02:35:33 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2023-02-20T02:35:33.8062979Z Feb 20 02:35:33 at java.lang.reflect.Method.invoke(Method.java:498)
2023-02-20T02:35:33.8067430Z Feb 20 02:35:33 at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
2023-02-20T02:35:33.8068205Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2023-02-20T02:35:33.8084092Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2023-02-20T02:35:33.8086430Z Feb 20 02:35:33 at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
2023-02-20T02:35:33.8091529Z Feb 20 02:35:33 at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
2023-02-20T02:35:33.8095711Z Feb 20 02:35:33 at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
2023-02-20T02:35:33.8100200Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
2023-02-20T02:35:33.8105626Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
2023-02-20T02:35:33.8106481Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2023-02-20T02:35:33.8110824Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2023-02-20T02:35:33.8115401Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2023-02-20T02:35:33.8119477Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2023-02-20T02:35:33.8123232Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
2023-02-20T02:35:33.8126522Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
2023-02-20T02:35:33.8131150Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)
2023-02-20T02:35:33.8134609Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8135399Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)
2023-02-20T02:35:33.8139846Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
2023-02-20T02:35:33.8144099Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)
2023-02-20T02:35:33.8148759Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2023-02-20T02:35:33.8153437Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8258078Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2023-02-20T02:35:33.8287534Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2023-02-20T02:35:33.8288428Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2023-02-20T02:35:33.8306752Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8311332Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2023-02-20T02:35:33.8321055Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2023-02-20T02:35:33.8325096Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
2023-02-20T02:35:33.8330535Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
2023-02-20T02:35:33.8335300Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
2023-02-20T02:35:33.8340477Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
2023-02-20T02:35:33.8341206Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
2023-02-20T02:35:33.8341860Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2023-02-20T02:35:33.8342446Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2023-02-20T02:35:33.8344739Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2023-02-20T02:35:33.8345312Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2023-02-20T02:35:33.8350125Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2023-02-20T02:35:33.8350695Z Feb 20 02:35:33 at java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1235)
2023-02-20T02:35:33.8353059Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:647)
2023-02-20T02:35:33.8353637Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2023-02-20T02:35:33.8357250Z Feb 20 02:35:33 at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2023-02-20T02:35:33.8362239Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2023-02-20T02:35:33.8366794Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2023-02-20T02:35:33.8372939Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2023-02-20T02:35:33.8373550Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2023-02-20T02:35:33.8380470Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2023-02-20T02:35:33.8384170Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2023-02-20T02:35:33.8384746Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2023-02-20T02:35:33.8388492Z Feb 20 02:35:33 at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2023-02-20T02:35:33.8394487Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2023-02-20T02:35:33.8396502Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2023-02-20T02:35:33.8398692Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2023-02-20T02:35:33.8402044Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2023-02-20T02:35:33.8404194Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2023-02-20T02:35:33.8404748Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2023-02-20T02:35:33.8407167Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
2023-02-20T02:35:33.8407900Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
2023-02-20T02:35:33.8410326Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2023-02-20T02:35:33.8411062Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8414460Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2023-02-20T02:35:33.8415147Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2023-02-20T02:35:33.8415775Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2023-02-20T02:35:33.8416489Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8417195Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2023-02-20T02:35:33.8421929Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2023-02-20T02:35:33.8422630Z Feb 20 02:35:33 at java.util.ArrayList.forEach(ArrayList.java:1259)
2023-02-20T02:35:33.8425526Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
2023-02-20T02:35:33.8426375Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2023-02-20T02:35:33.8427049Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8430288Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2023-02-20T02:35:33.8430959Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2023-02-20T02:35:33.8431613Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2023-02-20T02:35:33.8432330Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8433030Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2023-02-20T02:35:33.8436589Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2023-02-20T02:35:33.8437309Z Feb 20 02:35:33 at java.util.ArrayList.forEach(ArrayList.java:1259)
2023-02-20T02:35:33.8437966Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
2023-02-20T02:35:33.8438791Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2023-02-20T02:35:33.8439643Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8453519Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2023-02-20T02:35:33.8454213Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2023-02-20T02:35:33.8454878Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2023-02-20T02:35:33.8455596Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8456243Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2023-02-20T02:35:33.8456912Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2023-02-20T02:35:33.8463365Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
2023-02-20T02:35:33.8464211Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
2023-02-20T02:35:33.8464958Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
2023-02-20T02:35:33.8465684Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
2023-02-20T02:35:33.8480449Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
2023-02-20T02:35:33.8481350Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
2023-02-20T02:35:33.8482105Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
2023-02-20T02:35:33.8483031Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
2023-02-20T02:35:33.8483717Z Feb 20 02:35:33 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2023-02-20T02:35:33.8488892Z Feb 20 02:35:33 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2023-02-20T02:35:33.8489606Z Feb 20 02:35:33 at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2023-02-20T02:35:33.8490348Z Feb 20 02:35:33 at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2023-02-20T02:35:33.8491103Z Feb 20 02:35:33 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
2023-02-20T02:35:33.8491796Z Feb 20 02:35:33 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2023-02-20T02:35:33.8495235Z Feb 20 02:35:33 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:128)
2023-02-20T02:35:33.8495922Z Feb 20 02:35:33 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2023-02-20T02:35:33.8496555Z Feb 20 02:35:33 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2023-02-20T02:35:33.8497159Z Feb 20 02:35:33 at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2023-02-20T02:35:33.8499964Z Feb 20 02:35:33 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2023-02-20T02:35:33.8500551Z Feb 20 02:35:33 Caused by: java.lang.RuntimeException: Failed to fetch next result
2023-02-20T02:35:33.8501305Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
2023-02-20T02:35:33.8502083Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
2023-02-20T02:35:33.8502933Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.utils.CollectIteratorAssert.compareWithExactlyOnceSemantic(CollectIteratorAssert.java:116)
2023-02-20T02:35:33.8506223Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.utils.CollectIteratorAssert.matchesRecordsFromSource(CollectIteratorAssert.java:71)
2023-02-20T02:35:33.8507029Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.lambda$checkResultWithSemantic$3(SourceTestSuiteBase.java:739)
2023-02-20T02:35:33.8507751Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
2023-02-20T02:35:33.8508295Z Feb 20 02:35:33 at java.lang.Thread.run(Thread.java:750)
2023-02-20T02:35:33.8508741Z Feb 20 02:35:33 Caused by: java.io.IOException: Failed to fetch job execution result
2023-02-20T02:35:33.8511646Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
2023-02-20T02:35:33.8512406Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
2023-02-20T02:35:33.8515917Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
2023-02-20T02:35:33.8516485Z Feb 20 02:35:33 ... 6 more
2023-02-20T02:35:33.8517057Z Feb 20 02:35:33 Caused by: java.util.concurrent.ExecutionException: org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: deb052f89a69f00f2c8df55054c62136)
2023-02-20T02:35:33.8517782Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2023-02-20T02:35:33.8520857Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2023-02-20T02:35:33.8521702Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
2023-02-20T02:35:33.8522272Z Feb 20 02:35:33 ... 8 more
2023-02-20T02:35:33.8525696Z Feb 20 02:35:33 Caused by: org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: deb052f89a69f00f2c8df55054c62136)
2023-02-20T02:35:33.8526439Z Feb 20 02:35:33 at org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:130)
2023-02-20T02:35:33.8527127Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2023-02-20T02:35:33.8533130Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2023-02-20T02:35:33.8533796Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2023-02-20T02:35:33.8534374Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2023-02-20T02:35:33.8535047Z Feb 20 02:35:33 at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403)
2023-02-20T02:35:33.8540462Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2023-02-20T02:35:33.8541129Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2023-02-20T02:35:33.8541772Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2023-02-20T02:35:33.8546133Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2023-02-20T02:35:33.8546842Z Feb 20 02:35:33 at org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$26(RestClusterClient.java:708)
2023-02-20T02:35:33.8547629Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2023-02-20T02:35:33.8548277Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2023-02-20T02:35:33.8548914Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2023-02-20T02:35:33.8553248Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2023-02-20T02:35:33.8553937Z Feb 20 02:35:33 at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403)
2023-02-20T02:35:33.8554607Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2023-02-20T02:35:33.8558492Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2023-02-20T02:35:33.8559185Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2023-02-20T02:35:33.8559811Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
2023-02-20T02:35:33.8560682Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:943)
2023-02-20T02:35:33.8561396Z Feb 20 02:35:33 at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
2023-02-20T02:35:33.8565571Z Feb 20 02:35:33 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2023-02-20T02:35:33.8566217Z Feb 20 02:35:33 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2023-02-20T02:35:33.8568485Z Feb 20 02:35:33 ... 1 more
2023-02-20T02:35:33.8568955Z Feb 20 02:35:33 Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2023-02-20T02:35:33.8569570Z Feb 20 02:35:33 at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2023-02-20T02:35:33.8573199Z Feb 20 02:35:33 at org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:128)
2023-02-20T02:35:33.8573935Z Feb 20 02:35:33 ... 24 more
2023-02-20T02:35:33.8577229Z Feb 20 02:35:33 Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
2023-02-20T02:35:33.8578006Z Feb 20 02:35:33 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
2023-02-20T02:35:33.8578798Z Feb 20 02:35:33 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
2023-02-20T02:35:33.8579566Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
2023-02-20T02:35:33.8582693Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
2023-02-20T02:35:33.8583446Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
2023-02-20T02:35:33.8584170Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
2023-02-20T02:35:33.8584852Z Feb 20 02:35:33 at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78)
2023-02-20T02:35:33.8587756Z Feb 20 02:35:33 at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:443)
2023-02-20T02:35:33.8588341Z Feb 20 02:35:33 at sun.reflect.GeneratedMethodAccessor43.invoke(Unknown Source)
2023-02-20T02:35:33.8588915Z Feb 20 02:35:33 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2023-02-20T02:35:33.8589496Z Feb 20 02:35:33 at java.lang.reflect.Method.invoke(Method.java:498)
2023-02-20T02:35:33.8590099Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2023-02-20T02:35:33.8594219Z Feb 20 02:35:33 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2023-02-20T02:35:33.8594946Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2023-02-20T02:35:33.8595606Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2023-02-20T02:35:33.8596238Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2023-02-20T02:35:33.8596905Z Feb 20 02:35:33 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2023-02-20T02:35:33.8599678Z Feb 20 02:35:33 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2023-02-20T02:35:33.8600384Z Feb 20 02:35:33 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2023-02-20T02:35:33.8600947Z Feb 20 02:35:33 at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2023-02-20T02:35:33.8601498Z Feb 20 02:35:33 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2023-02-20T02:35:33.8602012Z Feb 20 02:35:33 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2023-02-20T02:35:33.8605347Z Feb 20 02:35:33 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2023-02-20T02:35:33.8605918Z Feb 20 02:35:33 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-20T02:35:33.8606487Z Feb 20 02:35:33 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2023-02-20T02:35:33.8607025Z Feb 20 02:35:33 at akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-02-20T02:35:33.8609612Z Feb 20 02:35:33 at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-02-20T02:35:33.8610126Z Feb 20 02:35:33 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2023-02-20T02:35:33.8610686Z Feb 20 02:35:33 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2023-02-20T02:35:33.8611205Z Feb 20 02:35:33 at akka.actor.ActorCell.invoke(ActorCell.scala:548)
2023-02-20T02:35:33.8611913Z Feb 20 02:35:33 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-02-20T02:35:33.8615550Z Feb 20 02:35:33 at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-02-20T02:35:33.8616048Z Feb 20 02:35:33 at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-02-20T02:35:33.8616534Z Feb 20 02:35:33 at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2023-02-20T02:35:33.8617120Z Feb 20 02:35:33 at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2023-02-20T02:35:33.8617704Z Feb 20 02:35:33 at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2023-02-20T02:35:33.8621123Z Feb 20 02:35:33 at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2023-02-20T02:35:33.8621710Z Feb 20 02:35:33 Caused by: java.lang.RuntimeException: One or more fetchers have encountered exception
2023-02-20T02:35:33.8622378Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:225)
2023-02-20T02:35:33.8623118Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:169)
2023-02-20T02:35:33.8623783Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:130)
2023-02-20T02:35:33.8628484Z Feb 20 02:35:33 at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:385)
2023-02-20T02:35:33.8629161Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68)
2023-02-20T02:35:33.8629869Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
2023-02-20T02:35:33.8630557Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:519)
2023-02-20T02:35:33.8633587Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
2023-02-20T02:35:33.8634401Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:807)
2023-02-20T02:35:33.8634994Z Feb 20 02:35:33 at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:756)
2023-02-20T02:35:33.8635625Z Feb 20 02:35:33 at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)
2023-02-20T02:35:33.8636244Z Feb 20 02:35:33 at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
2023-02-20T02:35:33.8640770Z Feb 20 02:35:33 at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)
2023-02-20T02:35:33.8641348Z Feb 20 02:35:33 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
2023-02-20T02:35:33.8641850Z Feb 20 02:35:33 at java.lang.Thread.run(Thread.java:750)
2023-02-20T02:35:33.8642276Z Feb 20 02:35:33 Caused by: java.lang.OutOfMemoryError: Java heap space
2023-02-20T02:35:33.8681059Z Feb 20 02:35:33 at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57)
2023-02-20T02:35:33.8681610Z Feb 20 02:35:33 at java.nio.ByteBuffer.allocate(ByteBuffer.java:335)
2023-02-20T02:35:33.8682175Z Feb 20 02:35:33 at org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30)
2023-02-20T02:35:33.8685445Z Feb 20 02:35:33 at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:113)
2023-02-20T02:35:33.8686093Z Feb 20 02:35:33 at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:452)
2023-02-20T02:35:33.8686662Z Feb 20 02:35:33 at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:402)
2023-02-20T02:35:33.8687259Z Feb 20 02:35:33 at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:674)
2023-02-20T02:35:33.8687866Z Feb 20 02:35:33 at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:576)
2023-02-20T02:35:33.8691297Z Feb 20 02:35:33 at org.apache.kafka.common.network.Selector.poll(Selector.java:481)
2023-02-20T02:35:33.8692048Z Feb 20 02:35:33 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561)
2023-02-20T02:35:33.8692690Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265)
2023-02-20T02:35:33.8693406Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)
2023-02-20T02:35:33.8694070Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:227)
2023-02-20T02:35:33.8697040Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1746)
2023-02-20T02:35:33.8697676Z Feb 20 02:35:33 at org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1704)
2023-02-20T02:35:33.8698417Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.lambda$removeEmptySplits$4(KafkaPartitionSplitReader.java:338)
2023-02-20T02:35:33.8699179Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader$$Lambda$1426/1494823239.get(Unknown Source)
2023-02-20T02:35:33.8704983Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.retryOnWakeup(KafkaPartitionSplitReader.java:439)
2023-02-20T02:35:33.8707504Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.removeEmptySplits(KafkaPartitionSplitReader.java:337)
2023-02-20T02:35:33.8708303Z Feb 20 02:35:33 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.handleSplitsChanges(KafkaPartitionSplitReader.java:215)
2023-02-20T02:35:33.8712760Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.fetcher.AddSplitsTask.run(AddSplitsTask.java:51)
2023-02-20T02:35:33.8713580Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142)
2023-02-20T02:35:33.8716986Z Feb 20 02:35:33 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105)
2023-02-20T02:35:33.8719588Z Feb 20 02:35:33 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
2023-02-20T02:35:33.8722985Z Feb 20 02:35:33 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
2023-02-20T02:35:33.8723587Z Feb 20 02:35:33 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2023-02-20T02:35:33.8724163Z Feb 20 02:35:33 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2023-02-20T02:35:33.8727430Z Feb 20 02:35:33 ... 1 more
2023-02-20T02:35:33.8727747Z Feb 20 02:35:33
2023-02-20T02:35:33.8728294Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.checkResultWithSemantic(SourceTestSuiteBase.java:741)
2023-02-20T02:35:33.8729099Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.restartFromSavepoint(SourceTestSuiteBase.java:329)
2023-02-20T02:35:33.8732079Z Feb 20 02:35:33 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testScaleDown(SourceTestSuiteBase.java:279)
2023-02-20T02:35:33.8732680Z Feb 20 02:35:33 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2023-02-20T02:35:33.8733247Z Feb 20 02:35:33 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2023-02-20T02:35:33.8733957Z Feb 20 02:35:33 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2023-02-20T02:35:33.8734617Z Feb 20 02:35:33 at java.lang.reflect.Method.invoke(Method.java:498)
2023-02-20T02:35:33.8738501Z Feb 20 02:35:33 at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
2023-02-20T02:35:33.8739162Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2023-02-20T02:35:33.8739904Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2023-02-20T02:35:33.8740745Z Feb 20 02:35:33 at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
2023-02-20T02:35:33.8741428Z Feb 20 02:35:33 at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
2023-02-20T02:35:33.8744395Z Feb 20 02:35:33 at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
2023-02-20T02:35:33.8745162Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
2023-02-20T02:35:33.8745922Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
2023-02-20T02:35:33.8746676Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2023-02-20T02:35:33.8749636Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2023-02-20T02:35:33.8750397Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2023-02-20T02:35:33.8751085Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2023-02-20T02:35:33.8753946Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
2023-02-20T02:35:33.8754600Z Feb 20 02:35:33 at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
2023-02-20T02:35:33.8755317Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)
2023-02-20T02:35:33.8756148Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8759894Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)
2023-02-20T02:35:33.8760846Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
2023-02-20T02:35:33.8761514Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)
2023-02-20T02:35:33.8762229Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2023-02-20T02:35:33.8762946Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8766342Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2023-02-20T02:35:33.8767027Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2023-02-20T02:35:33.8767698Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2023-02-20T02:35:33.8768396Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8769052Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2023-02-20T02:35:33.8769698Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2023-02-20T02:35:33.8773694Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
2023-02-20T02:35:33.8774527Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
2023-02-20T02:35:33.8775414Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
2023-02-20T02:35:33.8776162Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
2023-02-20T02:35:33.8779002Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
2023-02-20T02:35:33.8779702Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2023-02-20T02:35:33.8780254Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2023-02-20T02:35:33.8780856Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2023-02-20T02:35:33.8781459Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2023-02-20T02:35:33.8785484Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2023-02-20T02:35:33.8786089Z Feb 20 02:35:33 at java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1235)
2023-02-20T02:35:33.8786751Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:647)
2023-02-20T02:35:33.8787311Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2023-02-20T02:35:33.8787915Z Feb 20 02:35:33 at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2023-02-20T02:35:33.8790592Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2023-02-20T02:35:33.8791199Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2023-02-20T02:35:33.8791895Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2023-02-20T02:35:33.8792520Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2023-02-20T02:35:33.8797120Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2023-02-20T02:35:33.8797677Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2023-02-20T02:35:33.8798269Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2023-02-20T02:35:33.8798876Z Feb 20 02:35:33 at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2023-02-20T02:35:33.8799476Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2023-02-20T02:35:33.8811653Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2023-02-20T02:35:33.8812316Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2023-02-20T02:35:33.8812912Z Feb 20 02:35:33 at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2023-02-20T02:35:33.8813523Z Feb 20 02:35:33 at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2023-02-20T02:35:33.8814115Z Feb 20 02:35:33 at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2023-02-20T02:35:33.8819568Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
2023-02-20T02:35:33.8820298Z Feb 20 02:35:33 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
2023-02-20T02:35:33.8821033Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2023-02-20T02:35:33.8821753Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8822438Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2023-02-20T02:35:33.8825202Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2023-02-20T02:35:33.8825874Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2023-02-20T02:35:33.8826582Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8827268Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2023-02-20T02:35:33.8827949Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2023-02-20T02:35:33.8828521Z Feb 20 02:35:33 at java.util.ArrayList.forEach(ArrayList.java:1259)
2023-02-20T02:35:33.8829189Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
2023-02-20T02:35:33.8832902Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2023-02-20T02:35:33.8833624Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8834336Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2023-02-20T02:35:33.8835001Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2023-02-20T02:35:33.8837220Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2023-02-20T02:35:33.8837950Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8838717Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2023-02-20T02:35:33.8839353Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2023-02-20T02:35:33.8843500Z Feb 20 02:35:33 at java.util.ArrayList.forEach(ArrayList.java:1259)
2023-02-20T02:35:33.8844217Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
2023-02-20T02:35:33.8849137Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2023-02-20T02:35:33.8849858Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8850652Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2023-02-20T02:35:33.8851320Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2023-02-20T02:35:33.8851946Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2023-02-20T02:35:33.8854746Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2023-02-20T02:35:33.8855444Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2023-02-20T02:35:33.8856119Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2023-02-20T02:35:33.8856894Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
2023-02-20T02:35:33.8860669Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
2023-02-20T02:35:33.8861538Z Feb 20 02:35:33 at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
2023-02-20T02:35:33.8862262Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
2023-02-20T02:35:33.8862931Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
2023-02-20T02:35:33.8863672Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
2023-02-20T02:35:33.8864433Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
2023-02-20T02:35:33.8868534Z Feb 20 02:35:33 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
2023-02-20T02:35:33.8869224Z Feb 20 02:35:33 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2023-02-20T02:35:33.8871773Z Feb 20 02:35:33 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2023-02-20T02:35:33.8872481Z Feb 20 02:35:33 at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2023-02-20T02:35:33.8873163Z Feb 20 02:35:33 at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2023-02-20T02:35:33.8876179Z Feb 20 02:35:33 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
2023-02-20T02:35:33.8876898Z Feb 20 02:35:33 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2023-02-20T02:35:33.8877701Z Feb 20 02:35:33 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:128)
2023-02-20T02:35:33.8878383Z Feb 20 02:35:33 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2023-02-20T02:35:33.8894343Z Feb 20 02:35:33 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2023-02-20T02:35:33.8895004Z Feb 20 02:35:33 at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2023-02-20T02:35:33.8895569Z Feb 20 02:35:33 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
Bug
Major