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

flink版本1.14.2 kafka版本0.11.0.1 精确一次模式生产数据报错,有遇到过的吗?

flink版本1.14.2 kafka版本0.11.0.1 精确一次模式生产数据报错,有遇到过的吗?

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

flink checkpoint 保留机制问题 集群模式是 standlane模式 我设置参数sta

flink checkpoint 保留机制问题 集群模式是 standlane模式 我设置参数state.checkpoints.num-retained 参数为2 清除策略设置 RETAIN_ON_CANCELLATION 出现的问题就是:主节点中chk-xxx 文件有删除 但工作节点中的shared目录下的引用文件未删除,时间一长会导致磁盘爆满,跟了下代码 删除操作是在主节点进行的没有看到.....

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

怎么让flink 部分算子跑批 部分跑流模式?

怎么让flink 部分算子跑批 部分跑流模式? ALL_EXCHANGES_BLOCKING

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

flink 打了断点 debug模式但一直不进断点是啥情况?也没报错

flink 打了断点 debug模式但一直不进断点是啥情况?也没报错

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

请教一个问题,flinkcdc同步时间,flink Standalone模式在生产环境可以不?

请教一个问题,flinkcdc同步时间,flink Standalone模式在生产环境可以不,或者生产环境flink集群,搭建什么模式的,目前只做数据同步

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

flink-mysql-cdc streaming模式时区问题要怎么处理啊?

flink-mysql-cdc streaming模式时区问题要怎么处理啊,现在不加time-zone设置,全量部分数据正常,但是进入增量部分就差了8个小时,如果time-zone设置上Asia/shanghai,全量和增量时间就都不对了

问答 2022-08-31 来自:开发者社区

flink application模式 支持jar存储在OSS上吗

flink application模式 支持jar存储在OSS上吗

问答 2022-08-31 来自:开发者社区

小红书书选择Native Flink on K8s部署模式的原因是因为什么?

小红书书选择Native Flink on K8s部署模式的原因是因为什么?

问答 2022-08-26 来自:开发者社区

mysql开启gtid模式的主从架构下, flink cdc 从库A 切换到主库B,会自动从 g

mysql开启gtid模式的主从架构下, flink cdc 从库A 切换到主库B,会自动从 gtid 启动?

问答 2022-08-25 来自:开发者社区

大佬们, flink的yarn-session模式是在那个服务器起的在哪个服务器提交作业吗,还是根

大佬们, flink的yarn-session模式是在那个服务器起的在哪个服务器提交作业吗,还是根据flink-conf.yaml里设置的那个jobmanager.rpc.address:指定的那个服务器提交?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注