问答 2024-07-15 来自:开发者社区

在Flink CDC中oraclecdc 有设置监听间隔时间的参数吗?

在Flink CDC中oraclecdc 有设置监听间隔时间的参数吗?

问答 2024-07-11 来自:开发者社区

flink报错 给的解决方法是 这个,但是rds又不支持 设置这几个参数 该怎么办啊?

flink报错 给的解决方法是 这个 但是rds又不支持 设置这几个参数 该怎么办啊?set global slave_net_timeout = 120Access denied; you need (at least one of) the SUPER or SYSTEM_VARIABLES_ADMIN privilege(s) for this operation当前数据库账号无权限执行.....

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

实时计算 Flink版产品使用问题之设置什么参数可以让多张表同时写入

问题一:Flink 想全量同步,但是历史数据只同步过来最后一条,请问一下什么原因导致的呀? Flink CDC 中scan.startup.mode设置了initial,想全量同步,但是历史数据只同步过来最后一条,请问一下什么原因导致的呀?源库与目标库都是oracle 参考答案: 当scan.startup.mode设置为initial时,Flink ...

实时计算 Flink版产品使用问题之设置什么参数可以让多张表同时写入
问答 2024-06-03 来自:开发者社区

实时计算Flink如何设置allowNonRestoredState参数

实时计算Flink如何设置allowNonRestoredState参数

问答 2024-05-28 来自:开发者社区

flink 1.19.0 版本 任务提交命令中设置TaskManager 个数的参数是哪个?

flink 1.19.0 版本 任务提交命令中设置TaskManager 个数的参数是哪个?

文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之向FlinkSQL的表连接配置设置参数的步骤是什么

问题一:Flink CDC如何向flinksql的表连接配置设置参数? Flink CDC如何向flinksql的表连接配置设置参数? 参考答案: Flink CDC 向 Flink SQL 的表连接配置设置参数可以通过以下步骤进行: 首先,确保你已经在 Flink 中启用了 CDC。你可以通过在 Flink 配置文件(flink-...

实时计算 Flink版产品使用合集之向FlinkSQL的表连接配置设置参数的步骤是什么
文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之使用 MySQL CDC 进行数据同步时,设置 server_id 参数如何解决

问题一:Flink CDC中oralce cdc必须要在库级别开启ALTER DATABASE ADD 吗? Flink CDC中oralce cdc必须要在库级别开启ALTER DATABASE ADD SUPPLEMENTAL LOG DATA吗?不能只执行ALTER TABLE inventory.customers ADD SUPPLEMENTAL LOG DATA (...

实时计算 Flink版产品使用合集之使用 MySQL CDC 进行数据同步时,设置 server_id 参数如何解决
问答 2024-05-01 来自:开发者社区

Flink CDC里在这可以有设置并行度的参数么,貌似没有吧,只有sink端可以吧?

'connector' = 'mysql-cdc', 'hostname' = '{}', 'port' = '{}', 'database-name' = '{}', 'username' = '{}', 'password' = '{}', ...

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

大佬们,Flink CDC里我设置了这两个参数,如果sink端出现问题,是不是也会重试?

Flink CDC里我设置了这两个参数,如果sink端出现问题,是不是也会重试?restart-strategy.fixed-delay.attempts: 3restart-startegy.fixed-delay.delay: 10s 还是只针对source端?有办法针对source和sink进行设置吗?

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

Flink CDC里请问flink-sql有设置source并发度为1的参数么?

Flink CDC里请问flink-sql有设置source并发度为1的参数么?其他并发大于1,没找到那个参数。 'write.tasks' = '4' ,'compaction.tasks' = '2',parallelism.default=1,是能控制source=1,'compaction.tasks' = '2','write.tasks' = '4'。但是我们是用sql文件提交的,只....

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

产品推荐

阿里云实时计算Flink

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

+关注