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

使用flink cdc监听一个mysql表的binlog,debezuim反序列化日志 报错,为什么

使用flink cdc监听一个mysql表的binlog,但是现在再该库下新增了一个表,但是由于字段类型不对,然后修改了字段,然后就导致 debezuim反序列化日志 报错,为什么?

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

Flink CDC 哪位老哥能告知一下,在数据库里显示的是数字,用flinkcdc采集反序列化后成

Flink CDC 哪位老哥能告知一下,在数据库里显示的是数字,用flinkcdc采集反序列化后成了字符串了,而且不是数字的字符串

问答 2022-08-30 来自:开发者社区

flink-cdc自定义的反序列化,sink无输出,有人知道原因吗

flink-cdc自定义的反序列化,sink无输出,有人知道原因吗

文章 2022-06-09 来自:开发者社区

Flink 1.14.0 消费 kafka 数据自定义反序列化类

在最近发布的 Flink 1.14.0 版本中对 Source 接口进行了重构,细节可以参考 FLIP-27: Refactor Source Interface重构之后 API 层面的改动还是非常大的,那在使用新的 API 消费 kafka 数据的时候如何自定义序列化类呢?Kafka SourceKafkaSource<String> source = KafkaSourc...

问答 2021-12-07 来自:开发者社区

Flink kafka Consumer的反序列化数据是什么?

Flink kafka Consumer的反序列化数据是什么?

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

本地测试 flink 1.10 hbase sql create table 在反序列化byte之后

$stringUtil.substring( $!{XssContent1.description},200)...

问答 2021-12-03 来自:开发者社区

job独立提交到到Flink per-job cluster 就报kafka反序列化错怎么解决?

$stringUtil.substring( $!{XssContent1.description},200)...

问答 2021-12-03 来自:开发者社区

Flink JSON反序列化DECIMAL精度丢失

https://issues.apache.org/jira/browse/FLINK-20170 这是我今天提的issue。 Jackson这样反序列化会把BigDECIMAL转成Double。超过12位的小数精度丢失。这种情况我得怎么办。只能先当做STRING类型处理或修改下JSON这个包的源码重新变一下。 还有其他的最佳实践吗*来自志愿者整理的flink邮件归档

问答 2021-01-06 来自:开发者社区

Flink Pojo 的序列化与反序列化的类型规则是怎样的

Flink Pojo 的序列化与反序列化的类型规则是怎样的

问答 2021-01-06 来自:开发者社区

在 Flink 通信层的序列化中,何时进行真正的序列化 / 反序列化操作?

在 Flink 通信层的序列化中,何时进行真正的序列化 / 反序列化操作?

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

产品推荐

阿里云实时计算Flink

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

+关注