问答 2023-11-15 来自:开发者社区

Flink CDC在sql-client创建的库和表,这个有什么方式可以解决没?

Flink CDC在sql-client创建的库和表,在重新进入到sql-client中就没有了,这个有什么方式可以解决没?我们一次性执行了多个job呢,基于hadoop yarn是默认分配的吗?还是会分配到一台机器里

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

flink sql 按日期统计数据,日期变更,怎样撤回已经落库的数据?

flink sql 按日期统计数据,日期变更,怎样撤回已经落库的数据?多个大表join状态会很大,实时join的话,状态读写的效率是影响实时性的主要因素吧

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

请问flink cdc sql能整库同步吗?

请问flink cdc sql能整库同步吗?

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

大佬们,如何使用flink sql,同步数据库,带上执行时间插入宽表?!

问题1:大佬们,如何使用flink sql,同步数据库,带上执行时间插入宽表?为啥这种会导致同步失效?问题2:错误现象是,性别M同步正常,如果数据改为W,目标表的数据不删除,也不变化,理论上是要删除的,目前问题就是如何把操作时间设置进去

问答 2023-07-13 来自:开发者社区

flink sql不同通过jdbc连接hive吗?只能创建catalog加载整个库?那么不同hive

flink sql不同通过jdbc连接hive吗?只能创建catalog加载整个库?那么不同hive库,之间如何进行交互呢?

问答 2023-07-02 来自:开发者社区

Flink CDC中知道sql,动态加库以后,怎么加上这个参数么?

问题1:Flink CDC中知道sql,动态加库以后,怎么加上allowNonRestoredState 这个参数么? 问题2:那如果我当前任务是1个库,我需要在当前任务中再增加一个库,咋整,我就是没有看到这个,官方的有这个参数直接跳转到jar了

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

请问flink cdc 有没有办法,通过sql的方式,将整库的binlog写到kafka呢?

请问flink cdc 有没有办法,通过sql的方式,将整库的binlog写到kafka呢?

问答 2023-04-23 来自:开发者社区

咨询一个Flink问题,我现在把聚合sql拿到 holo库里面去聚合结果又是对的,这是什么原因?

咨询一个问题,我现在从dwd join 维表以后 往dws 写聚合之后的数据,发现聚合的结果数据不对。但是我把聚合sql拿到 holo库里面去聚合结果又是对的,这是什么原因?

问答 2023-02-27 来自:开发者社区

flink sql CDC msyql整库同步 大家有没有好的方案?

flink sql CDC msyql整库同步 大家有没有好的方案?

问答 2023-01-29 来自:开发者社区

flink cdc sql模式是无法做到同时整库读取的吧?

flink cdc sql模式是无法做到同时整库读取的吧?

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

产品推荐

阿里云实时计算Flink

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

+关注