java.lang.IllegalAccessError: tried to access class io.debezium.embedded.EmbeddedEngineChangeEvent from class com.ververica.cdc.debezium.internal.DebeziumChangeConsumer

[ighack]

2023-07-11 18:02:24,860 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: WMS_ISH_PURCHASE_HDR[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: LMIS_ISH_PURCHASE_HDR[3] (1/1) (2fb4c34ee82620f8517379d34eb99717_cbc357ccb763df2852fee8c4fc7d55f2_0_0) switched from RUNNING to FAILED on container_e90_1680504434553_0301_01_000002 @ bigdser3 (dataPort=32467).
java.lang.IllegalAccessError: tried to access class io.debezium.embedded.EmbeddedEngineChangeEvent from class com.ververica.cdc.debezium.internal.DebeziumChangeConsumer
	at com.ververica.cdc.debezium.internal.DebeziumChangeConsumer.commitOffset(DebeziumChangeConsumer.java:82) ~[flink-connector-debezium-2.2.1.jar:2.2.1]
	at com.ververica.cdc.debezium.DebeziumSourceFunction.notifyCheckpointComplete(DebeziumSourceFunction.java:488) ~[flink-connector-debezium-2.2.1.jar:2.2.1]
	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.notifyCheckpointComplete(AbstractUdfStreamOperator.java:126) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.notifyCheckpointComplete(StreamOperatorWrapper.java:104) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.notifyCheckpointComplete(RegularOperatorChain.java:145) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpoint(SubtaskCheckpointCoordinatorImpl.java:479) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpointComplete(SubtaskCheckpointCoordinatorImpl.java:413) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.notifyCheckpointComplete(StreamTask.java:1412) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointCompleteAsync$15(StreamTask.java:1353) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointOperation$18(StreamTask.java:1392) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:398) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:367) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:352) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:229) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:831) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:780) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:914) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550) ~[flink-dist-1.16.1.jar:1.16.1]
	at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_271]
2023-07-11 18:02:24,892 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Clearing resource requirements of job fefe52a512cee55db512c5d3bb0a9238
2023-07-11 18:02:24,899 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task 2fb4c34ee82620f8517379d34eb99717_cbc357ccb763df2852fee8c4fc7d55f2_0_0.
2023-07-11 18:02:24,899 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job ?????? (fefe52a512cee55db512c5d3bb0a9238) switched from state RUNNING to RESTARTING.
2023-07-11 18:02:24,901 WARN  org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to trigger or complete checkpoint 4 for job fefe52a512cee55db512c5d3bb0a9238. (0 consecutive failed attempts so far)
org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint Coordinator is suspending.
	at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.stopCheckpointScheduler(CheckpointCoordinator.java:1926) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.checkpoint.CheckpointCoordinatorDeActivator.jobStatusChanges(CheckpointCoordinatorDeActivator.java:46) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifyJobStatusChange(DefaultExecutionGraph.java:1566) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.transitionState(DefaultExecutionGraph.java:1161) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.transitionState(DefaultExecutionGraph.java:1133) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.scheduler.SchedulerBase.transitionExecutionGraphState(SchedulerBase.java:571) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.scheduler.DefaultScheduler.addVerticesToRestartPending(DefaultScheduler.java:362) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.scheduler.DefaultScheduler.restartTasksWithDelay(DefaultScheduler.java:334) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeRestartTasks(DefaultScheduler.java:305) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:247) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:240) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:738) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:715) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78) ~[flink-dist-1.16.1.jar:1.16.1]
	at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:477) ~[flink-dist-1.16.1.jar:1.16.1]
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_271]
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_271]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_271]
	at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_271]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:309) ~[flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) ~[flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:307) ~[flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222) ~[flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84) ~[flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168) ~[flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.actor.Actor.aroundReceive(Actor.scala:537) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.actor.Actor.aroundReceive$(Actor.scala:535) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.actor.ActorCell.invoke(ActorCell.scala:548) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.dispatch.Mailbox.run(Mailbox.scala:231) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at akka.dispatch.Mailbox.exec(Mailbox.scala:243) [flink-rpc-akka_d31cf213-bc13-4029-a7a0-7448679955b5.jar:1.16.1]
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_271]
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1067) [?:1.8.0_271]
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1703) [?:1.8.0_271]
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:172) [?:1.8.0_271]
2023-07-11 18:02:25,913 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job ?????? (fefe52a512cee55db512c5d3bb0a9238) switched from state RESTARTING to RUNNING.
2023-07-11 18:02:25,915 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - Restoring job fefe52a512cee55db512c5d3bb0a9238 from Checkpoint 3 @ 1689069736234 for fefe52a512cee55db512c5d3bb0a9238 located at hdfs:/flink/checkpoints/oraclecdc/fefe52a512cee55db512c5d3bb0a9238/chk-3.
2023-07-11 18:02:25,931 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No master state to restore

flink-1.16.1
flink-sql-connector-oracle-cdc-2.2.1.jar
flink-connector-debezium-2.2.1.jar
flink-connector-oracle-cdc-2.2.1.jar