问答 2024-07-29 来自:开发者社区

Flink1.19还没适配es,要么等,要么自己写connect,然后commit怎么办?

Flink1.19还没适配es,要么等,要么自己写connect,然后commit?flink-connector-elasticsearch项目热度不高

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

flink - sink - mysql,commit阶段失败了,那这数据是什么状态?我的理解,正常

flink - sink - mysql,commit阶段失败了,那这数据是什么状态?我的理解,正常jdbc开启事务,如果抛异常失败的话那这条数据就丢失了,因为只有checkpoint触发后才会提交事务的,offset在什么时候保存的呢,kafka(source) -> flink -> (sink)mysql

问答 2023-03-15 来自:开发者社区

Flink有用jdbcsink向phoenix插入数据的吗,怎么设置自动commit?

Flink有用jdbcsink向phoenix插入数据的吗,怎么设置自动commit?

问答 2023-01-30 来自:开发者社区

请问一个在flink官网下载的flink执行包,怎么看这个包产出时候的git commit ID呀?

请问一个在flink官网下载的flink执行包、就是包含bin和lib那种、怎么看这个包产出时候的git commit ID呀?

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

为啥flink离线压缩hudi表 每次只压缩一个commit呀

为啥flink离线压缩hudi表 每次只压缩一个commit呀

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

有没有对flink 离线任务压缩 hudi表 增大一次压缩的commit个数,感觉默认的太慢了

有没有对flink 离线任务压缩 hudi表 增大一次压缩的commit个数,感觉默认的太慢了

问答 2021-12-07 来自:开发者社区

Flink kafka Consumer的commit offset方式有什么?

Flink kafka Consumer的commit offset方式有什么?

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

产品推荐

阿里云实时计算Flink

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

+关注