stanb commented on PR #38:
URL:
https://github.com/apache/flink-connector-opensearch/pull/38#issuecomment-2124753448
With this jar i get another error:
```
2024-05-22 15:57:26
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:176)
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:107)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:285)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:276)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:269)
at
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:764)
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:741)
at
org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:83)
at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:488)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown
Source)
at java.base/java.lang.reflect.Method.invoke(Unknown Source)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:309)
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:307)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:222)
at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:85)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:168)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:280)
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:241)
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:253)
at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown
Source)
at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source)
at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source)
at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown
Source)
Caused by: java.lang.ExceptionInInitializerError
at
org.apache.flink.opensearch2.shaded.org.opensearch.transport.RemoteClusterService.lambda$static$1(RemoteClusterService.java:123)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting.affixKeySetting(Setting.java:2837)
at
org.apache.flink.opensearch2.shaded.org.opensearch.transport.RemoteClusterService.<clinit>(RemoteClusterService.java:120)
at
org.apache.flink.opensearch2.shaded.org.opensearch.node.Node.<clinit>(Node.java:318)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.util.concurrent.OpenSearchExecutors.threadName(OpenSearchExecutors.java:361)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.util.concurrent.OpenSearchExecutors.daemonThreadFactory(OpenSearchExecutors.java:375)
at
org.apache.flink.opensearch2.shaded.org.opensearch.threadpool.Scheduler.initScheduler(Scheduler.java:73)
at
org.apache.flink.opensearch2.shaded.org.opensearch.action.bulk.BulkProcessor.builder(BulkProcessor.java:263)
at
org.apache.flink.connector.opensearch.sink.Opensearch2Writer.createBulkProcessor(Opensearch2Writer.java:166)
at
org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(Opensearch2Writer.java:113)
at
org.apache.flink.connector.opensearch.sink.Opensearch2Sink.createWriter(Opensearch2Sink.java:95)
at
org.apache.flink.streaming.runtime.operators.sink.StatelessSinkWriterStateHandler.createWriter(StatelessSinkWriterStateHandler.java:39)
at
org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.initializeState(SinkWriterOperator.java:149)
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.initializeOperatorState(StreamOperatorStateHandler.java:122)
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:274)
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:106)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:753)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:728)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:693)
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:953)
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:922)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:746)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
at java.base/java.lang.Thread.run(Unknown Source)
Caused by: java.lang.NullPointerException
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting.arrayToParsableString(Setting.java:2373)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting$ListSetting.lambda$new$0(Setting.java:2405)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting$ListSetting.innerGetRaw(Setting.java:2416)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting.getRaw(Setting.java:549)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting.lambda$listSetting$37(Setting.java:2300)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting.listSetting(Setting.java:2340)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting.listSetting(Setting.java:2329)
at
org.apache.flink.opensearch2.shaded.org.opensearch.common.settings.Setting.listSetting(Setting.java:2300)
at
org.apache.flink.opensearch2.shaded.org.opensearch.transport.TransportSettings.<clinit>(TransportSettings.java:68)
... 25 more
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
