1??????????yarn-session??????????????
2??????yarn-perjob?????????????????? --????
??????????????????????????????????????????????????????
Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager with
id container_e66_1616483562588_2358_01_000002(XXXX) timed out.
at
org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1378)
~[flink-dist_2.11-1.12.1.jar:1.12.1]
at
org.apache.flink.runtime.heartbeat.HeartbeatMonitorImpl.run(HeartbeatMonitorImpl.java:111)
~[flink-dist_2.11-1.12.1.jar:1.12.1]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_151]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_151]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:442)
~[flink-dist_2.11-1.12.1.jar:1.12.1]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:209)
~[flink-dist_2.11-1.12.1.jar:1.12.1]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
~[flink-dist_2.11-1.12.1.jar:1.12.1]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:159)
~[flink-dist_2.11-1.12.1.jar:1.12.1]
3??flink-session ???????? nohup bin/yarn-session.sh -jm 1024 -tm
1024 -s 2 -qu root.CBT -d & ????????????
4????????????yarn-perjob??????????????????????FLINK-CDC??sql??????????flink-per
-job????????????????????????????????????
