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

对于Flink CDC,数值型的列变成了字母串可能是什么问题?

对于Flink CDC,flink oracle cdc 3.1.1抽取时,数值型的列变成了字母串可能是什么问题?

文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之通过flink同步kafka数据进到doris,decimal数值类型的在kafka是正常显示数值,但是同步到doris表之后数据就变成了整数,该如何处理

问题一:Flink如果sink表建表字段过短,有数据不能插入,有啥策略配置能丢弃这些不合格的数据吗? Flink如果sink表建表字段过短,有数据不能插入,有啥策略配置能丢弃这些不合格的数据吗? configuration.set(ExecutionConfigOptions.TABLE_EXEC_SINK_TYPE_LENGTH_ENFORCER, ExecutionConfi...

实时计算 Flink版产品使用问题之通过flink同步kafka数据进到doris,decimal数值类型的在kafka是正常显示数值,但是同步到doris表之后数据就变成了整数,该如何处理
文章 2024-02-23 来自:开发者社区

Flink CDC 数据源问题之数值不匹配如何解决

问题一:请问Flink CDC可以在一个作业里面将数据源的不同数据以某种自定义规则同步到不同的hive库里? 请问Flink CDC可以在一个作业里面将数据源的不同数据以某种自定义规则同步到不同的hive库里吗? 参考回答: 是的,Flink CDC可以在一个作业中将数据源的不同数据以某种自定义规则同步到不同的Hive库里。您可以使用Flink的Dat...

Flink CDC 数据源问题之数值不匹配如何解决
问答 2024-02-06 来自:开发者社区

Flink CDC里我mysql 数据库有个表它的字段定义为date类型,数值变化什么原因?

Flink CDC里我mysql 数据库有个表它的字段定义为date类型,比如在数据库中存储的值为2024-02-01,用flink cdc读取binlog这个字段的值变成了数字19754,是什么原因,该怎么解决?

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

Flink CDC里任务运行时间过长 cache缓存占用了大量资源 ,有没有具体数值可以参考?

Flink CDC里任务运行时间过长 cache缓存占用了大量资源 我想让cache资源自动释放或者减少使用内存 是它回答的这样嘛 设置状态后端最大值 如果设置了这个会不会导致任务有可能找不到状态报错 有没有具体的参数值可以参考下?

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

Flink CDC有例子吗,传入的是字段数值?

Flink CDC有例子吗,传入的是字段数值?我只想sink 到部分表,表结构差不多的,我用RichSinkFunction 自定义sink到数据库表,但感觉还是用官方的jdbcsink性能好

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

Flink CDC这个memory在完成全量进入增量阶段后,数值能否有明显下降?

Flink CDC这个memory在完成全量进入增量阶段后,数值能否有明显下降?

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

要求是每来一条输出一次结果,计算一个数值按照group id,Flink有啥办法处理嘛?

要求是每来一条输出一次结果,计算一个数值按照group id,现在发现我一次发多条数据的时候,可能会触发一起计算,不是一条条的,Flink有啥办法处理嘛?

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

Flink CDC要求是每来一条输出一次结果,计算一个数值按照group id,有啥办法处理嘛?

Flink CDC要求是每来一条输出一次结果,计算一个数值按照group id,现在发现我一次发多条数据的时候,可能会触发一起计算,不是一条条的,有啥办法处理嘛?select id, count(1) over w as idcountfrom KafkaSourcewindow w as ( partition by id order by proc_time ...

问答 2023-10-18 来自:开发者社区

Flink CDC在使用过程中,decimal类型的数值过大会出现负值有碰到过吗 ?

Flink CDC在使用过程中,decimal类型的数值过大会出现负值有碰到过吗 ?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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