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

Flink数据库只有5个字段 这里为什么会有6个value的?

Flink数据库只有5个字段 这里为什么会有6个value的?在测试非null字段修改长度 测试完 我把starrocks表删除 重新启动任务 结果数据同步失败了

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

实时计算Flink使用kafkasource的时候怎么获取到完整的value

实时计算Flink使用kafkasource的时候怎么获取到完整的value

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

Flink有没有参数设置,将写入key置为空,整行的数据都写入value中?

我同步mysql表到kafka,使用CTAS同步, 现在表写入kafka了,但是整条数据被拆分为key和value, 如下图,Flink有没有参数设置,将写入key置为空,整行的数据都写入value中?

问答 2024-05-30 来自:开发者社区

Flink报错IllegalArgumentException: timeout value ...

Flink报错IllegalArgumentException: timeout value is negative

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

实时计算 Flink版sql如何接受kafka中value是[{},{}]格式的数据?

实时计算 Flink版sql如何接受kafka中value是[{},{}]格式的数据?目前找到的全是{},一条的数据格式

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

Flink CDC里flinksql如何接受kafka中value是[{},{}]格式的数据?

Flink CDC里请问谁知道flinksql如何接受kafka中value是[{},{}]格式的数据?

文章 2023-12-02 来自:开发者社区

Flink CDC对于这种DEFAULT VALUE 序列化不支持?

Flink CDC 在处理 DEFAULT VALUE(默认值)时,通常会根据数据库的数据类型进行序列化和反序列化。在某些情况下,对于某些特殊的数据类型或 DEFAULT VALUE 的设置,可能会存在一些不支持的情况。 具体来说,如果 DEFAULT VALUE 涉及到自定义序列化或复杂的数据类型转换ÿ...

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

Flink CDC对于这种DEFAULT VALUE 序列化不支持?

Flink CDC对于这种DEFAULT VALUE 序列化不支持?

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

Flink该怎么取对应key的value呢?我用json获取方法不行,其它也没看到适合的函数。

Flink该怎么取对应key的value呢?我用json获取方法不行,其它也没看到适合的函数。

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

Flink CDC中column default value的转换能关闭吗?

Flink CDC中column default value的转换能关闭吗?

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

产品推荐

阿里云实时计算Flink

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

+关注