问答 2022-11-20 来自:开发者社区

flink任务每次重启的时候会丢失一些数据,请问大家有遇到过吗?

flink任务每次重启的时候会丢失一些数据,请问大家有遇到过吗?

文章 2022-11-12 来自:开发者社区

【Flink-容错API】重启策略-CheckPoint/StateBackend

一、Flink容错1.1 State状态Flink实时计算为了保证计算过程中,出现异常可以容错,就要中间结果的计算结果存储起来,这些中间数据就叫做State。State时多类型的,默认是保存在JobManger的内存中,也可以保存在TaskManager的本地文件中,也可以保存在本地文件系统或者HDFS这样的分布式文件系统中。1.2 StateBackend用来保存State的存储后端就叫做St....

【Flink-容错API】重启策略-CheckPoint/StateBackend
问答 2022-11-05 来自:开发者社区

请问下当flink集群重启之后 kafka消息还是重复 有什么办法解决吗 kafka sink 已设

请问下当flink集群重启之后 kafka消息还是重复 有什么办法解决吗 kafka sink 已设置 'sink.semantic' = 'exactly-once',

问答 2022-10-24 来自:开发者社区

请教一下:flinksql创建的同步sqlsever到mysql的任务,重启Flink程序后,任务还

请教一下:flinksql创建的同步sqlsever到mysql的任务,重启Flink程序后,任务还能自动从检查点开始吗?

问答 2022-10-24 来自:开发者社区

请问下Flink CDC datastream 采集mysql binlog数据,如何每次重启的时候

请问下Flink CDC datastream 采集mysql binlog数据,如何每次重启的时候采集全量数据,而不是从上一次binlog的位置解析读取?

问答 2022-10-01 来自:开发者社区

flink任务重启起来之后还是会消费之前的日志信息,这个咋解决

我 mysql CDC 设置了startOptions(StartupOptions.lasest()),flink任务重启起来之后还是会消费之前的日志信息,这个咋解决

问答 2022-09-17 来自:开发者社区

flink使用cdc怎么让它中断后,再次重启自动从上次的offset位置消费

flink使用cdc怎么让它中断后,再次重启自动从上次的offset位置消费

问答 2022-09-16 来自:开发者社区

flink 重启任务 有什么解决方案吗?

避免同步重复数据

问答 2022-09-15 来自:开发者社区

界面提交的 jar,为什么 flink 重启之后 jar 就没了为什么

界面提交的 jar,为什么 flink 重启之后 jar 就没了为什么

问答 2022-09-06 来自:开发者社区

请问sqlClient中创建的表与insert into命令在flink重启后都丢失了为啥

请问sqlClient中创建的表与insert into命令在flink重启后都丢失了,每次都要重新操作一遍,这个是正常现象吗? 每次重启flink都要手动提交一遍?

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

产品推荐

阿里云实时计算Flink

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

+关注