[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402598#comment-17402598 ] Till Rohrmann commented on FLINK-21538: --- For the 2) point I've created FLINK-23906. > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1, 1.13.0 >Reporter: Dawid Wysakowicz >Assignee: Till Rohrmann >Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned, > 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=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9609252Z at > akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) > 2021-02-27T00:16:06.9610024Z at > scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402592#comment-17402592 ] Till Rohrmann commented on FLINK-21538: --- Looking at this test failure two things are interesting: 1) The tests don't configure a parallelism. That's why we run a job with a parallelism of 32. This slows down the execution. 2) The execution is not super fast on the CI infrastructure. That's why we run into the 10s {{akka.ask.timeout}}. I would suggest two things: 1) Configuring a lower parallelism to reduce the complexity of the test. 2) Set a higher default {{akka.ask.timeout}} when using the {{MiniCluster}}. This should also solve a lot of other test instabilities that are caused by timeouts due to slow CI infrastructure. > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1, 1.13.0 >Reporter: Dawid Wysakowicz >Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 202
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391875#comment-17391875 ] Xintong Song commented on FLINK-21538: -- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=21331&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=03dca39c-73e8-5aaf-601d-328ae5c35f20&l=12136 > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1, 1.13.0 >Reporter: Dawid Wysakowicz >Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9609252Z at > akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) > 2021-02-27T00:16:06.9610024Z at > scala.runtime.java8.JFunction0$mcV$sp.apply(J
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17390387#comment-17390387 ] Dawid Wysakowicz commented on FLINK-21538: -- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=21181&view=logs&j=ba53eb01-1462-56a3-8e98-0dd97fbcaab5&t=bfbc6239-57a0-5db0-63f3-41551b4f7d51&l=12520 > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1, 1.13.0 >Reporter: Dawid Wysakowicz >Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9609252Z at > akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) > 2021-02-27T00:16:06.9610024Z at > scala.runtime.java8.JFunction0$mcV$sp
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385950#comment-17385950 ] Dawid Wysakowicz commented on FLINK-21538: -- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=20852&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=34f486e1-e1e4-5dd2-9c06-bfdd9b9c74a8&l=12108 > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1, 1.13.0 >Reporter: Dawid Wysakowicz >Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9609252Z at > akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) > 2021-02-27T00:16:06.9610024Z at > scala.runtime.java8.JFunction0$mcV$s
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17338176#comment-17338176 ] Guowei Ma commented on FLINK-21538: --- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=17476&view=logs&j=961f8f81-6b52-53df-09f6-7291a2e4af6a&t=60581941-0138-53c0-39fe-86d62be5f407&l=11818 > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1, 1.13.0 >Reporter: Dawid Wysakowicz >Priority: Major > Labels: stale-assigned, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9609252Z at > akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) > 2021-02-27T00:16:06.9610024Z at > scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) > 2021-
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17338172#comment-17338172 ] Guowei Ma commented on FLINK-21538: --- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=17477&view=logs&j=ba53eb01-1462-56a3-8e98-0dd97fbcaab5&t=bfbc6239-57a0-5db0-63f3-41551b4f7d51&l=12390 > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1, 1.13.0 >Reporter: Dawid Wysakowicz >Priority: Major > Labels: stale-assigned, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9609252Z at > akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) > 2021-02-27T00:16:06.9610024Z at > scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) > 2021-
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331137#comment-17331137 ] Guowei Ma commented on FLINK-21538: --- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=17129&view=logs&j=c91190b6-40ae-57b2-5999-31b869b0a7c1&t=43529380-51b4-5e90-5af4-2dccec0ef402&l=11878 > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1, 1.13.0 >Reporter: Dawid Wysakowicz >Priority: Major > Labels: stale-assigned, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9609252Z at > akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) > 2021-02-27T00:16:06.9610024Z at > scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) > 2021-
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324619#comment-17324619 ] Flink Jira Bot commented on FLINK-21538: This issue is assigned but has not received an update in 7 days so it has been labeled "stale-assigned". If you are still working on the issue, please give an update and remove the label. If you are no longer working on the issue, please unassign so someone else may work on it. In 7 days the issue will be automatically unassigned. > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1, 1.13.0 >Reporter: Dawid Wysakowicz >Assignee: Austin Cawley-Edwards >Priority: Major > Labels: stale-assigned, test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318659#comment-17318659 ] Guowei Ma commented on FLINK-21538: --- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16308&view=logs&j=ba53eb01-1462-56a3-8e98-0dd97fbcaab5&t=bfbc6239-57a0-5db0-63f3-41551b4f7d51&l=12338 > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1 >Reporter: Dawid Wysakowicz >Assignee: Austin Cawley-Edwards >Priority: Major > Labels: test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9609252Z at > akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) > 2021-02-27T00:16:06.9610024Z at > scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mc
[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300636#comment-17300636 ] Austin Cawley-Edwards commented on FLINK-21538: --- Test debug build here: https://dev.azure.com/austincawley0684/flink/_build/results?buildId=3&view=results > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job > -- > > Key: FLINK-21538 > URL: https://issues.apache.org/jira/browse/FLINK-21538 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch, Runtime / Coordination >Affects Versions: 1.12.1 >Reporter: Dawid Wysakowicz >Priority: Major > Labels: test-stability > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13868&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=5d6e4255-0ea8-5e2a-f52c-c881b7872361 > {code} > 2021-02-27T00:16:06.9493539Z > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2021-02-27T00:16:06.9494494Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > 2021-02-27T00:16:06.9495733Z at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:117) > 2021-02-27T00:16:06.9496596Z at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > 2021-02-27T00:16:06.9497354Z at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) > 2021-02-27T00:16:06.9525795Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9526744Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9527784Z at > org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) > 2021-02-27T00:16:06.9528552Z at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > 2021-02-27T00:16:06.9529271Z at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > 2021-02-27T00:16:06.9530013Z at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) > 2021-02-27T00:16:06.9530482Z at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) > 2021-02-27T00:16:06.9531068Z at > org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1046) > 2021-02-27T00:16:06.9531544Z at > akka.dispatch.OnComplete.internal(Future.scala:264) > 2021-02-27T00:16:06.9531908Z at > akka.dispatch.OnComplete.internal(Future.scala:261) > 2021-02-27T00:16:06.9532449Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) > 2021-02-27T00:16:06.9532860Z at > akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) > 2021-02-27T00:16:06.9533245Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9533721Z at > org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) > 2021-02-27T00:16:06.9534225Z at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > 2021-02-27T00:16:06.9534697Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) > 2021-02-27T00:16:06.9535217Z at > scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) > 2021-02-27T00:16:06.9535718Z at > scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > 2021-02-27T00:16:06.9536127Z at > akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > 2021-02-27T00:16:06.9536861Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) > 2021-02-27T00:16:06.9537394Z at > akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) > 2021-02-27T00:16:06.9537916Z at > scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) > 2021-02-27T00:16:06.9605804Z at > scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) > 2021-02-27T00:16:06.9606794Z at > scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) > 2021-02-27T00:16:06.9607642Z at > scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > 2021-02-27T00:16:06.9608419Z at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > 2021-02-27T00:16:06.9609252Z at > akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) > 2021-02-27T00:16:06.9610024Z at > scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) > 2021-02-27T00:16:06.9613676Z at > scala.concurrent.BlockContext$.with