【flink 报错】Heartbeat of TaskManager is timed out

文章目录

报错Heartbeat of TaskManager is timed out
解决timeout时长设置大

报错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

【flink 报错】Heartbeat of TaskManager is timed out相关推荐

【Flink】Flink 报错 Writing records to streamload failed
1.概述 flink报错这个问题是 FLink是高频写入doris导致的
flink报错：The types of the interface org.apache.flink.util.OutputTag could not be inferred.
测试flink报错如下: The types of the interface org.apache.flink.util.OutputTag could not be inferred. Suppo ...
Flink 报错：unable to generate a JAAS configuration file
安装 Flink 报错:unable to generate a JAAS configuration file 原因是Flink的存放临时文件的地方,默认是 tmp/,例如我的是/data/flin ...
【Flink报错】Option not applicable to singleton quantifier
[Flink报错]Option not applicable to singleton quantifier 在使用 Flink CEP greedy 的时候遇到下面的异常. Exception in ...
Flink : Flink JobManager报错 akka.pattern.AskTimeoutException: Ask timed out on
1.美图 2.背景 Flink 1.10 JobManager报错错误信息如下 2020-04-02 14:38:26,867 INFO org.apache.flink.runtime.execu ...
flink报错org.apache.commons.cli.Option.builder
问题复现: yarn-session.sh 完整报错如下: SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found bindi ...
flink报错ByteArraySerializer is not an instance of org.apache.kafka.common.serialization.Serializer
文章目录问题描述报错信息问题解决方式一: 方式二: 问题描述代码如下: public class Sink_KafkaSink_1{public static void main(Strin ...
flink报错：Error: Static methods in interface require -target:jvm-1.8 已解决
一.详细报错 Error:(55, 92) Static methods in interface require -target:jvm-1.8.assignTimestampsAndWaterma ...
【Flink】Flink 报错 Initial AbstractPagedOutputView Segment may not be null
文章目录 1.概述 2.源码分析 1.概述写了一个FLink SQL 报错 Initial AbstractPagedOutputView Segment may not be null 写的SQL ...

【flink 报错】Heartbeat of TaskManager is timed out

文章目录

报错Heartbeat of TaskManager is timed out

解决timeout时长设置大

【flink 报错】Heartbeat of TaskManager is timed out相关推荐

最新文章

热门文章