问答 2024-06-16 来自:开发者社区

E-MapReduce上的Flink任务的Checkpoint 写在哪里合适

E-MapReduce上的Flink任务的Checkpoint 写在哪里合适

文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之任务在同步过程中新增同步表后选择全量初始化历史数据,是否会阻塞原先其余表的增量同步

问题一:Flink cdc在同步过程中新增同步表后选择全量初始化历史数据,会阻塞原先其余表的增量同步吗? Flink cdc任务在同步过程中新增同步表后选择全量初始化历史数据,会阻塞原先其余表的增量同步么? 参考答案: 新增表不影响其他,有个feature是新增表不断流。增量数据从任务开始就在同步了。历史数据同步及binlog同步在全量阶段是并行执行的...

实时计算 Flink版产品使用问题之任务在同步过程中新增同步表后选择全量初始化历史数据,是否会阻塞原先其余表的增量同步
文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之如何从指定的savepoint恢复任务

问题一:Flink 这是为何? Flink 这是为何?我的数据库中压根没有wh_item_lending这个表 flink是1.13.6的 CDC是1.4.0 参考答案: 应该是mysql 的元数...

实时计算 Flink版产品使用问题之如何从指定的savepoint恢复任务
文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之如何避免任务取消之后,检查点目录直接被删除

问题一:我用flinkcdc做update和delete的时候目标库要等10分钟左右才变更,为什么会这么慢? 我用flinkcdc做update和delete的时候目标库要等10分钟左右才会变更,为什么会这么慢啊?跟checkpoint有关系吗? 参考答案: 看看是业务延迟了吗,如果不是,看下checkpoint多久一次,多久一次才做成功。配Oracl...

实时计算 Flink版产品使用问题之如何避免任务取消之后,检查点目录直接被删除
文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之yarn session模式中启动的任务链接是http IP,想把IP映射为主机hadoop,该怎么操作

问题一:我使用flink on yarn启动了一个任务模式 怎么看这个会话的资源被当前任务占用了多少? 我使用flink on yarn启动了一个任务 yarn session模式 怎么看这个会话的资源被当前任务占用了多少? 参考答案: 应该看不了 , 关于本问题的更多回答可点击进行查看: https://devel...

文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之运行run-application --target kubernetes-application执行,通过进程的返回码来决定作业是否成功,任务返回码都是0,该怎么办

问题一:有个Flink问题咨询下,application模式需要怎么配置呢? 有个Flink问题咨询下,运行run-application --target kubernetes-application执行,想通过进程的返回码来决定作业是否成功,但是任务不论成功还是失败返回码都是0,session模式成功是0,失败是其他的,application模式需要怎么配置呢? ...

实时计算 Flink版产品使用问题之运行run-application --target kubernetes-application执行,通过进程的返回码来决定作业是否成功,任务返回码都是0,该怎么办
文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之同步oracle表时,任务不报错,但是读不到数据,是什么导致的

问题一:各位有遇到过flinkcdc 同步oracle表时,任务不报错,但是读不到数据的情况吗? 各位有遇到过flinkcdc 同步oracle表时,任务不报错,但是读不到数据的情况吗? ...

实时计算 Flink版产品使用问题之同步oracle表时,任务不报错,但是读不到数据,是什么导致的
问答 2024-06-14 来自:开发者社区

Flink批任务启动报错Detected an UNBOUNDED source with t...

Flink批任务启动报错Detected an UNBOUNDED source with the 'execution.runtime-mode' set to 'BATCH'

问答 2024-06-14 来自:开发者社区

实时计算Flink任务默认写出到OSS的有哪些文件

实时计算Flink任务默认写出到OSS的有哪些文件

问答 2024-06-13 来自:开发者社区

Flink消费Kafka任务正常无延迟但Kafka控制台显示数据堆积

Flink消费Kafka任务正常无延迟但Kafka控制台显示数据堆积

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

产品推荐

阿里云实时计算Flink

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

+关注