问答 2023-08-28 来自:开发者社区

Flink sql-client提交的sql任务能写到sink表,通过flink ?

Flink sql-client提交的sql任务能写到sink表,通过flink sql-gateway提交的sql任务写不进去,有人遇见过吗?

问答 2023-08-23 来自:开发者社区

flink管理界面,有任务暂停的按钮吗?- "INITIALIZING":初始化中

flink管理界面,有任务暂停的按钮吗?- "INITIALIZING":初始化中 "CREATED":已创建 "RUNNING":运行中 "FAILING":失败中 "FAILED":已失败 "CANCELLING":取消中 "CANCELED":已取消 "FINISHED":已完成 "RESTARTING":重启中 "SUSPENDED":已暂停 "RECONCILING":调节中我看文档.....

问答 2023-08-23 来自:开发者社区

请教Flink CDC中environment.execute("DbForJob")这个执行了一?

请教Flink CDC中environment.execute("DbForJob")这个执行了一个任务,怎么停止这个服务呢?

问答 2023-08-23 来自:开发者社区

Flink CDC中如果我设置了checkpoint操作,然后我的任务失败了,在yarn上面已经没?

Flink CDC中如果我设置了checkpoint操作,然后我的任务失败了,在yarn上面已经没有了,然后我重启了,有没有办法从上一次checkpoint开始操作呢?

问答 2023-08-22 来自:开发者社区

请问flink1.16任务执行时 flink-rocksdb目录下没state文件 是哪儿没配对吗?

请问flink1.16任务执行时 flink-rocksdb目录下没state文件 是哪儿没配对吗?

问答 2023-08-22 来自:开发者社区

如何通过 flink api 方式,将jar任务提交到Yarn上以Application运行?

有没有谁知道如何通过 flink api 方式,将jar任务提交到 Yarn 上以Application运行?就是用本地Java代码替代"flink run-application ..."命令。

问答 2023-08-22 来自:开发者社区

Flink为什么我的这个任务,遇到异常数据自动重启时,不会从上一次的CheckPoint进行重启呢?

Flink为什么我的这个任务,遇到异常数据(手动造了一条)自动重启时,不会从上一次的CheckPoint进行重启呢?而是从latest-offset进行重启呢?手动造了一条异常数据 让它自动重启的。

问答 2023-08-22 来自:开发者社区

flink任务从intel x86机器迁移到arm机器, 报错怎么解决?

flink任务从intel x86机器迁移到arm机器, 从checkpoint启动 state rockdb报错 怎么解决?Snappy not supported or corrupted Snappy compressed block contents,

问答 2023-08-22 来自:开发者社区

请问,Flink CDC怎么停止启动的任务?

请问,Flink CDC怎么停止启动的任务?

问答 2023-08-22 来自:开发者社区

Flink CDC你们如果中间任务失败了?如何恢复?通过检查点恢复还是怎么搞?如果binlog索引被

问题1:Flink CDC你们如果中间任务失败了?如何恢复?通过检查点恢复还是怎么搞?如果binlog索引被清理了你是怎么解决的?问题2:你们代码有加什么设置吗?比如server id?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注