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

FlinkCDC Oracle使用Table Api和FlinkSQL读取全量,每次都是最后一条

FlinkCDC Oracle使用Table Api和FlinkSQL读取全量,每次读到的全量都是最后一条,前面的数据没了,然后增量又没有问题,我的Oracle版本是12c,试了Flinkcdc的2.4、3.0、3.1版本,所有效果都一样,求大佬指点 CREATE TABLE table_source_oracle ( ID BIGINT, NAME VARCHA...

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

Flink CDC里flinksql能否按照分区分批次采oracle的数据呀?

Flink CDC里flinksql能否按照分区分批次采oracle的数据呀?

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

oracle11g 在 flinkCDC2.4 下使用flinkSql来进行同步,增量没有问题吗?

oracle11g 在 flinkCDC2.4 下使用flinkSql来进行同步,增量没有问题吗?会在全量结束后,确认 checkpoint 的时候卡住,表现出来就是只能全量不能增量,但是用 datastream 编写没有问题。Snapshot split assigner received all splits finished, waiting for a complete checkpoi....

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

有没有人知道,flinkSQL,用jdbc方式读取oracle的number类型怎么映射?

有没有人知道,flinkSQL,用jdbc方式读取oracle的number类型怎么映射?

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

oracle cdc使用flinksql的时候同步全量数据的时候是不是不支持checkpoint啊?

oraclecdc使用flinksql的时候同步全量数据的时候是不是不支持checkpoint啊?是不是flinksql不支持呀?

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

我用的flinksql 去group by然后count统计值 将结果插入oracle中。这个?

我用的flinksql 去group by然后count统计值 将结果插入oracle中。这个flink自己去插入 具体用的什么函数我也不知道?oracle中有主键 这样插入应该是用的merge语句

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

大佬们 我有个Flink问题 我用flinksql进行了分组并统计 将统计结果写入oracle?

问题1:大佬们 我有个Flink问题 我用flinksql进行了分组并统计 将统计结果写入oracle 。如果多并行写入会报死锁,只能把并行度设置为1才能写入。这是因为对同一个主键同时进行了marge操作导致的吗?问题2:因为统计数据变了要进行更新吧?count值一直在变的

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

请问下,flinksql读取hive历史数据(十几亿)同步到Oracle中,感觉比较慢,有哪里可以?

请问下,flinksql读取hive历史数据(十几亿)同步到Oracle中,感觉比较慢,有哪里可以优化的或者其它比较快的导入方式嘛?这样设置的

问答 2023-05-30 来自:开发者社区

请问下,flinksql操作Oracle是必须使用sid吗?servicename是不行的是吗?

请问下,flinksql操作Oracle是必须使用sid吗?servicename是不行的是吗

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

flinksql从kafka批量写入oracle,写入有什么优化方式吗?

flinksql从kafka批量写入oracle,写入有什么优化方式吗,每秒十几万数据,没有什么逻辑。目前就设置了批量和定时,写入感觉有点慢

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

相关镜像