Flink的api停止方式
您好: 我这边现在有个flink读hbase的程序需要每天在固定的时间段内调用接口,然后如果在指定时间以外或者处理的数据量达到一个阈值的时候停止,在第二天的重复第一天的操作。现在有个问题,就是如何在代码里面可以像UI界面那样将jobcancel掉,而且第二天可以接着第一天的处理进度接着处理剩下的数据。有个savepoint的方案,需要jobid和applicationid但是目前好像在代码里面获取不到,有人有解决思路吗?
回复:Flink的api停止方式
hi: 这个借助外部脚本应该比较容易实现吧。stop后再启动。 ---原始邮件--- 发件人: "lei-tian"
Re:回复:Flink的api停止方式
因为要在代码里面判断是否停止的条件,停止的时候还是要在代码里面停止吧。 在 2021-10-11 09:06:17,"995626544" <995626...@qq.com.INVALID> 写道: >hi: >这个借助外部脚本应该比较容易实现吧。stop后再启动。 > > > >---原始邮件--- >发件人: "lei-tian"发送时间: 2021年10月11日(周一) 上午9:02 >收件人: "user-zh"主题: Flink的api停止方式 > > >您好: > >我这边现在有个flink读hbase的程序需要每天在固定的时间段内调用接口,然后如果在指定时间以外或者处理的数据量达到一个阈值的时候停止,在第二天的重复第一天的操作。现在有个问题,就是如何在代码里面可以像UI界面那样将jobcancel掉,而且第二天可以接着第一天的处理进度接着处理剩下的数据。有个savepoint的方案,需要jobid和applicationid但是目前好像在代码里面获取不到,有人有解决思路吗?
回复: 如何查看1.10的中文文档
hi 杨浩: 中文版地址 https://ci.apache.org/projects/flink/flink-docs-release-1.10/ 可以看到最左侧 下面有个 Pick Docs Version 可以通过这里选择所有版本的文档 wukon...@foxmail.com 发件人: 杨浩 发送时间: 2021-10-09 10:57 收件人: user-zh 主题: 如何查看1.10的中文文档 我们公司用的flink版本是release-1.10,请问如何查看该版本的中文文档, 英文文档:https://ci.apache.org/projects/flink/flink-docs-release-1.10/ 中文只能看最新的:https://flink.apache.org/zh/flink-architecture.html
退订
退订 | | nixiaoning | | nixiaon...@163.com | 签名由网易邮箱大师定制
回复:回复: 如何查看1.10的中文文档
多谢,看的这个哈 https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/ 在 2021-10-11 09:34:10,"wukon...@foxmail.com" 写道: hi 杨浩: 中文版地址 https://ci.apache.org/projects/flink/flink-docs-release-1.10/ 可以看到最左侧 下面有个 Pick Docs Version 可以通过这里选择所有版本的文档 wukon...@foxmail.com 发件人: 杨浩 发送时间: 2021-10-09 10:57 收件人: user-zh 主题: 如何查看1.10的中文文档 我们公司用的flink版本是release-1.10,请问如何查看该版本的中文文档, 英文文档:https://ci.apache.org/projects/flink/flink-docs-release-1.10/ 中文只能看最新的:https://flink.apache.org/zh/flink-architecture.html