Yun Gao created FLINK-26111:
-------------------------------
Summary: ElasticsearchSinkITCase.testElasticsearchSink failed on
azure
Key: FLINK-26111
URL: https://issues.apache.org/jira/browse/FLINK-26111
Project: Flink
Issue Type: Bug
Components: Connectors / ElasticSearch
Affects Versions: 1.14.3
Reporter: Yun Gao
{code:java}
2022-02-12T02:31:35.0591708Z Feb 12 02:31:35 [ERROR] testElasticsearchSink
Time elapsed: 32.062 s <<< ERROR!
2022-02-12T02:31:35.0592911Z Feb 12 02:31:35
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-02-12T02:31:35.0594116Z Feb 12 02:31:35 at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-02-12T02:31:35.0595330Z Feb 12 02:31:35 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
2022-02-12T02:31:35.0597985Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-02-12T02:31:35.0598951Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-02-12T02:31:35.0599766Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-02-12T02:31:35.0600573Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-02-12T02:31:35.0601580Z Feb 12 02:31:35 at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258)
2022-02-12T02:31:35.0670936Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-02-12T02:31:35.0672538Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-02-12T02:31:35.0673610Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-02-12T02:31:35.0674648Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-02-12T02:31:35.0675637Z Feb 12 02:31:35 at
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389)
2022-02-12T02:31:35.0676705Z Feb 12 02:31:35 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
2022-02-12T02:31:35.0677921Z Feb 12 02:31:35 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2022-02-12T02:31:35.0679204Z Feb 12 02:31:35 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2022-02-12T02:31:35.0680428Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-02-12T02:31:35.0681685Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-02-12T02:31:35.0682868Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-02-12T02:31:35.0683909Z Feb 12 02:31:35 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-02-12T02:31:35.0684997Z Feb 12 02:31:35 at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
2022-02-12T02:31:35.0686539Z Feb 12 02:31:35 at
akka.dispatch.OnComplete.internal(Future.scala:300)
2022-02-12T02:31:35.0687383Z Feb 12 02:31:35 at
akka.dispatch.OnComplete.internal(Future.scala:297)
2022-02-12T02:31:35.0688214Z Feb 12 02:31:35 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2022-02-12T02:31:35.0689231Z Feb 12 02:31:35 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2022-02-12T02:31:35.0690125Z Feb 12 02:31:35 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-02-12T02:31:35.0691199Z Feb 12 02:31:35 at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2022-02-12T02:31:35.0692578Z Feb 12 02:31:35 at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2022-02-12T02:31:35.0693634Z Feb 12 02:31:35 at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2022-02-12T02:31:35.0694775Z Feb 12 02:31:35 at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2022-02-12T02:31:35.0695856Z Feb 12 02:31:35 at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2022-02-12T02:31:35.0696776Z Feb 12 02:31:35 at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2022-02-12T02:31:35.0697777Z Feb 12 02:31:35 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24)
2022-02-12T02:31:35.0698877Z Feb 12 02:31:35 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2022-02-12T02:31:35.0699876Z Feb 12 02:31:35 at
scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2022-02-12T02:31:35.0700768Z Feb 12 02:31:35 at
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2022-02-12T02:31:35.0701749Z Feb 12 02:31:35 at
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2022-02-12T02:31:35.0702846Z Feb 12 02:31:35 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-02-12T02:31:35.0703850Z Feb 12 02:31:35 at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2022-02-12T02:31:35.0704883Z Feb 12 02:31:35 at
akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2022-02-12T02:31:35.0705898Z Feb 12 02:31:35 at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2022-02-12T02:31:35.0706846Z Feb 12 02:31:35 at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2022-02-12T02:31:35.0707785Z Feb 12 02:31:35 at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2022-02-12T02:31:35.0708688Z Feb 12 02:31:35 at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2022-02-12T02:31:35.0709477Z Feb 12 02:31:35 at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2022-02-12T02:31:35.0710106Z Feb 12 02:31:35 at
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-02-12T02:31:35.0710707Z Feb 12 02:31:35 at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-02-12T02:31:35.0711285Z Feb 12 02:31:35 at
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-02-12T02:31:35.0712163Z Feb 12 02:31:35 at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-02-12T02:31:35.0712962Z Feb 12 02:31:35 Caused by:
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
2022-02-12T02:31:35.0713918Z Feb 12 02:31:35 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
2022-02-12T02:31:35.0714806Z Feb 12 02:31:35 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
2022-02-12T02:31:35.0715572Z Feb 12 02:31:35 at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252)
2022-02-12T02:31:35.0716705Z Feb 12 02:31:35 at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242)
2022-02-12T02:31:35.0717421Z Feb 12 02:31:35 at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233)
2022-02-12T02:31:35.0718126Z Feb 12 02:31:35 at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684)
2022-02-12T02:31:35.0718796Z Feb 12 02:31:35 at
org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79)
2022-02-12T02:31:35.0719442Z Feb 12 02:31:35 at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444)
2022-02-12T02:31:35.0720010Z Feb 12 02:31:35 at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-02-12T02:31:35.0720538Z Feb 12 02:31:35 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-02-12T02:31:35.0721161Z Feb 12 02:31:35 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-02-12T02:31:35.0721823Z Feb 12 02:31:35 at
java.lang.reflect.Method.invoke(Method.java:498)
2022-02-12T02:31:35.0722617Z Feb 12 02:31:35 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316)
2022-02-12T02:31:35.0723624Z Feb 12 02:31:35 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-02-12T02:31:35.0724399Z Feb 12 02:31:35 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314)
2022-02-12T02:31:35.0725046Z Feb 12 02:31:35 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2022-02-12T02:31:35.0725696Z Feb 12 02:31:35 at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2022-02-12T02:31:35.0726354Z Feb 12 02:31:35 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2022-02-12T02:31:35.0727104Z Feb 12 02:31:35 at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-02-12T02:31:35.0727631Z Feb 12 02:31:35 at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-02-12T02:31:35.0728175Z Feb 12 02:31:35 at
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-02-12T02:31:35.0728714Z Feb 12 02:31:35 at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-02-12T02:31:35.0729262Z Feb 12 02:31:35 at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-02-12T02:31:35.0729824Z Feb 12 02:31:35 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-02-12T02:31:35.0730384Z Feb 12 02:31:35 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-02-12T02:31:35.0730942Z Feb 12 02:31:35 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-02-12T02:31:35.0731538Z Feb 12 02:31:35 at
akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-02-12T02:31:35.0732279Z Feb 12 02:31:35 at
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-02-12T02:31:35.0732843Z Feb 12 02:31:35 at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-02-12T02:31:35.0733379Z Feb 12 02:31:35 at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-02-12T02:31:35.0733885Z Feb 12 02:31:35 at
akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-02-12T02:31:35.0734389Z Feb 12 02:31:35 at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-02-12T02:31:35.0734886Z Feb 12 02:31:35 at
akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-02-12T02:31:35.0735347Z Feb 12 02:31:35 at
akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-02-12T02:31:35.0735746Z Feb 12 02:31:35 ... 4 more
2022-02-12T02:31:35.0736192Z Feb 12 02:31:35 Caused by:
java.lang.RuntimeException: An error occurred in ElasticsearchSink.
2022-02-12T02:31:35.0736870Z Feb 12 02:31:35 at
org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkErrorAndRethrow(ElasticsearchSinkBase.java:427)
2022-02-12T02:31:35.0737886Z Feb 12 02:31:35 at
org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkAsyncErrorsAndRequests(ElasticsearchSinkBase.java:432)
2022-02-12T02:31:35.0738665Z Feb 12 02:31:35 at
org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.invoke(ElasticsearchSinkBase.java:329)
2022-02-12T02:31:35.0739353Z Feb 12 02:31:35 at
org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54)
2022-02-12T02:31:35.0740060Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)
2022-02-12T02:31:35.0740821Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)
2022-02-12T02:31:35.0741658Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)
2022-02-12T02:31:35.0742569Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
2022-02-12T02:31:35.0743241Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496)
2022-02-12T02:31:35.0744020Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
2022-02-12T02:31:35.0744730Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)
2022-02-12T02:31:35.0745351Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)
2022-02-12T02:31:35.0745964Z Feb 12 02:31:35 at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
2022-02-12T02:31:35.0746594Z Feb 12 02:31:35 at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
2022-02-12T02:31:35.0747320Z Feb 12 02:31:35 at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
2022-02-12T02:31:35.0747875Z Feb 12 02:31:35 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
2022-02-12T02:31:35.0748366Z Feb 12 02:31:35 at
java.lang.Thread.run(Thread.java:748)
2022-02-12T02:31:35.0748880Z Feb 12 02:31:35 Suppressed:
java.lang.RuntimeException: An error occurred in ElasticsearchSink.
2022-02-12T02:31:35.0749561Z Feb 12 02:31:35 at
org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.checkErrorAndRethrow(ElasticsearchSinkBase.java:427)
2022-02-12T02:31:35.0750336Z Feb 12 02:31:35 at
org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.close(ElasticsearchSinkBase.java:366)
2022-02-12T02:31:35.0751037Z Feb 12 02:31:35 at
org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41)
2022-02-12T02:31:35.0751806Z Feb 12 02:31:35 at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:114)
2022-02-12T02:31:35.0752705Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141)
2022-02-12T02:31:35.0753429Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127)
2022-02-12T02:31:35.0754129Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1035)
2022-02-12T02:31:35.0754800Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:1021)
2022-02-12T02:31:35.0755455Z Feb 12 02:31:35 at
org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:928)
2022-02-12T02:31:35.0756072Z Feb 12 02:31:35 at
org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:940)
2022-02-12T02:31:35.0756695Z Feb 12 02:31:35 at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
2022-02-12T02:31:35.0757493Z Feb 12 02:31:35 at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940)
2022-02-12T02:31:35.0757938Z Feb 12 02:31:35 ... 3 more
2022-02-12T02:31:35.0759078Z Feb 12 02:31:35 Caused by:
[elasticsearch-sink-test-json-index] IndexNotFoundException[no such index]
2022-02-12T02:31:35.0759724Z Feb 12 02:31:35 at
org.elasticsearch.cluster.metadata.IndexNameExpressionResolver.concreteIndices(IndexNameExpressionResolver.java:182)
2022-02-12T02:31:35.0760450Z Feb 12 02:31:35 at
org.elasticsearch.cluster.metadata.IndexNameExpressionResolver.concreteIndices(IndexNameExpressionResolver.java:117)
2022-02-12T02:31:35.0761198Z Feb 12 02:31:35 at
org.elasticsearch.cluster.metadata.IndexNameExpressionResolver.concreteSingleIndex(IndexNameExpressionResolver.java:239)
2022-02-12T02:31:35.0762171Z Feb 12 02:31:35 at
org.elasticsearch.action.bulk.TransportBulkAction$ConcreteIndices.resolveIfAbsent(TransportBulkAction.java:494)
2022-02-12T02:31:35.0762965Z Feb 12 02:31:35 at
org.elasticsearch.action.bulk.TransportBulkAction$BulkOperation.addFailureIfIndexIsUnavailable(TransportBulkAction.java:448)
2022-02-12T02:31:35.0763711Z Feb 12 02:31:35 at
org.elasticsearch.action.bulk.TransportBulkAction$BulkOperation.doRun(TransportBulkAction.java:291)
2022-02-12T02:31:35.0764368Z Feb 12 02:31:35 at
org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
2022-02-12T02:31:35.0765028Z Feb 12 02:31:35 at
org.elasticsearch.action.bulk.TransportBulkAction.executeBulk(TransportBulkAction.java:474)
2022-02-12T02:31:35.0765690Z Feb 12 02:31:35 at
org.elasticsearch.action.bulk.TransportBulkAction$1.onResponse(TransportBulkAction.java:179)
2022-02-12T02:31:35.0766351Z Feb 12 02:31:35 at
org.elasticsearch.action.bulk.TransportBulkAction$1.onResponse(TransportBulkAction.java:175)
2022-02-12T02:31:35.0767001Z Feb 12 02:31:35 at
org.elasticsearch.action.support.TransportAction$1.onResponse(TransportAction.java:88)
2022-02-12T02:31:35.0767649Z Feb 12 02:31:35 at
org.elasticsearch.action.support.TransportAction$1.onResponse(TransportAction.java:84)
2022-02-12T02:31:35.0768376Z Feb 12 02:31:35 at
org.elasticsearch.action.support.master.TransportMasterNodeAction$AsyncSingleAction$1.onResponse(TransportMasterNodeAction.java:149)
2022-02-12T02:31:35.0769190Z Feb 12 02:31:35 at
org.elasticsearch.action.support.master.TransportMasterNodeAction$AsyncSingleAction$1.onResponse(TransportMasterNodeAction.java:146)
2022-02-12T02:31:35.0770006Z Feb 12 02:31:35 at
org.elasticsearch.action.admin.indices.create.TransportCreateIndexAction.lambda$masterOperation$0(TransportCreateIndexAction.java:82)
2022-02-12T02:31:35.0770706Z Feb 12 02:31:35 at
org.elasticsearch.action.ActionListener$1.onResponse(ActionListener.java:59)
2022-02-12T02:31:35.0771459Z Feb 12 02:31:35 at
org.elasticsearch.cluster.metadata.MetaDataCreateIndexService.lambda$createIndex$1(MetaDataCreateIndexService.java:212)
2022-02-12T02:31:35.0772362Z Feb 12 02:31:35 at
org.elasticsearch.action.ActionListener$1.onResponse(ActionListener.java:59)
2022-02-12T02:31:35.0773041Z Feb 12 02:31:35 at
org.elasticsearch.action.support.ContextPreservingActionListener.onResponse(ContextPreservingActionListener.java:43)
2022-02-12T02:31:35.0773748Z Feb 12 02:31:35 at
org.elasticsearch.cluster.AckedClusterStateUpdateTask.onAckTimeout(AckedClusterStateUpdateTask.java:74)
2022-02-12T02:31:35.0774460Z Feb 12 02:31:35 at
org.elasticsearch.cluster.service.ClusterService$SafeAckedClusterStateTaskListener.onAckTimeout(ClusterService.java:1062)
2022-02-12T02:31:35.0775164Z Feb 12 02:31:35 at
org.elasticsearch.cluster.service.ClusterService$AckCountDownListener.onTimeout(ClusterService.java:1318)
2022-02-12T02:31:35.0775848Z Feb 12 02:31:35 at
org.elasticsearch.cluster.service.ClusterService$AckCountDownListener.lambda$new$0(ClusterService.java:1286)
2022-02-12T02:31:35.0776532Z Feb 12 02:31:35 at
org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:569)
2022-02-12T02:31:35.0777337Z Feb 12 02:31:35 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2022-02-12T02:31:35.0777947Z Feb 12 02:31:35 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2022-02-12T02:31:35.0778416Z Feb 12 02:31:35 ... 1 more
2022-02-12T02:31:35.0779188Z Feb 12 02:31:35 Caused by: [CIRCULAR REFERENCE:
[elasticsearch-sink-test-json-index] IndexNotFoundException[no such index]]
2022-02-12T02:31:35.0779661Z Feb 12 02:31:35
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31303&view=logs&j=ba53eb01-1462-56a3-8e98-0dd97fbcaab5&t=2e426bf0-b717-56bb-ab62-d63086457354&l=12465
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
