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

Flink传入是String,输出也是STRING。但是总是报类型强转失败呢。请问这是怎么回事啊?

Flink传入是String,输出也是STRING。但是总是报类型强转失败呢。请问这是怎么回事啊?

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

Flink问题之嵌套 json 中string 数组的解析异常如何解决

问题一:嵌套 json 中string 数组的解析异常 我使用 flink 1.9 处理嵌套 json, 它嵌套了一个string数组,构造出的 table schema结构为: Row(parsedResponse: BasicArrayTypeInfo , timestamp: Long) 执行作业后会发生报错如下,出现 object 类型和string 类...

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

我用的是flink kubernetes operator, 不支持string类型,怎么办?

我用的是flink kubernetes operator, 不支持string类型,改成0.1是可以的,但limit是不生效的 怎么办?

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

Flink sql有没有函数支持解析一个json string并转成期望的数据类型呢?

Flink sql有没有函数支持解析一个json string并转成期望的数据类型呢?JSON_QUERY('{"a":[{"c":"c1"},{"c":"c2"}]}', 'lax $.a[*].c')这个内置函数返回的是string: '["c1","c2"]',而我期望返回的是ARRAY: ["c1","c2"]

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

flink sql有没有函数支持解析一个json string并转成期望的数据类型呢?

flink sql有没有函数支持解析一个json string并转成期望的数据类型呢?JSON_QUERY('{"a":[{"c":"c1"},{"c":"c2"}]}', 'lax $.a[].c')这个内置函数返回的是string: '["c1","c2"]',而我期望返回的是ARRAY: ["c1","c2"]所以期望的sql长这样select parse_json( JSON_QU...

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

Flink CDC你说的用string代替,我没明白什么意思,可以详细点吗?

Flink CDC你说的用string代替,我没明白什么意思,可以详细点吗;这种如果配置加大内存的话,应该加大哪个内存参数呢?

阿里云文档 2023-09-03

如何使用STRING_SPLIT函数_实时计算 Flink版(Flink)

本文为您介绍如何使用STRING_SPLIT函数,根据指定的分隔符将目标字符串拆分为子字符串,并返回子字符串列表。

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

Flink CDC中这个报错如何解决?我换成string也不行同样的报错。

问题1:Flink CDC中这个报错如何解决?我换成string也不行同样的报错。我没有加默认值,源表的默认值,我在flink cdc source中就给了个decimal sink Kafka也是decimal ,还是同样的错误。抽取没有问题 就是sink kafka 有问题。问题2:那问题是什么错,我改成了string 也不想 decimal也不行,主要是 同样的代码放在idea没有问...

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

为啥flink jdbc会把我hive的array类型转成string啊?array int 和ar

为啥flink jdbc会把我hive的array类型转成string啊?array int 和array string都变成string了?是hive jdbc干的

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

Flink CDC MySqlSource<String> 消息发出来是怎么回事?

Flink CDC MySqlSource mySqlSource = sourceBuilder.deserializer(schema).includeSchemaChanges(true).build();设置了includeSchemaChanges(true)后表添加新列没有schema change消息发出来是怎么回事?

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

开发与运维

集结各类场景实战经验,助你开发运维畅行无忧

+关注