登录
当前位置： 首页 > 工具软件 > Java HeartBeat > 使用案例 >

【flink 报错】Heartbeat of TaskManager is timed out

高朝明
2023-12-01

报错Heartbeat of TaskManager is timed out

java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id container_e219_1670315060312_637295_01_000010(10.203.23.12:8842) timed out.
	at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1420) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.heartbeat.HeartbeatMonitorImpl.run(HeartbeatMonitorImpl.java:111) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_60]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_60]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:440) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:208) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.Actor.aroundReceive(Actor.scala:517) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.Actor.aroundReceive$(Actor.scala:515) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.12-1.12.7.jar:1.12.7]
2022-12-26 19:38:27,518 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Discarding the results produced by task execution 7f3fbe3205ce8e8cc57dce49b695e8ec.
2022-12-26 19:38:27,531 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy [] - Calculating tasks to restart to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_28.
2022-12-26 19:38:27,532 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy [] - 1 tasks should be restarted to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_28. 
2022-12-26 19:38:27,535 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job Flink RI Job (c50c3785ffc128855f286b895fc17562) switched from state RUNNING to RESTARTING.
2022-12-26 19:38:27,539 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: TableSourceScan(table=[[default_catalog, default_database, source]], fields=[raw_message]) -> Calc(select=[(raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mid=([^& \">]*)' REGEXP_EXTRACT 2) AS mid, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)m2=([^& \">]*)' REGEXP_EXTRACT 2) AS m2, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)v=([^& \">]*)' REGEXP_EXTRACT 2) AS v, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)product=([^& \">]*)' REGEXP_EXTRACT 2) AS product, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)combo=([^& \">]*)' REGEXP_EXTRACT 2) AS combo, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)cs=([^& \">]*)' REGEXP_EXTRACT 2) AS cs, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)pa=([^& \">]*)' REGEXP_EXTRACT 2) AS pa, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)pid=([^& \">]*)' REGEXP_EXTRACT 2) AS pid, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sysver=([^& \">]*)' REGEXP_EXTRACT 2) AS sysver, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ver=([^& \">]*)' REGEXP_EXTRACT 2) AS ver, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)lan=([^& \">]*)' REGEXP_EXTRACT 2) AS lan, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)os=([^& \">]*)' REGEXP_EXTRACT 2) AS os, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ch=([^& \">]*)' REGEXP_EXTRACT 2) AS ch, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sch=([^& \">]*)' REGEXP_EXTRACT 2) AS sch, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)a=([^& \">]*)' REGEXP_EXTRACT 2) AS a, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ori_path=([^& \">]*)' REGEXP_EXTRACT 2) AS ori_path, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ba=([^& \">]*)' REGEXP_EXTRACT 2) AS ba, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)spl=([^& \">]*)' REGEXP_EXTRACT 2) AS spl, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)upl=([^& \">]*)' REGEXP_EXTRACT 2) AS upl, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)us=([^& \">]*)' REGEXP_EXTRACT 2) AS us, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)acc=([^& \">]*)' REGEXP_EXTRACT 2) AS acc, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)m=([^& \">]*)' REGEXP_EXTRACT 2) AS m, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)veng=([^& \">]*)' REGEXP_EXTRACT 2) AS veng, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ip=([^& \">]*)' REGEXP_EXTRACT 2) AS ip, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)time=([^& \">]*)' REGEXP_EXTRACT 2) AS time, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)s=([^& \">]*)' REGEXP_EXTRACT 2) AS s, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)np=([^& \">]*)' REGEXP_EXTRACT 2) AS np, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mdcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS mdcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mxcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS mxcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mdfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS mdfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mxfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS mxfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mderrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS mderrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mxerrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS mxerrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)incontime=([^& \">]*)' REGEXP_EXTRACT 2) AS incontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)xjcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS xjcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)infinish=([^& \">]*)' REGEXP_EXTRACT 2) AS infinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)xjfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS xjfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)inerrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS inerrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)xjerrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS xjerrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)rbcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS rbcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)decontime=([^& \">]*)' REGEXP_EXTRACT 2) AS decontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)rbfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS rbfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)definish=([^& \">]*)' REGEXP_EXTRACT 2) AS definish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)rberrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS rberrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)deerrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS deerrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sbcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS sbcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sbfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS sbfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sberrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS sberrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)e=([^& \">]*)' REGEXP_EXTRACT 2) AS e, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)b=([^&\">]*)' REGEXP_EXTRACT 2) AS b, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)d=([^& \">]*)' REGEXP_EXTRACT 2) AS d, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sysdisk=([^& \">]*)' REGEXP_EXTRACT 2) AS sysdisk, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sysfree=([^& \">]*)' REGEXP_EXTRACT 2) AS sysfree, _UTF-16LE'\N' AS country, _UTF-16LE'\N' AS province, _UTF-16LE'\N' AS city, _UTF-16LE'\N' AS operator, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)f=([^& \">]*)' REGEXP_EXTRACT 2) AS f, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)md5=([^& \">]*)' REGEXP_EXTRACT 2) AS md5, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sha1=([^& \">]*)' REGEXP_EXTRACT 2) AS sha1, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)computertype=([^& \">]*)' REGEXP_EXTRACT 2) AS computertype, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)platform=([^& \">]*)' REGEXP_EXTRACT 2) AS platform, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)processors=([^& \">]*)' REGEXP_EXTRACT 2) AS processors, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ram=([^& \">]*)' REGEXP_EXTRACT 2) AS ram, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mfg=([^& \">]*)' REGEXP_EXTRACT 2) AS mfg, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)hddv=([^& \">]*)' REGEXP_EXTRACT 2) AS hddv, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)osser=([^& \">]*)' REGEXP_EXTRACT 2) AS osser, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)iever=([^& \">]*)' REGEXP_EXTRACT 2) AS iever, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)vm=([^& \">]*)' REGEXP_EXTRACT 2) AS vm, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)syssp=([^& \">]*)' REGEXP_EXTRACT 2) AS syssp, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)nb=([^& \">]*)' REGEXP_EXTRACT 2) AS nb]) -> Sink: Sink(table=[default_catalog.default_database.sink], fields=[mid, m2, v, product, combo, cs, pa, pid, sysver, ver, lan, os, ch, sch, a, ori_path, ba, spl, upl, us, acc, m, veng, ip, time, s, np, mdcontime, mxcontime, mdfinish, mxfinish, mderrorcode, mxerrorcode, incontime, xjcontime, infinish, xjfinish, inerrorcode, xjerrorcode, rbcontime, decontime, rbfinish, definish, rberrorcode, deerrorcode, sbcontime, sbfinish, sberrorcode, e, b, d, sysdisk, sysfree, country, province, city, operator, f, md5, sha1, computertype, platform, processors, ram, mfg, hddv, osser, iever, vm, syssp, nb]) (22/1000) (5dd49c63870ade83b22fd73e0b1c7c25) switched from RUNNING to FAILED on container_e219_1670315060312_637295_01_000010 @ 10.203.23.12 (dataPort=17504).
java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id container_e219_1670315060312_637295_01_000010(10.203.23.12:8842) timed out.
	at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1420) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.heartbeat.HeartbeatMonitorImpl.run(HeartbeatMonitorImpl.java:111) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_60]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_60]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:440) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:208) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.Actor.aroundReceive(Actor.scala:517) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.Actor.aroundReceive$(Actor.scala:515) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.12-1.12.7.jar:1.12.7]
