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

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

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

问题一:嵌套 json 中string 数组的解析异常 我使用 flink 1.9 处理嵌套 json, 它嵌套了一个string数组,构造出的 table schema结构为: Row(parsedResponse: BasicArrayTypeInfo , timestamp: Long) 执行...

在Flink比如像string_split里面的字符串不固定,目前阿里云Flink貌似还不支持?

在Flink比如像string_split里面的字符串不固定,可能是, 可能是$ 可能是| 目前阿里云Flink貌似还不支持?我预期是:目标字符串:Jack,John,Mary$A$B$C|D|E结果:JackJohnMaryABCDE

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

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

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

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

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

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

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

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

[帮助文档] 如何使用STRING_SPLIT函数_实时计算 Flink版(Flink)

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

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

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

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

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

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

社区圈子

开发与运维
开发与运维
集结各类场景实战经验,助你开发运维畅行无忧
6428+人已加入
加入
相关实验场景
更多