问答 2024-10-31 来自:开发者社区

flink同步sqlserver到mysql的时候遇到sqlserver自定义类型的字段属性导致失败

sqlserver字段属性未自定义类型 在同步到mysql的表中:使用flinksql去创建表同步到库里发现flink不支持这个自定义类型会报错: Don t support SqlSever type uid_exch yet, jdbcType: -5 .以下是flink建表同步语句求大佬帮忙看看:CREATE TABLE CARGO ( CGO_ID BIGINT, CGO...

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

Flink在不重新建catalog的情况下,是不是把这个宽表的binlog属性这样改一下就行?

holo上的ods层的表已经在实时更新了,但这几张表拼接处理形成的宽表没有更新,原因可能是holo的catalog我是用Ui模式创建的,有些属性没设置,Flink在不重新建catalog的情况下,是不是把这个宽表的binlog属性这样改一下就行?

问答 2024-08-12 来自:开发者社区

在Flink CDC中,ebezium.log.mining这2个属性设置下呢 ?

在Flink CDC中,ebezium.log.mining.continuous.mine=truedebezium.log.mining.strategy=online_catalog这2个属性设置下呢 ?

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

flink链接rocketMQ5.*的时候,需要配置的属性字段除了文档里给的之外,还有其他参数吗?

flink链接rocketMQ5.*的时候,需要配置的属性字段除了文档里给的这四个字的之外,还有其他的必要参数嘛?:CREATE TEMPORARY TABLE source_table ( mess varbinary) WITH ( 'connector' = 'mq5', 'endpoint' = '', 'topic' = 'mq-test', 'consumerGroup' ...

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

对于Flink CDC,mysql到Doris库的mysql-to-doris.yaml用这个属性嘛

对于Flink CDC,mysql到Doris库的的那个示例mysql-to-doris.yaml可以用这个属性嘛?

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

flink-cdc3.1现在可以支持排除表选项了么,是哪个属性设置?

flink-cdc3.1现在可以支持排除表选项了么,是哪个属性设置?

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

Flink能否像通过set增加表属性

Flink能否像通过set增加表属性

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

Flink CDC里这两部分交接器,有区别吗?3.0整合后,灵活性怎么感觉差了呢?

Flink CDC里使用3.0整库同步怎么配置scan.incremental.snapshot.chunk.key-column属性,Sqlserver整库同步现在是还不支持吗?

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

Flink CDC里这个是字段属性类型问题吗?

Flink CDC里这个是字段属性类型问题吗?java.lang.IllegalArgumentException: Variable character string length must be between 1 and 2147483647 (both inclusive).

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

Flink使用滑动窗口时报这个错,这个函数的参数有什么限制吗?必须有时间属性?

Flink使用滑动窗口时报这个错,这个函数的参数有什么限制吗?必须有时间属性?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注