2022-12-26 19:38:27,540 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Discarding the results produced by task execution 5dd49c63870ade83b22fd73e0b1c7c25.
2022-12-26 19:38:27,541 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy [] - Calculating tasks to restart to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_21.
2022-12-26 19:38:27,541 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy [] - 1 tasks should be restarted to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_21. 
2022-12-26 19:38:27,541 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: TableSourceScan(table=[[default_catalog, default_database, source]], fields=[raw_message]) -> Calc(select=[(raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mid=([^& \">]*)' REGEXP_EXTRACT 2) AS mid, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)m2=([^& \">]*)' REGEXP_EXTRACT 2) AS m2, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)v=([^& \">]*)' REGEXP_EXTRACT 2) AS v, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)product=([^& \">]*)' REGEXP_EXTRACT 2) AS product, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)combo=([^& \">]*)' REGEXP_EXTRACT 2) AS combo, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)cs=([^& \">]*)' REGEXP_EXTRACT 2) AS cs, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)pa=([^& \">]*)' REGEXP_EXTRACT 2) AS pa, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)pid=([^& \">]*)' REGEXP_EXTRACT 2) AS pid, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sysver=([^& \">]*)' REGEXP_EXTRACT 2) AS sysver, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ver=([^& \">]*)' REGEXP_EXTRACT 2) AS ver, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)lan=([^& \">]*)' REGEXP_EXTRACT 2) AS lan, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)os=([^& \">]*)' REGEXP_EXTRACT 2) AS os, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ch=([^& \">]*)' REGEXP_EXTRACT 2) AS ch, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sch=([^& \">]*)' REGEXP_EXTRACT 2) AS sch, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)a=([^& \">]*)' REGEXP_EXTRACT 2) AS a, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ori_path=([^& \">]*)' REGEXP_EXTRACT 2) AS ori_path, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ba=([^& \">]*)' REGEXP_EXTRACT 2) AS ba, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)spl=([^& \">]*)' REGEXP_EXTRACT 2) AS spl, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)upl=([^& \">]*)' REGEXP_EXTRACT 2) AS upl, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)us=([^& \">]*)' REGEXP_EXTRACT 2) AS us, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)acc=([^& \">]*)' REGEXP_EXTRACT 2) AS acc, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)m=([^& \">]*)' REGEXP_EXTRACT 2) AS m, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)veng=([^& \">]*)' REGEXP_EXTRACT 2) AS veng, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ip=([^& \">]*)' REGEXP_EXTRACT 2) AS ip, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)time=([^& \">]*)' REGEXP_EXTRACT 2) AS time, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)s=([^& \">]*)' REGEXP_EXTRACT 2) AS s, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)np=([^& \">]*)' REGEXP_EXTRACT 2) AS np, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mdcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS mdcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mxcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS mxcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mdfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS mdfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mxfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS mxfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mderrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS mderrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mxerrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS mxerrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)incontime=([^& \">]*)' REGEXP_EXTRACT 2) AS incontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)xjcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS xjcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)infinish=([^& \">]*)' REGEXP_EXTRACT 2) AS infinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)xjfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS xjfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)inerrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS inerrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)xjerrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS xjerrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)rbcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS rbcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)decontime=([^& \">]*)' REGEXP_EXTRACT 2) AS decontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)rbfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS rbfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)definish=([^& \">]*)' REGEXP_EXTRACT 2) AS definish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)rberrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS rberrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)deerrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS deerrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sbcontime=([^& \">]*)' REGEXP_EXTRACT 2) AS sbcontime, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sbfinish=([^& \">]*)' REGEXP_EXTRACT 2) AS sbfinish, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sberrorcode=([^& \">]*)' REGEXP_EXTRACT 2) AS sberrorcode, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)e=([^& \">]*)' REGEXP_EXTRACT 2) AS e, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)b=([^&\">]*)' REGEXP_EXTRACT 2) AS b, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)d=([^& \">]*)' REGEXP_EXTRACT 2) AS d, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sysdisk=([^& \">]*)' REGEXP_EXTRACT 2) AS sysdisk, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sysfree=([^& \">]*)' REGEXP_EXTRACT 2) AS sysfree, _UTF-16LE'\N' AS country, _UTF-16LE'\N' AS province, _UTF-16LE'\N' AS city, _UTF-16LE'\N' AS operator, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)f=([^& \">]*)' REGEXP_EXTRACT 2) AS f, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)md5=([^& \">]*)' REGEXP_EXTRACT 2) AS md5, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)sha1=([^& \">]*)' REGEXP_EXTRACT 2) AS sha1, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)computertype=([^& \">]*)' REGEXP_EXTRACT 2) AS computertype, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)platform=([^& \">]*)' REGEXP_EXTRACT 2) AS platform, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)processors=([^& \">]*)' REGEXP_EXTRACT 2) AS processors, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)ram=([^& \">]*)' REGEXP_EXTRACT 2) AS ram, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)mfg=([^& \">]*)' REGEXP_EXTRACT 2) AS mfg, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)hddv=([^& \">]*)' REGEXP_EXTRACT 2) AS hddv, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)osser=([^& \">]*)' REGEXP_EXTRACT 2) AS osser, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)iever=([^& \">]*)' REGEXP_EXTRACT 2) AS iever, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)vm=([^& \">]*)' REGEXP_EXTRACT 2) AS vm, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)syssp=([^& \">]*)' REGEXP_EXTRACT 2) AS syssp, (raw_message REGEXP_EXTRACT _UTF-16LE'(\?|&|<)nb=([^& \">]*)' REGEXP_EXTRACT 2) AS nb]) -> Sink: Sink(table=[default_catalog.default_database.sink], fields=[mid, m2, v, product, combo, cs, pa, pid, sysver, ver, lan, os, ch, sch, a, ori_path, ba, spl, upl, us, acc, m, veng, ip, time, s, np, mdcontime, mxcontime, mdfinish, mxfinish, mderrorcode, mxerrorcode, incontime, xjcontime, infinish, xjfinish, inerrorcode, xjerrorcode, rbcontime, decontime, rbfinish, definish, rberrorcode, deerrorcode, sbcontime, sbfinish, sberrorcode, e, b, d, sysdisk, sysfree, country, province, city, operator, f, md5, sha1, computertype, platform, processors, ram, mfg, hddv, osser, iever, vm, syssp, nb]) (26/1000) (29e3cc11fe25a6f09f7080add4ca8ed5) switched from RUNNING to FAILED on container_e219_1670315060312_637295_01_000010 @ 10.203.23.12 (dataPort=17504).
java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id container_e219_1670315060312_637295_01_000010(10.203.23.12:8842) timed out.
	at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1420) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.heartbeat.HeartbeatMonitorImpl.run(HeartbeatMonitorImpl.java:111) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_60]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_60]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:440) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:208) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.Actor.aroundReceive(Actor.scala:517) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.Actor.aroundReceive$(Actor.scala:515) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.12-1.12.7.jar:1.12.7]
