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

Flink CDC中sqlserver自增ID的场景,cdc拿到的id为0?

Flink CDC中sqlserver自增ID的场景,cdc拿到的id为0?这个是bug吗

问答 2023-09-19 来自:开发者社区

Flink CDC这个权限问题的么,场景是从Kafka -> hive ,通过FlinkSQL实现?

Flink CDC这个权限问题的么,场景是从Kafka -> hive ,通过FlinkSQL实现,在dolphinscheduler调度。Permission denied: user=dolphinscheduler, access=READ, inode="/warehouse/tablespace/managed/hive/":hdfs:hadoop:drwxrwx---?

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

Flink CDC 双流join场景,是直接报错oom还是丢弃状态?

Flink CDC 双流join场景,join算子的state越来越大,是直接报错oom还是丢弃状态?我配置的是rocksdb 状态后端

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

请教下 有没有用flink只为了实时cdc刷新报表的场景?多个事实表之间join在正常窗口期一大半都

请教下 有没有用flink只为了实时cdc刷新报表的场景?多个事实表之间join在正常窗口期一大半都关联不上,很多需要查表

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

有没有兄弟用了flink cdc目的端到hive的场景?

有没有兄弟用了flink cdc目的端到hive的场景?

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

Flink CDC中我的场景是同步Mysql数据到es中,应该怎样写才可以插入一组数据?

Flink CDC中我的场景是同步Mysql数据到es中,es索引对应的类型是一个数组,我在flink sql中创建了对应的类型 regions ARRAY>, 那insert into到 es_index应该怎样写才可以插入一组数据,我使用insert into es_index select ROW(regionId, regionName) AS regions from ... 只能...

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

大佬 Flink CDC中这种场景下的统计逻辑怎么优化呢? 我理解挺常见的。 入出茅庐 不求甚解,比

大佬 Flink CDC中这种场景下的统计逻辑怎么优化呢? 我理解挺常见的。 入出茅庐 不求甚解,比如订单总数 消费金额,这种类似的场景 我的理解和这种是差不多的

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

Flink CDC 你好 ”丢数据“ 这个在什么场景下会丢,能否分享下。 这个是删除最新的归档?

Flink CDC 你好 ”丢数据“ 这个在什么场景下会丢,能否分享下。 这个是删除最新的归档日志才会出现的吧中我们这边 有个场景就是每天会莫名的丢个几条数据。没有删除最新归档日志,怎么办?

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

大佬们现在咋处理flink cdc interval join场景的,现在测试下来一直报?

大佬们现在咋处理flink cdc interval join场景的,现在测试下来一直报【StreamPhysicalIntervalJoin doesn't support consuming update and delete changes which is produced by node TableSourceScan】这种错

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

Flink CDC log4j日志打印任务名和容器id,如果是session场景,是不是有问题啊?

Flink CDC log4j日志打印任务名和容器id,如果是session场景,是不是有问题啊,有多个任务运行的时候,也能打印出每个任务的任务名吗?

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等