嵌套json 解析后输出的数据为null
Personne n'a encore pris cette issue.
Évaluation
- Difficulté
- 4/5
- Temps estimé
- 3-5 jours
- Accessibilité débutants
- 35/100
- Type d'issue
- Bug
- Clarté
- À clarifier
- Activité
- À l'abandon
- Domaine
- data-engineering, stream-processing
Piste de recherche
Reproduisez le rapport avec la DDL de source Kafka fournie, le JSON imbriqué et la configuration sourcedatatype='json'. Commencez par suivre le traitement de la source JSON Kafka pour la projection imbriquée info.uid ; c'est terminé lorsque la uid projetée contient 427083 au lieu de null.
Rédigé par le modèle d'indexation à partir du texte de l'issue.
Description
嵌套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'
);
- Langage dominant
- Java
- Étoiles
- 2k
- Forks
- 913
- Métriques de merge des PR
- Aucune PR mergée en 30 j
Guide de contribution
Aucun guide de contribution indexé pour ce dépôt
Par où commencer
- Lisez l'issue en entier, puis le guide de contribution du projet.
- Signalez en commentaire que vous la prenez — cela évite que deux personnes fassent le même travail.
- Forkez le dépôt et travaillez sur une branche.
- Ouvrez une pull request qui référence le numéro de l'issue.
Autres issues de DTStack/flinkStreamSQL
-
Difficulté 5/5 Plus d'une semaine Accessibilité débutants 20/100
DTStack/flinkStreamSQL#467 · 1 commentaire ·
-
这个如何引入使用flink-connector-hive啊 Ouverte
Difficulté 4/5 3-5 jours Accessibilité débutants 25/100
DTStack/flinkStreamSQL#437 · 3 commentaires ·
-
Difficulté 3/5 1-2 jours Accessibilité débutants 38/100
DTStack/flinkStreamSQL#432 · 1 commentaire ·
-
新版FlinkStreamSQL已经融合进FlinkX项目 Ouverte
Difficulté 5/5 Plus d'une semaine Accessibilité débutants 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法 Ouverte
Difficulté 5/5 Plus d'une semaine Accessibilité débutants 15/100
DTStack/flinkStreamSQL#430 · 1 commentaire ·
Toutes les issues de DTStack/flinkStreamSQL
Issues similaires
-
certification
Difficulté 1/5 Moins d'une heure Accessibilité débutants 80/100
-
Difficulté 2/5 1-3 heures Accessibilité débutants 75/100
-
[BUG] ECR GetAuthorizationToken returns a proxyEndpoint for the default region, not the request's Ouvertebug ecr
Difficulté 2/5 1-3 heures Accessibilité débutants 75/100
-
Needs: Triage Type: Feature request
Difficulté 2/5 1-3 heures Accessibilité débutants 70/100
AntennaPod/AntennaPod#8794 ·
-
agentic-workflows
Difficulté 2/5 1-3 heures Accessibilité débutants 65/100
github/copilot-sdk#2760 ·