Yun Gao created FLINK-25449:
-------------------------------
Summary: KafkaSourceITCase.testRedundantParallelism failed on azure
Key: FLINK-25449
URL: https://issues.apache.org/jira/browse/FLINK-25449
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.13.5
Reporter: Yun Gao
{code:java}
Dec 25 00:51:07 [ERROR] Tests run: 5, Failures: 1, Errors: 1, Skipped: 0, Time
elapsed: 88.463 s <<< FAILURE! - in
org.apache.flink.connector.kafka.source.KafkaSourceITCase
Dec 25 00:51:07 [ERROR]
testRedundantParallelism(org.apache.flink.connector.kafka.source.KafkaSourceITCase)
Time elapsed: 4.188 s <<< ERROR!
Dec 25 00:51:07 org.apache.flink.runtime.client.JobExecutionException: Job
execution failed.
Dec 25 00:51:07 at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
Dec 25 00:51:07 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
Dec 25 00:51:07 at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
Dec 25 00:51:07 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
Dec 25 00:51:07 at
org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081)
Dec 25 00:51:07 at akka.dispatch.OnComplete.internal(Future.scala:264)
Dec 25 00:51:07 at akka.dispatch.OnComplete.internal(Future.scala:261)
Dec 25 00:51:07 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
Dec 25 00:51:07 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
Dec 25 00:51:07 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
Dec 25 00:51:07 at
org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73)
Dec 25 00:51:07 at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
Dec 25 00:51:07 at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
Dec 25 00:51:07 at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)
Dec 25 00:51:07 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
Dec 25 00:51:07 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
Dec 25 00:51:07 at
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)
Dec 25 00:51:07 at
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)
Dec 25 00:51:07 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
Dec 25 00:51:07 at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
{code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
