退订
退订
退订
退订
sql-client.sh 终止后, 进程不会被 kill
Hi 各位, 碰到sql-client进程不会被kill, 如下所示 --- Flink SQL> [4]+ Stopped ./bin/sql-client.sh [l3@node1 flink-1.16.0]$ jps 35040 SqlClient 20148 SqlClient 19284 NameNode 19540 GetConf 19733 RunJar 19544 Jps 19497 DataNode 9644 SqlClient 36063 SqlClient --- Best regards AboutMe * Hi, I’m @lllong33 * I’m interested in Flink & dbt & StarRocks
Re: 请问cancel的任务能够恢复running状态吗？
话说我也有个问题，stop后基于savepoint恢复 不同于先savepoint，然后cancel后基于savepoint恢复？ Weihua Hu 于2023年1月5日周四 10:38写道： > > Hi， > > 简单来说是不能，已经 cancel 的 job 状态不能恢复到 running 状态。用 savepoint 恢复的任务是新的 job。 > > 这个问题的背景是什么呢？什么情况下需要将已经 cancel 的 job 恢复呢？ > > > Best, > Weihua > > > On Fri, Dec 30, 2022 at 5:12 PM 陈佳豪 wrote: > > > hi > > 我目前测试flink restapi > > 指定savepointpath来恢复任务发现会重新触发创建一个新的任务原有的任务还是cancel状态，请问有办法恢复原有cancel状态的任务为running吗？
Re: 任务本地运行正常，提交到集群报错 - 图片挂掉，文字贴一下报错信息，非常抱歉打扰
看报错 Could not connect to BlobServer at address localhost/127.0.0.1:33271，你本地的配置是不是不对。提交到什么模式部署的集群，配置是否配对了。 WD.Z 于2023年1月10日周二 10:56写道： > > 任务在webui点击submit时报错，看起来是从JM提交到TM时报错，服务器防火墙已关闭，资源足够，还没有安装hadoop，但以standalone模式启动，看了下文档是不需要hadoop? > 报错中的Caused by列表如下： > > > 2023-01-10 09:46:14,627 INFO > org.apache.flink.client.deployment.application.executors.EmbeddedExecutor [] > - Job e343bc906ea6889d34d9472d40d4f8ff is submitted. > 2023-01-10 09:46:14,627 INFO > org.apache.flink.client.deployment.application.executors.EmbeddedExecutor [] > - Submitting Job with JobId=e343bc906ea6889d34d9472d40d4f8ff. > 2023-01-10 09:46:14,629 WARN > org.apache.flink.client.deployment.application.DetachedApplicationRunner [] - > Could not execute application: > org.apache.flink.client.program.ProgramInvocationException: The main method > caused an error: org.apache.flink.util.FlinkException: Failed to execute job > 'Flink Streaming Job'. > > > Caused by: java.lang.RuntimeException: org.apache.flink.util.FlinkException: > Failed to execute job 'Flink Streaming Job'. > > > Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'Flink > Streaming Job'. > > > Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'Flink > Streaming Job'. > > > Caused by: org.apache.flink.util.FlinkException: Could not upload job files. > > > Caused by: java.io.IOException: Could not connect to BlobServer at address > localhost/127.0.0.1:33271 > > > Caused by: java.net.ConnectException: 拒绝连接 (Connection refused)
