问答 2024-01-18 来自:开发者社区

Flink CDC里stream park有计划接入flink-cdc 3.0来管理任务吗?

Flink CDC里stream park有计划接入flink-cdc 3.0来管理任务吗?

问答 2024-01-18 来自:开发者社区

Flink的CDC任务,你们一般是放在Yarn中执行吗?

Flink的CDC任务,你们一般是放在Yarn中执行吗?放在k8s和yarn上怎么评估呢,yarn上是不是没有k8s的稳定,受到yarn的其他资源调度影响啊。

问答 2024-01-18 来自:开发者社区

Flink CDC里flinkcdc3.0启动同步任务,还需要添加什么环境吗?

Flink CDC里flinkcdc3.0启动同步任务,还需要添加什么环境吗?exec "$JAVA_RUN" -classpath "$CLASSPATH" "${LOG_SETTINGS[@]}" com.ververica.cdc.cli.CliFrontend "$@"

问答 2024-01-18 来自:开发者社区

Flink CDC我配置mysql CDC,但任务重启(重新执行)后,它总是全量同步数据,要怎么做?

Flink CDC里我配置mysql CDC,但是任务重启(重新执行)后,它总是全量同步数据,具体有什么参数可以配置使用增量同步啊?

问答 2024-01-18 来自:开发者社区

Flink CDC里flink 能获取的当前任务运行的jar 名称吗?

Flink CDC里flink 能获取的当前任务运行的jar 名称吗?

问答 2024-01-18 来自:开发者社区

Flink CDC里cdc2.4.0出现这个报错,是什么原因引起的呢?

Flink CDC里cdc2.4.0出现这个报错,如果任务失败,在session模式中,失败任务保留2个小时就看不到了在webui,是什么原因引起的呢?1.17

问答 2024-01-18 来自:开发者社区

Flink CDC里集群偶发性的报这个错误,对数据有影响吗?

Flink CDC里集群偶发性的报这个错误,我们用的yarn,遇到这个错误,任务自动重启,容器就换了,对数据有影响吗?

问答 2024-01-18 来自:开发者社区

Flink CDC里通过savepoint恢复除了指定savepoint 路径还要啥?

在使用Flink CDC时,除了指定savepoint路径外,恢复任务还需要提供哪些信息?当尝试通过手动保存的savepoint(路径为/data/bigdata/flksavepoint/savepoint-8bf7c8-d01d1e73c7c2)恢复Flink CDC从MySQL到StarRocks的任务时,在sql-client端提交作业时报错,请问如何解读这些错误信息?

问答 2024-01-18 来自:开发者社区

Flink CDC里基于yaml文件提交任务报这个错误,缺什么配置?

Flink CDC里我在基于Flink-1.18+CDC 3.0基于yaml文件提交任务报这个错误,是我缺少什么配置吗?

文章 2024-01-17 来自:开发者社区

DataphinV3.14 Flink SQL任务支持基于Session集群调试,模拟生产代码逻辑的调试效果

背景 实时研发一直以来的都是通过local-debug的方式来调试开发中的Flink SQL任务,该方式有如下不足: 支持的采样数据有限,且非是流式数据的调试。手动上传构造数据的方式较为繁琐,局限性较大。为便于Flink SQL任务的调试,DataphinV3.14版本支持Flink SQL任务基于Session集群调试,期望...

DataphinV3.14 Flink SQL任务支持基于Session集群调试,模拟生产代码逻辑的调试效果

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

产品推荐

阿里云实时计算Flink

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

+关注