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

Flink SQL复杂JSON解析

像如下这种JSON输入, { "id": 1, "many_names": [ {"name": "foo"}, {"name": "bar"} ] } 输出表两行 id 1, name foo | id 1, name bar 最佳实践是从Kafka读到后,调用TableFunction这个UDTF转出多行? 还是Flink SQL有更方便的操作,从Source读出来就能把...

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

嵌套 json 中string 数组的解析异常

我使用 flink 1.9 处理嵌套 json, 它嵌套了一个string数组,构造出的 table schema结构为: Row(parsedResponse: BasicArrayTypeInfo , timestamp: Long) 执行作业后会发生报错如下,出现 object 类型和string 类型的转换错误 Caused by: java.lang.ClassCas...

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

Flink SQL 解析复杂(嵌套)JSON的问题 以及写入到hive类型映射问题

json格式,如果是一个json array 该如何定义 schema,array里还可能存在嵌套json array的情况。 如数据: {"user_info":{"user_id":"0111","name":"xxx"},"timestam":1586676835655,"id":"10001","jsonArray":[{"name222":"xxx","user_id222":"00.....

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

Flink SQL 解析复杂(嵌套)JSON 的问题以及写入到 hive 映射问题

json格式,如果是一个json数组的方法定义模式,数组里还可能存在隐藏json数组的情况。 如数据: {"user_info":{"user_id":"0111","name":"xxx"},"timestam":1586676835655,"id":"10001","jsonArray":[{"name222":"xxx" ,"user_id222":"0022"},{"name333":.....

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

flink 1.11 cdc: kafka中存了canal-json格式的多张表信息,需要按表解析做

mysql表: CREATE TABLE test ( id int(11) NOT NULL, name varchar(255) NOT NULL, time datetime NOT NULL, status int(11) NOT NULL, PRIMARY KEY (id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 CREATE TABLE statu.....

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

SQL解析复杂JSON问题

麻烦问下我已经在字段上面定了结构,还需要再写format.json-schema吗?CREATE TABLE user_log( id VARCHAR, timestam VARCHAR, user_info ROW(user_id string, name string ), jsonArray ARRAY ) WITH ( 'connector.type' = 'kafka', 'conne....

文章 2021-12-05 来自:开发者社区

Unexpected token o in JSON at position 1 前端JSON数据包解析的问题

这几天在做微服务项目开发的时候发现json数据报错了这个问题其实就是一个json数据的解析问题,JSON的parse方法在解析成json对象的时候方法内参数必须是一个json数据格式的字符串!!!注意是字符串,而且是json格式的才能解析出来,否则会报错。我在cookie中放的值是一个对象类型之后我又将其取出来,又没有对其做任何操作,就放入方法中解析。当然会被当成对象类型进行解析,导致程序出现了....

Unexpected token o in JSON at position 1 前端JSON数据包解析的问题
问答 2021-12-05 来自:开发者社区

kafka数据写入kafka flink1.10-sql解析复杂json中字段string,数据丢失

kafka数据写入kafka 数据,flink1.10-sql解析复杂json中字段为string,导致数据丢失。 来自志愿者整理的flink邮件归档来自志愿者整理的FLINK邮件归档

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

link sql1.10有解析json的udf吗?

请问,flink sql1.10有解析json的udf吗?没有找到*来自志愿者整理的FLINK邮件归档

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

解析kafka 非标准JSON问题,如何解决?

您好!请问遇到如下格式的该如何用SQL解析。 string {name=string} {id : 1, name : abram} eg: 2021-04-03xxxxx {name=aaaaaa} {id : 1, name : abram} 最重要为第三个字段 JSON,里面包含了data 第一和第二个字段可要可不要     请问,有思路可以参考吗?或者demo...

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

开发与运维

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

+关注