Flink 报错Ask timed out on [Actor[akka://flink/user/rpc/dispatcher_2#673109285]] after [10000 ms]. Mes

liyongjun6316

978人浏览 · 2024-08-01 11:41:43

liyongjun6316 · 2024-08-01 11:41:43 发布

报错信息：

Exception in thread “main” org.apache.flink.table.api.TableException: Failed to execute sql
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:810)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1223)
at org.apache.flink.table.api.internal.TableImpl.execute(TableImpl.java:577)
at org.caigou._1_cdc_mysql._2.main(_2.java:1159)
Caused by: org.apache.flink.util.FlinkException: Failed to execute job ‘collect’.
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1970)
at org.apache.flink.table.planner.delegation.ExecutorBase.executeAsync(ExecutorBase.java:55)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:793)
… 3 more
Caused by: java.lang.RuntimeException: Error while waiting for job to be initialized
at org.apache.flink.client.ClientUtils.waitUntilJobInitializationFinished(ClientUtils.java:160)
at org.apache.flink.client.program.PerJobMiniClusterFactory.lambda$submitJob $2 (P er J o b M ini Cl u s t er F a c t ory . ja v a : 83) a t or g . a p a c h e . f l ink . u t i l . f u n c t i o n . F u n c t i o n U t i l s . l amb d a$ uncheckedFunction $2 (F u n c t i o n U t i l s . ja v a : 73) a t ja v a . ba se / ja v a . u t i l . co n c u rre n t . C o m pl e t ab l e F u t u re$ UniApply.tryFire(CompletableFuture.java:646)
at java.base/java.util.concurrent.CompletableFuture $C o m pl e t i o n . e x ec (C o m pl e t ab l e F u t u re . ja v a : 483) a t ja v a . ba se / ja v a . u t i l . co n c u rre n t . F or k J o in T a s k . d o E x ec (F or k J o in T a s k . ja v a : 373) a t ja v a . ba se / ja v a . u t i l . co n c u rre n t . F or k J o in P oo l$ WorkQueue.topLevelExec(ForkJoinPool.java:1182)
at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
Caused by: java.util.concurrent.ExecutionException: java.util.concurrent.TimeoutException: Invocation of public default java.util.concurrent.CompletableFuture org.apache.flink.runtime.webmonitor.RestfulGateway.requestJobStatus(org.apache.flink.api.common.JobID,org.apache.flink.api.common.time.Time) timed out.
at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
at org.apache.flink.client.program.PerJobMiniClusterFactory.lambda$null $0 (P er J o b M ini Cl u s t er F a c t ory . ja v a : 89) a t or g . a p a c h e . f l ink . c l i e n t . Cl i e n t U t i l s . w ai t U n t i l J o b I ni t ia l i z a t i o n F ini s h e d (Cl i e n t U t i l s . ja v a : 144) ...9 m ore C a u se d b y : ja v a . u t i l . co n c u rre n t . T im eo u tE x ce pt i o n : I n v oc a t i o n o f p u b l i c d e f a u lt ja v a . u t i l . co n c u rre n t . C o m pl e t ab l e F u t u reor g . a p a c h e . f l ink . r u n t im e . w e bm o ni t or . R es t f u lG a t e w a y . re q u es t J o b St a t u s (or g . a p a c h e . f l ink . a p i . co mm o n . J o b I D, or g . a p a c h e . f l ink . a p i . co mm o n . t im e . T im e) t im e d o u t . a t j d k . p ro x y 2/ j d k . p ro x y 2.$ Proxy175.requestJobStatus(Unknown Source)
at org.apache.flink.runtime.minicluster.MiniCluster.lambda$getJobStatus $6 (M ini Cl u s t er . ja v a : 704) a t ja v a . ba se / ja v a . u t i l . co n c u rre n t . C o m pl e t ab l e F u t u re . u ni A ppl y N o w (C o m pl e t ab l e F u t u re . ja v a : 684) a t ja v a . ba se / ja v a . u t i l . co n c u rre n t . C o m pl e t ab l e F u t u re . u ni A ppl y St a g e (C o m pl e t ab l e F u t u re . ja v a : 662) a t ja v a . ba se / ja v a . u t i l . co n c u rre n t . C o m pl e t ab l e F u t u re . t h e n A ppl y (C o m pl e t ab l e F u t u re . ja v a : 2168) a t or g . a p a c h e . f l ink . r u n t im e . mini c l u s t er . M ini Cl u s t er . r u n D i s p a t c h er C o mman d (M ini Cl u s t er . ja v a : 751) a t or g . a p a c h e . f l ink . r u n t im e . mini c l u s t er . M ini Cl u s t er . g e t J o b St a t u s (M ini Cl u s t er . ja v a : 703) a t or g . a p a c h e . f l ink . c l i e n t . p ro g r am . P er J o b M ini Cl u s t er F a c t ory . l amb d a$ null $KaTeX parse error: Expected 'EOF', got '#' at position 153: \dotspc/dispatcher_2#̲673109285]] aft\dots$ $anonfun $2. a ppl y (A s k S u pp or t . sc a l a : 635) a t akka . p a tt er n . P ro mi se A c t or R e f$ $anonfun $2. a ppl y (A s k S u pp or t . sc a l a : 635) a t akka . p a tt er n . P ro mi se A c t or R e f$ $anonfun $1. a ppl y$ mcV $s p (A s k S u pp or t . sc a l a : 648) a t akka . a c t or . S c h e d u l er$ $anon $4. r u n (S c h e d u l er . sc a l a : 205) a t sc a l a . co n c u rre n t . F u t u re$ InternalCallbackExecutor $. u nba t c h e d E x ec u t e (F u t u re . sc a l a : 601) a t sc a l a . co n c u rre n t . B a t c hin g E x ec u t or$ class.execute(BatchingExecutor.scala:109)
at scala.concurrent.Future $I n t er na lC a ll ba c k E x ec u t or$ .execute(Future.scala:599)
at akka.actor.LightArrayRevolverScheduler $T a s k Ho l d er . e x ec u t e T a s k (L i g h t A rr a y R e v o l v er S c h e d u l er . sc a l a : 328) a t akka . a c t or . L i g h t A rr a y R e v o l v er S c h e d u l er$ $anon$4.executeBucket $1 (L i g h t A rr a y R e v o l v er S c h e d u l er . sc a l a : 279) a t akka . a c t or . L i g h t A rr a y R e v o l v er S c h e d u l er$ $anon $4. n e x tT i c k (L i g h t A rr a y R e v o l v er S c h e d u l er . sc a l a : 283) a t akka . a c t or . L i g h t A rr a y R e v o l v er S c h e d u l er$ $anon$4.run(LightArrayRevolverScheduler.scala:235)
at java.base/java.lang.Thread.run(Thread.java:840)