2022-12-26 19:38:27,542 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Discarding the results produced by task execution 29e3cc11fe25a6f09f7080add4ca8ed5.
2022-12-26 19:38:27,543 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy [] - Calculating tasks to restart to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_25.
2022-12-26 19:38:27,543 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy [] - 1 tasks should be restarted to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_25. 
2022-12-26 19:38:27,550 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job Flink RI Job (c50c3785ffc128855f286b895fc17562) switched from state RESTARTING to FAILING.
org.apache.flink.runtime.JobException: Recovery is suppressed by FailureRateRestartBackoffTimeStrategy(FailureRateRestartBackoffTimeStrategy(failuresIntervalMS=3600000,backoffTimeMS=30000,maxFailuresPerInterval=2)
	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:118) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:80) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:233) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:224) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:215) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:666) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:56) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.executiongraph.ExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(ExecutionGraph.java:1869) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1463) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1403) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.executiongraph.Execution.fail(Execution.java:1081) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.signalPayloadRelease(SingleLogicalSlot.java:213) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.release(SingleLogicalSlot.java:200) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.scheduler.SharedSlot.lambda$release$4(SharedSlot.java:272) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:656) ~[?:1.8.0_60]
	at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:669) ~[?:1.8.0_60]
	at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:1997) ~[?:1.8.0_60]
	at org.apache.flink.runtime.scheduler.SharedSlot.release(SharedSlot.java:272) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.jobmaster.slotpool.AllocatedSlot.releasePayload(AllocatedSlot.java:152) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl.releaseTaskManagerInternal(SlotPoolImpl.java:941) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl.releaseTaskManager(SlotPoolImpl.java:892) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.jobmaster.JobMaster.disconnectTaskManager(JobMaster.java:508) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1416) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.heartbeat.HeartbeatMonitorImpl.run(HeartbeatMonitorImpl.java:111) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_60]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_60]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:440) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:208) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.Actor.aroundReceive(Actor.scala:517) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.Actor.aroundReceive$(Actor.scala:515) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.12-1.12.7.jar:1.12.7]
	at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.12-1.12.7.jar:1.12.7]
Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id container_e219_1670315060312_637295_01_000010(10.203.23.12:8842) timed out.
	at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1420) ~[flink-dist_2.12-1.12.7.jar:1.12.7]
	... 27 more

 
 

解决timeout时长设置大

heartbeat.timeout: 600000
 类似资料：

相关阅读

Android Studio 报错“app:processDebugResources"解决方法Flink中的java.lang.NoSuchMethodError子进程communication（）的“是”报告错误解决mybatis case when 报错的问题maven deploy时报错的解决方法

相关文章

Flink-Sql和Table Api-3Flink-Sql和Table Api-2Flink-Sql和Table Api-1Flink-状态编程-2Flink-状态编程-1

相关问答

Apache Flink错误Java . lang . classnotfoundexceptionFlink可查询状态错误kafka-apache flink执行log4j错误gulp打包报错？vue.js - storybook build 报错？

相关文档

常见 HTTP / FTP / WebSocket 错误代码大全
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.