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

Flink两个流 需要关联,但是条件是A流的一个字段(字符串)包含B流的 一个字段?

Flink两个流 需要关联,但是条件是A流的一个字段(字符串)包含B流的 一个字段,前辈们有过类似经验吗 用join或者 connect写不出来呀?

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

请问一下,flink sql udf 通过字符串这样传进来,大家有没有一个好的实现办法呀?

请问一下,flink sql udf 通过字符串这样传进来,然后用groovy编译成Class,然后通过tableEnv去注册,这样会报错。大家有没有一个好的实现办法呀?外面传个字符串就能注入进tableEnv的udf的

文章 2024-01-02 来自:开发者社区

Flink CDC 3.0 对于字符串类型的切片键(sharding key)确实存在一些问题

是的,Flink CDC 3.0 对于字符串类型的切片键(sharding key)确实存在一些问题,它不能直接进行切分。这是因为 Flink CDC 3.0 默认使用 HashPartitioner 对数据进行分区,而 HashPartitioner 只能处理数值类型的键。 为了解决这个问题,你可以考虑以下几种...

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

flink cdc 3.0对切片key是字符串不能进行切分吗?

Flink CDC 3.0 确实支持对切片key进行字符串切分。您可以使用STRING_SPLIT函数,根据指定的分隔符将目标字符串拆分为子字符串,并返回子字符串列表。例如,如果需要按照逗号进行切分,可以在配置中使用'table-name' = 't_process_wihistory\d{1,2}'...

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

flink cdc 3.0对切片key是字符串不能进行切分吗?

flink cdc 3.0对切片key是字符串不能进行切分吗?

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

Apache Flink SQL目前还不支持直接解析JSON字符串并将其转换为预期的数据类型

Apache Flink SQL目前还不支持直接解析JSON字符串并将其转换为预期的数据类型。你可以在Flink SQL中使用STRING_TO_ARRAY函数将字符串转换为数组。 以下是一个示例,展示了如何将字符串转换为数组: SELECT STRING_TO_ARRAY(JSON_QUERY('{"a":[{"c":"...

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

Flink CDC中“null”是字符串不是空转不了long?

Flink CDC中“null”是字符串不是空转不了long?

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

Flink CDC 过来之后是乱码的字符串是什么原因呢?

Flink CDC SQL server表中字段类型是numeric(12,2),cdc过来之后是乱码的字符串是什么原因呢?

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

Flink使用fastjson 字符串 转json 方法 内存满了 ,有什么更好的方法 处理吗?

Flink使用fastjson 字符串 转json 方法 内存满了 ,有什么更好的方法 处理吗。

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

Flink CDC中sqlserver cdc 千万级别表结构,字符串主键,有没有什么好的解决方案?

Flink CDC中sqlserver cdc 千万级别表结构,字符串主键,在cdc在切片过程中卡死,有没有什么好的解决方案?

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

产品推荐

阿里云实时计算Flink

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

+关注