解决方案：添加2个配置

Configuration conf = new Configuration();
//设置WebUI绑定的本地端口
 conf.setString(RestOptions.BIND_PORT, "8081");
// 设置 akka.ask.timeout 参数为 100s
conf.setString("akka.ask.timeout", "100s");
//创建执行环境
StreamExecutionEnvironment env =
                StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);

天工造物局

北京人形旗下天工造物具身智能开源社区，聚焦具身天工与慧思开物两大平台

更多推荐

LMCache CLI 实战：用 `lmcache kvcache clear` 管理运行中服务的 KV Cache 状态

本文是一份针对 LMCache 官方 CLI 命令 `lmcache kvcache` 的完整技术指南。该命令用于在**运行中的 LMCache 服务（MP HTTP server）**上管理 KV cache 状态，当前提供 `clear` 子命令，用于清空 L1（CPU 内存）层中缓存的全部 KV 数据。读完本文，你将掌握该命令的完整参数体系、退出码语义、终端/JSON/静默三种输出模式，并能

天工造物局

Plate 编辑器降级契约（Degradation Contract）：为虚拟化与 Shell 模式划定原生行为底线

本文围绕 Plate 仓库 `.agents/skills/performance/rules/degradation-contract.md` 中的核心规则展开，说明在编辑器引入虚拟化渲染、Shell 岛屿（shell islands）、模型驱动选择（model-backed selection）或分阶段挂载（staged mounting）等激进性能手段时，如何为每一种降级模式登记完整的行为契

天工造物局

Dozzle 在 Kubernetes 中的部署与配置：实时查看 Pod 日志的完整指南

Dozzle 是一个面向容器的实时日志查看器，原生支持 Docker、Swarm 与 Kubernetes 三种运行环境。本文围绕官方 Kubernetes 支持文档展开，讲解如何通过 `DOZZLE_MODE=k8s` 在集群内以最小权限 RBAC 部署 Dozzle、如何安装并依赖 Kubernetes Metrics API 展示资源用量，以及如何用 `DOZZLE_NAMESPACE` 与