问答 2024-04-09 来自:开发者社区

Flink CDC中csdn上说要创建这些目录,我创建了把包挪进去还是没用?

csdn上说 flink cdc 要创建这些目录,我创建了把包挪进去还是没用?

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

Flink CDC 里jar都放入lib目录了,执行flink-cdc.sh还是失败怎么弄?

Flink CDC 里jar都放入lib目录了,执行flink-cdc.sh还是失败怎么弄?

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

Flink独立集群与hdfs集群不在一起,flink如何配置checkpoint目录为hdfs?

Flink独立集群与hdfs集群不在一起,flink如何配置checkpoint目录为hdfs?

问答 2024-04-02 来自:开发者社区

Flink设置了这两个参数,但还是会被清理,只留下元目录,chk-1会被清理,如何解决?

Flink设置了这两个参数,但还是会被清理,只留下元目录,chk-1会被清理?

问答 2024-04-02 来自:开发者社区

Flink的任务取消之后,检查点目录直接被删除了,该如何避免呢?

Flink的任务取消之后,检查点目录直接被删除了,该如何避免呢?

问答 2024-03-19 来自:开发者社区

Flink CDC 里jar都放入lib目录了,执行flink-cdc.sh还是失败怎么弄?

请教下Flink CDC 中,3.0提示这个以下,pipeline connectors sink 是否不支持mysql? Cannot find factory with identifier "mysql" in the classpath. Available factory classes are:com.ververica.cdc.connectors.mysql.factory.My....

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

Flink CDC里 一定要有dfs ?如果用linux本地目录呢?

Flink CDC里 Zookeeper的HA Flink standalone 集群,savepoint保存的是linux本地服务器地址,到恢复程序时,要每个taskmanager的服务器都要有这savepoint文件,否则一直报找不到savepoint地址 请问一定要每个taskmanager服务器都分发这个savepoint文件吗?一定要有dfs ?如果用linux本地目录呢?

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

flink 1.15.4 /tmp目录,看每天都会生成10多个flink-这个是什么情况呢?

flink 1.15.4 /tmp目录,看每天都会生成10多个flink-table-planner_xxx.jar,这个是什么情况呢?

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

把mysql-cdc的jar挂到/opt/flink/lib目录下提示找不到该连接器?

把mysql-cdc的jar挂到/opt/flink/lib目录下了。但是启动sql-client时,提示找不到该连接器?

问答 2023-12-20 来自:开发者社区

Flink CDC集群拓展lib目录是必须重启集群jar才会生效嘛?

Flink CDC集群拓展lib目录是必须重启集群jar才会生效嘛 能不能动态拓展 比如我新增一个jar直接放进去执行一个命令就可以直接用 而不用重启集群?

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

产品推荐

阿里云实时计算Flink

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

+关注