[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22333: - Issue Type: Technical Debt (was: Bug) > Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy > task timeout. > --- > > Key: FLINK-22333 > URL: https://issues.apache.org/jira/browse/FLINK-22333 > Project: Flink > Issue Type: Technical Debt > Components: Runtime / Coordination >Affects Versions: 1.13.0 >Reporter: Guowei Ma >Assignee: Till Rohrmann >Priority: Major > Labels: pull-request-available, test-stability > Fix For: 1.14.0, 1.12.6, 1.13.3 > > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16694=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=03dca39c-73e8-5aaf-601d-328ae5c35f20=12329 > {code:java} > 2021-04-16T23:37:23.5719280Z Apr 16 23:37:23 > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-04-16T23:37:23.5739250Z Apr 16 23:37:23 at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-04-16T23:37:23.5759329Z Apr 16 23:37:23 at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) > 2021-04-16T23:37:23.5779145Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-04-16T23:37:23.5799204Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-04-16T23:37:23.5819302Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5839106Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5859276Z Apr 16 23:37:23 at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-04-16T23:37:23.5868964Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-04-16T23:37:23.5869925Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-04-16T23:37:23.5919839Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5959562Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5989732Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) > 2021-04-16T23:37:23.6019422Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-04-16T23:37:23.6039067Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-04-16T23:37:23.6060126Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-04-16T23:37:23.6089258Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-04-16T23:37:23.6119150Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6139149Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-04-16T23:37:23.6159077Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) > 2021-04-16T23:37:23.6189432Z Apr 16 23:37:23 at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) > 2021-04-16T23:37:23.6215243Z Apr 16 23:37:23 at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) > 2021-04-16T23:37:23.6219148Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-04-16T23:37:23.6220221Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-04-16T23:37:23.6249411Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) > 2021-04-16T23:37:23.6259145Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) > 2021-04-16T23:37:23.6289272Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6309243Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-04-16T23:37:23.6359306Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) > 2021-04-16T23:37:23.6369399Z Apr 16 23:37:23 at >
[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22333: --- Labels: pull-request-available test-stability (was: test-stability) > Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy > task timeout. > --- > > Key: FLINK-22333 > URL: https://issues.apache.org/jira/browse/FLINK-22333 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.13.0 >Reporter: Guowei Ma >Assignee: Till Rohrmann >Priority: Major > Labels: pull-request-available, test-stability > Fix For: 1.14.0, 1.12.6, 1.13.3 > > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16694=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=03dca39c-73e8-5aaf-601d-328ae5c35f20=12329 > {code:java} > 2021-04-16T23:37:23.5719280Z Apr 16 23:37:23 > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-04-16T23:37:23.5739250Z Apr 16 23:37:23 at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-04-16T23:37:23.5759329Z Apr 16 23:37:23 at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) > 2021-04-16T23:37:23.5779145Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-04-16T23:37:23.5799204Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-04-16T23:37:23.5819302Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5839106Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5859276Z Apr 16 23:37:23 at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-04-16T23:37:23.5868964Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-04-16T23:37:23.5869925Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-04-16T23:37:23.5919839Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5959562Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5989732Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) > 2021-04-16T23:37:23.6019422Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-04-16T23:37:23.6039067Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-04-16T23:37:23.6060126Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-04-16T23:37:23.6089258Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-04-16T23:37:23.6119150Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6139149Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-04-16T23:37:23.6159077Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) > 2021-04-16T23:37:23.6189432Z Apr 16 23:37:23 at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) > 2021-04-16T23:37:23.6215243Z Apr 16 23:37:23 at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) > 2021-04-16T23:37:23.6219148Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-04-16T23:37:23.6220221Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-04-16T23:37:23.6249411Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) > 2021-04-16T23:37:23.6259145Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) > 2021-04-16T23:37:23.6289272Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6309243Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-04-16T23:37:23.6359306Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) > 2021-04-16T23:37:23.6369399Z Apr 16 23:37:23 at >
[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22333: -- Fix Version/s: 1.13.3 1.12.6 1.14.0 > Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy > task timeout. > --- > > Key: FLINK-22333 > URL: https://issues.apache.org/jira/browse/FLINK-22333 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.13.0 >Reporter: Guowei Ma >Priority: Major > Labels: test-stability > Fix For: 1.14.0, 1.12.6, 1.13.3 > > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16694=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=03dca39c-73e8-5aaf-601d-328ae5c35f20=12329 > {code:java} > 2021-04-16T23:37:23.5719280Z Apr 16 23:37:23 > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-04-16T23:37:23.5739250Z Apr 16 23:37:23 at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-04-16T23:37:23.5759329Z Apr 16 23:37:23 at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) > 2021-04-16T23:37:23.5779145Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-04-16T23:37:23.5799204Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-04-16T23:37:23.5819302Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5839106Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5859276Z Apr 16 23:37:23 at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-04-16T23:37:23.5868964Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-04-16T23:37:23.5869925Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-04-16T23:37:23.5919839Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5959562Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5989732Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) > 2021-04-16T23:37:23.6019422Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-04-16T23:37:23.6039067Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-04-16T23:37:23.6060126Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-04-16T23:37:23.6089258Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-04-16T23:37:23.6119150Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6139149Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-04-16T23:37:23.6159077Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) > 2021-04-16T23:37:23.6189432Z Apr 16 23:37:23 at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) > 2021-04-16T23:37:23.6215243Z Apr 16 23:37:23 at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) > 2021-04-16T23:37:23.6219148Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-04-16T23:37:23.6220221Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-04-16T23:37:23.6249411Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) > 2021-04-16T23:37:23.6259145Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) > 2021-04-16T23:37:23.6289272Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6309243Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-04-16T23:37:23.6359306Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) > 2021-04-16T23:37:23.6369399Z Apr 16 23:37:23 at >
[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22333: - Labels: test-stability (was: auto-deprioritized-major test-stability) > Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy > task timeout. > --- > > Key: FLINK-22333 > URL: https://issues.apache.org/jira/browse/FLINK-22333 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.13.0 >Reporter: Guowei Ma >Priority: Major > Labels: test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16694=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=03dca39c-73e8-5aaf-601d-328ae5c35f20=12329 > {code:java} > 2021-04-16T23:37:23.5719280Z Apr 16 23:37:23 > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-04-16T23:37:23.5739250Z Apr 16 23:37:23 at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-04-16T23:37:23.5759329Z Apr 16 23:37:23 at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) > 2021-04-16T23:37:23.5779145Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-04-16T23:37:23.5799204Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-04-16T23:37:23.5819302Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5839106Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5859276Z Apr 16 23:37:23 at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-04-16T23:37:23.5868964Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-04-16T23:37:23.5869925Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-04-16T23:37:23.5919839Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5959562Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5989732Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) > 2021-04-16T23:37:23.6019422Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-04-16T23:37:23.6039067Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-04-16T23:37:23.6060126Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-04-16T23:37:23.6089258Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-04-16T23:37:23.6119150Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6139149Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-04-16T23:37:23.6159077Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) > 2021-04-16T23:37:23.6189432Z Apr 16 23:37:23 at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) > 2021-04-16T23:37:23.6215243Z Apr 16 23:37:23 at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) > 2021-04-16T23:37:23.6219148Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-04-16T23:37:23.6220221Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-04-16T23:37:23.6249411Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) > 2021-04-16T23:37:23.6259145Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) > 2021-04-16T23:37:23.6289272Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6309243Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-04-16T23:37:23.6359306Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) > 2021-04-16T23:37:23.6369399Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) > 2021-04-16T23:37:23.6389444Z
[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22333: - Priority: Major (was: Minor) > Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy > task timeout. > --- > > Key: FLINK-22333 > URL: https://issues.apache.org/jira/browse/FLINK-22333 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.13.0 >Reporter: Guowei Ma >Priority: Major > Labels: auto-deprioritized-major, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16694=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=03dca39c-73e8-5aaf-601d-328ae5c35f20=12329 > {code:java} > 2021-04-16T23:37:23.5719280Z Apr 16 23:37:23 > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-04-16T23:37:23.5739250Z Apr 16 23:37:23 at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-04-16T23:37:23.5759329Z Apr 16 23:37:23 at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) > 2021-04-16T23:37:23.5779145Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-04-16T23:37:23.5799204Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-04-16T23:37:23.5819302Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5839106Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5859276Z Apr 16 23:37:23 at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-04-16T23:37:23.5868964Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-04-16T23:37:23.5869925Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-04-16T23:37:23.5919839Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5959562Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5989732Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) > 2021-04-16T23:37:23.6019422Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-04-16T23:37:23.6039067Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-04-16T23:37:23.6060126Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-04-16T23:37:23.6089258Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-04-16T23:37:23.6119150Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6139149Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-04-16T23:37:23.6159077Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) > 2021-04-16T23:37:23.6189432Z Apr 16 23:37:23 at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) > 2021-04-16T23:37:23.6215243Z Apr 16 23:37:23 at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) > 2021-04-16T23:37:23.6219148Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-04-16T23:37:23.6220221Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-04-16T23:37:23.6249411Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) > 2021-04-16T23:37:23.6259145Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) > 2021-04-16T23:37:23.6289272Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6309243Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-04-16T23:37:23.6359306Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) > 2021-04-16T23:37:23.6369399Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) > 2021-04-16T23:37:23.6389444Z Apr 16
[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22333: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability) Priority: Minor (was: Major) This issue was labeled "stale-major" 7 ago and has not received any updates so it is being deprioritized. If this ticket is actually Major, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy > task timeout. > --- > > Key: FLINK-22333 > URL: https://issues.apache.org/jira/browse/FLINK-22333 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.13.0 >Reporter: Guowei Ma >Priority: Minor > Labels: auto-deprioritized-major, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16694=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=03dca39c-73e8-5aaf-601d-328ae5c35f20=12329 > {code:java} > 2021-04-16T23:37:23.5719280Z Apr 16 23:37:23 > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-04-16T23:37:23.5739250Z Apr 16 23:37:23 at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-04-16T23:37:23.5759329Z Apr 16 23:37:23 at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) > 2021-04-16T23:37:23.5779145Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-04-16T23:37:23.5799204Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-04-16T23:37:23.5819302Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5839106Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5859276Z Apr 16 23:37:23 at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-04-16T23:37:23.5868964Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-04-16T23:37:23.5869925Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-04-16T23:37:23.5919839Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5959562Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5989732Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) > 2021-04-16T23:37:23.6019422Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-04-16T23:37:23.6039067Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-04-16T23:37:23.6060126Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-04-16T23:37:23.6089258Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-04-16T23:37:23.6119150Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6139149Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-04-16T23:37:23.6159077Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) > 2021-04-16T23:37:23.6189432Z Apr 16 23:37:23 at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) > 2021-04-16T23:37:23.6215243Z Apr 16 23:37:23 at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) > 2021-04-16T23:37:23.6219148Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-04-16T23:37:23.6220221Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-04-16T23:37:23.6249411Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) > 2021-04-16T23:37:23.6259145Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) > 2021-04-16T23:37:23.6289272Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6309243Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) >
[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22333: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Major but is unassigned and neither itself nor its Sub-Tasks have been updated for 30 days. I have gone ahead and added a "stale-major" to the issue". If this ticket is a Major, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy > task timeout. > --- > > Key: FLINK-22333 > URL: https://issues.apache.org/jira/browse/FLINK-22333 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.13.0 >Reporter: Guowei Ma >Priority: Major > Labels: stale-major, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16694=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=03dca39c-73e8-5aaf-601d-328ae5c35f20=12329 > {code:java} > 2021-04-16T23:37:23.5719280Z Apr 16 23:37:23 > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-04-16T23:37:23.5739250Z Apr 16 23:37:23 at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-04-16T23:37:23.5759329Z Apr 16 23:37:23 at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) > 2021-04-16T23:37:23.5779145Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-04-16T23:37:23.5799204Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-04-16T23:37:23.5819302Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5839106Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5859276Z Apr 16 23:37:23 at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-04-16T23:37:23.5868964Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-04-16T23:37:23.5869925Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-04-16T23:37:23.5919839Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5959562Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5989732Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) > 2021-04-16T23:37:23.6019422Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-04-16T23:37:23.6039067Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-04-16T23:37:23.6060126Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-04-16T23:37:23.6089258Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-04-16T23:37:23.6119150Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6139149Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-04-16T23:37:23.6159077Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) > 2021-04-16T23:37:23.6189432Z Apr 16 23:37:23 at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) > 2021-04-16T23:37:23.6215243Z Apr 16 23:37:23 at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) > 2021-04-16T23:37:23.6219148Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-04-16T23:37:23.6220221Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-04-16T23:37:23.6249411Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) > 2021-04-16T23:37:23.6259145Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) > 2021-04-16T23:37:23.6289272Z Apr 16 23:37:23 at >
[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.
[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22333: -- Summary: Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout. (was: Elasticsearch7DynamicSinkITCase.testWritingDocuments fail due to deploy task timeout.) > Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy > task timeout. > --- > > Key: FLINK-22333 > URL: https://issues.apache.org/jira/browse/FLINK-22333 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.13.0 >Reporter: Guowei Ma >Priority: Major > Labels: test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16694=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=03dca39c-73e8-5aaf-601d-328ae5c35f20=12329 > {code:java} > 2021-04-16T23:37:23.5719280Z Apr 16 23:37:23 > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-04-16T23:37:23.5739250Z Apr 16 23:37:23 at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-04-16T23:37:23.5759329Z Apr 16 23:37:23 at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) > 2021-04-16T23:37:23.5779145Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-04-16T23:37:23.5799204Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-04-16T23:37:23.5819302Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5839106Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5859276Z Apr 16 23:37:23 at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-04-16T23:37:23.5868964Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-04-16T23:37:23.5869925Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-04-16T23:37:23.5919839Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-04-16T23:37:23.5959562Z Apr 16 23:37:23 at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-04-16T23:37:23.5989732Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) > 2021-04-16T23:37:23.6019422Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-04-16T23:37:23.6039067Z Apr 16 23:37:23 at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-04-16T23:37:23.6060126Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-04-16T23:37:23.6089258Z Apr 16 23:37:23 at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-04-16T23:37:23.6119150Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6139149Z Apr 16 23:37:23 at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-04-16T23:37:23.6159077Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) > 2021-04-16T23:37:23.6189432Z Apr 16 23:37:23 at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) > 2021-04-16T23:37:23.6215243Z Apr 16 23:37:23 at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) > 2021-04-16T23:37:23.6219148Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-04-16T23:37:23.6220221Z Apr 16 23:37:23 at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-04-16T23:37:23.6249411Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) > 2021-04-16T23:37:23.6259145Z Apr 16 23:37:23 at > scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) > 2021-04-16T23:37:23.6289272Z Apr 16 23:37:23 at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) > 2021-04-16T23:37:23.6309243Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-04-16T23:37:23.6359306Z Apr 16 23:37:23 at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) > 2021-04-16T23:37:23.6369399Z Apr 16 23:37:23 at >