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

请教一下大家,对于window这种有状态的算子,假如整个flink任务突然挂了,可以从最近的一次ch

请教一下大家,对于window这种有状态的算子,假如整个flink任务突然挂了,可以从最近的一次checkpoint恢复吧,或者大家有什么更好的办法吗?

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

请问 一个flink-cdc 任务 可以连 俩个不同mysql数据源吗? 二个完全不同的 mysql

请问 一个flink-cdc 任务 可以连 俩个不同mysql数据源吗? 二个完全不同的 mysql实例

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

请问下,运行实时计算任务的时候,报这个错误是什么原因呢,oss上的bucket是设置的hangzho

请问下,运行实时计算任务的时候,报这个错误是什么原因呢,oss上的bucket是设置的hangzhou,但是运行的时候却endpoint找到了shanghai。

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

有大佬知道为啥在idea里面不输出增量数据吗,只有全量的,但是我把任务上传到flink里面运行,是有

有大佬知道为啥在idea里面不输出增量数据吗,只有全量的,但是我把任务上传到flink里面运行,是有增量的

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

flink cdc mysql 有 catalog功能吗? 多个任务的binlog 合并怎么实现?

flink cdc mysql 有 catalog功能吗? 多个任务的binlog 合并怎么实现?

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

有没有大佬在flink on k8s 上提交Application 任务,出现以下报错,我怀疑是我某

有没有大佬在flink on k8s 上提交Application 任务,出现以下报错,我怀疑是我某个超时时间太短所导致,有大佬知道的吗

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

flink batch任务,报Heartbeat of TaskManager timeout,该调

flink batch任务,报Heartbeat of TaskManager timeout,该调什么参数呢

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

各位大佬,flink cdc 动态加表,能否做到不重启任务?

各位大佬,flink cdc 动态加表,能否做到不重启任务?

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

大家flink on k8s 版本修改重新提交的时候,之前跑的任务怎么取消

大家flink on k8s 版本修改重新提交的时候,之前跑的任务怎么取消

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

我测试以固定节点3作为flink客户端提交任务,发现这一台的内存使用占比很高,感觉资源消耗没有均分到

我测试以固定节点3作为flink客户端提交任务,发现这一台的内存使用占比很高,感觉资源消耗没有均分到集群。有人知道这是什么原因吗

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

产品推荐

阿里云实时计算Flink

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

+关注