Hacktoberfest 2026: as issues que os mantenedores marcaram para outubro, abertas e boas para iniciantes. Ver issues do Hacktoberfest

嵌套json 解析后输出的数据为null

Aberta
#332 1 comentário 0 reações 0 responsáveis Ver no GitHub

Ninguém assumiu esta issue ainda.

Avaliação

Dificuldade
4/5
Tempo estimado
3-5 dias
Facilidade para iniciantes
35/100
Tipo de issue
Bug
Clareza
Precisa de esclarecimento
Status de atividade
Estagnada
Stack de tecnologia
java, kafka, sql
Domínio
data-engineering, stream-processing

Direção de pesquisa

Reproduza o relatório usando a DDL de origem Kafka fornecida, o JSON aninhado e a configuração sourcedatatype='json'. Comece rastreando o tratamento da fonte JSON do Kafka para a projeção aninhada info.uid; considera-se concluído quando a uid projetada contiver 427083 em vez de null.

Escrita pelo modelo de indexação a partir do texto da issue.

Descrição

嵌套json 解析后输出的数据 uid字段一直为null

json日志格式
{
"time":"2020-06-15 19:16:29.243",
"topic":"room_chat",
"appname":"ms",
"info":{
"uid":427083
}
}

kafkasource 建表语句
CREATE TABLE kafka11source (
appname VARCHAR ,
topic VARCHAR ,
info.uid bigint as uid,
time VARCHAR
)
WITH (
type='kafka11',
bootstrapServers='hadoop04:9092',
offsetReset='latest',
topic='room_topic',
groupId='flink_sql,
parallelism='2',
timezone='Asia/Shanghai',
topicIsPattern ='false',
sourcedatatype ='json'
);

Linguagem predominante
Java
Estrelas
2k
Forks
913
Nenhum PR com merge em 30d

Guia de contribuição

Nenhum guia de contribuição indexado para este repositório

Primeiros passos

  1. Leia a issue inteira e depois o guia de contribuição do projeto.
  2. Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
  3. Faça um fork do repositório e trabalhe em uma branch.
  4. Abra um pull request que referencie o número da issue.

Mais de DTStack/flinkStreamSQL

Todas as issues de DTStack/flinkStreamSQL

Issues semelhantes

Mais issues de Java

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.