加载中
shipyard

cat deploy | ACTION=node DISCOVERY=etcd://ip bash -s

Apache Flink 1.8.0 中的状态生存时间特性:如何自动清理应用程序的状态

原文链接:https://flink.apache.org/2019/05/19/state-ttl.html 对于许多状态流式计算程序来说,一个常见的需求是自动清理应用程序的状态(state),以便有效地控制状态大小,或者控制程序访...

2019/08/28 21:05
25
Flink SavePoint

SavePoint 和 CheckPoint的区别: checkpoint提供一种轻量级和快速恢复机制,整个生命周期由Flink框架管理,作业程序在运行期间不允许变更,任务执行结束后会删除checkpoint数据,除非显式配...

2019/08/12 15:41
15
Flink State 测试

1. 任务异常从checkpoint恢复 环境:Flink1.8 local模式 根据运行结果可以看出,在设置显式设置uidHash值的情况下当前版本会导致flink自身的checkpoint恢复失败。 测试结果如下图: 2. SaveP...

2019/08/06 15:22
51
Flink Kafka 实时日志处理实例

实时计算引擎Flink demo 了解一个东西除了关注当前技术本身,更应该联系整个应用环境来看。本文介绍一个从数据采集到入queue,再用Flink消费queue的消息,进行处理后写入ES Hbase HDFS等存储...

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部