DirtyDataEntry[jobId='f40f11b5b7019289e69fcf7ad2c27691', jobName='Flink_Job', operatorName='Sink: mysqlsinkfactory', dirtyContent='+I(cip,flinkxtest,6906443267232108544,2022-03-07 11:39:50.0,INSERT,9,Lij,23)', errorMessage='com.dtstack.flinkx.throwable.WriteRecordException: 

JdbcOutputFormat [Flink_Job] writeRecord error: when converting field[0] in Row(+I(cip,flinkxtest,6906443267232108544,2022-03-07 11:39:50.0,INSERT,9,Lij,23))

com.google.common.util.concurrent.UncheckedExecutionException: java.lang.IndexOutOfBoundsException: Index: -1, Size: 3

org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy

  at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:118)

  at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:80)

  at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:233)

  at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:224)

  at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:215)

  at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:666)

  at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:89)

  at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:446)

  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

  at java.lang.reflect.Method.invoke(Method.java:498)

  at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)

  at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)

  at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)

  at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)

  at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)

  at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)

  at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)

  at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)

  at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)

  at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)

  at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)

  at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)

  at akka.actor.Actor.aroundReceive(Actor.scala:517)

  at akka.actor.Actor.aroundReceive$(Actor.scala:515)

  at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)

  at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)

  at akka.actor.ActorCell.invoke(ActorCell.scala:561)

  at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)

  at akka.dispatch.Mailbox.run(Mailbox.scala:225)

  at akka.dispatch.Mailbox.exec(Mailbox.scala:235)

  at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)

  at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)

  at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)

  at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

Caused by: java.util.NoSuchElementException: No value present

  at java.util.Optional.get(Optional.java:135)

  at com.dtstack.flinkx.connector.jdbc.sink.JdbcOutputFormat.prepareTemplates(JdbcOutputFormat.java:329)

  at com.dtstack.flinkx.connector.jdbc.sink.JdbcOutputFormat.buildStmtProxy(JdbcOutputFormat.java:119)

  at com.dtstack.flinkx.connector.jdbc.sink.JdbcOutputFormat.openInternal(JdbcOutputFormat.java:102)

  at com.dtstack.flinkx.sink.format.BaseRichOutputFormat.open(BaseRichOutputFormat.java:229)

  at com.dtstack.flinkx.sink.DtOutputFormatSinkFunction.open(DtOutputFormatSinkFunction.java:95)

  at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)

  at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)

  at org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:63)

  at org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:433)

  at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:545)

  at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93)

  at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:535)

  at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:575)

  at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:758)

  at org.apache.flink.runtime.taskmanager.Task.run(Task.java:573)

  at java.lang.Thread.run(Thread.java:748)