阿里云开发者社区

Flink CDC里bin/sql-client.sh执行命后报错怎么办

Flink cdc-pipeline-doris-3.0 新增了第五张表全量同步 但原先的表有两张不写增量数据了 感觉像是源头直接就过滤了这个该怎么排查呀应该不是得加第四张表的时候 前面的表有增量

Flink CDC里sqlserver开了cdc后为什么有一个存储图片的字段在图片较大时就报超长关掉cdc后同样的图片再保存到该字段就不会报超长错误是为什么flink cdc 底层是做了什么截断操作

log event entry exceeded max_allowed_packet; Increase max_allowed_packet on master; the first event

Flink cdc3.0最低支持 flink 版本是多少我看代码里写的1.18的我用1.17会报一些类找不到。

Flink CDC里mysql to doris的pipeline方式不支持datatime类型吗报这个错怎么办

Flink CDC里源表是mysql使用flink cdc中获取mysql的数据如何在flink sql中如何获取到op这个这个隐藏字段op 插入更新删除这个操作之类的

Flink CDC里我们业务库在PolarDB1.0上flinkcdc监控的话有什么好的办法吗一直都用的是这个版本也没升级过现在我是直接监控DRDS下面的rds感觉这样比较麻烦有好的方案吗现在一个d

Flink cdc3.0读oracle有这样的字段怎么解决呢__debezium_unavailable_value

Flink CDC里mysql-cdc 做全量历史数据同步的时候如何控制同步速度么调整chunk-size参数大小么想限速 用cdc-pipeline 下游doris的io负载有些高配置还行 3f

Flink CDC里oracel cdc3.0捕捉字段类型加哪个配置

Flink CDC里 就是设置了SET table.exec.state.ttl 24h 的flink sql cdc任务将mysql表数据全部同步到upsert-kafka后停止任务然后再用最新

Flink CDC里这个怎么处理cdc-3.0 mysql -->starrocks 整库同步的时候有的有主键有的没主建没有的会报Caused by: org.apache.flink.tab

Flink CDC里oracle-cdc 是不能指定从最早或者指定的时间点开始消费吗

Flink CDC里這個不能这样设置吗

请问OceanBase数据库默认的字符集和排序字符集是啥

Flink CDC里pipline doris sink 怎么指定库文档没看到呢我看到 route 了但是我有几百张表不能每个表都写 route 吧

Flink CDC里有用过cdcdoris实时更新增删改的业务场景吗保证doris和业务数据库1:1一致同时删同时改 我们这边需要保证客户数据库几条数据我们就几条数据客户会硬删数据想保持同步。中间怎

通过obd 白板安装后的OceanBase数据库的配置文件一般放在哪里

参考图片在OceanBase数据库执行其它命令之后显示的是参数 连接的是proxysyssys租户可以

想在DSW把ChatGLM3和langchain集成在一起然后有一行代码是这样curl -X POST http://{your_host}:8000 \不知道在DSW里该怎么搞求大佬指点

java.lang.NoClassDefFoundError: com/ververica/cdc/common/utils/StringUtils Flink CDC里我也是这个问题 我用的 fl

Flink CDC里请教一个大数据组件问题cdh 5.9版本的kafka 指定消费组ID消费 zk中无法注册consumers 但是消息能消费是为什么

2881端口是直接登录的ob没有问题想在OceanBase数据库通过proxy登录总是不行怎么办

Flink CDC里这是啥问题用了dinky 1.0.2 flink 1.8.1 . perjob on yarn. 任务失败报了这个错。未用pipleline1.8.1

Flink CDC里这个报错怎么办Caused by: com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.Con

参考图片OceanBase数据库通过obp登录 执行sql总是不成功是怎么回事

id 选择器。

Flink CDC里pgsql开启cdc监听任务报错怎么办pgoutput这个需要改哪里

我自己测试flink cdc 读取MySQL表通过sql client映射表后去查询没有数据任务直接finshed了是什么原因但是我任务本地idea是可以跑的

flink cdc集群多个节点任务如何均分到各个节点上哪个参数设置flink1.18

我提了个帖子参考链接https://ask.oceanbase.com/t/topic/35608279 有个很奇怪的现象使用OceanBase数据库时候我们数据存储集中在一个节点上这个要怎么排查呀

Flink CDC里有没有本地调试connector的文档呀我想学习下看看问题出在哪。doris这边还有个问题mysql是TIME类型的话cdc这边没做处理导致报错怎么办

查看图片请问这个应该是OceanBase数据库的版本号吧

flinkcdc-2.4.2的基础上有表结构变更的同步用pyflink来实现的话有没有好的参考呀3.1会有多少source会有pgsql/sqlserver/oracle么这个表结构变更如果用2.4

Flink CDC里如果sink库要换库名只能用route吗有没有专门指定sink库的库名配置 database.mapping这种

参考图片下载的最新的OceanBase数据库版本 这个是怎么回事儿呢

flinkcdc mysql到doris 会自动建表吗

数据结构与算法⑩(第四章_上)树和二叉树和堆的概念及结构

flink cdc怎么指定额外resource路径我拷了个hive-site.xml放flink的lib下yarnsession模式能classloader的getresource能get到这个h

参考图片OceanBase数据库这个MetaDB 是所谓的数据库吗 我现在已经有了一个2881的数据库 还需要新建吗

Flink CDC里请教下这个问题会有影响么 不知道是什么导致的。FLINK1.16oracle-cdc-3.0.0

Flink CDC里我想问一下检查点的时间一般指多久为好我现在指定5分钟凌晨的时候就报这个错误 requested WAL segment 00000001000004A7000000B0 has

参考图片 社区创建了 OceanBase数据库 ocp的镜像在哪能找到啊 或者tar包 在官网没看到ocp的下载包

Retrieve schema history failed, the schema records for engine c6f9ddda-f5f8-4774-b1e3-9884cfb47c71

Flink CDC里 elsaticseach 跨集群同步数据有使用 增量/全量 使用 flink-cdc 可行吗

在OceanBase数据库不用ocp 可以迁移吗文档提示可选

数据结构与算法⑩(第四章_上)树和二叉树和堆的概念及结构

OceanBase数据库的oat有社区版的吗

Flink CDC里flinksql 维表join 主表同一条数据3s内连续变更维表字段会关联出很久以前的数据这种是什么情况造成的呢create table source_trade_order_t