最新版本读取kafka数据sink到ES，如果kafka数据是嵌套json，字段值在es中为null
Ninguém assumiu esta issue ainda.
Avaliação
- Dificuldade
- 4/5
- Tempo estimado
- 3-5 dias
- Facilidade para iniciantes
- 20/100
- Tipo de issue
- Bug
- Clareza
- Precisa de esclarecimento
- Status de atividade
- Estagnada
- Stack de tecnologia
- java
- Domínio
- data-engineering
Direção de pesquisa
Comece localizando o sink Kafka-to-Elasticsearch e seu caminho de mapeamento JSON aninhado; em seguida, reproduza o problema com o payload mostrado no relatório. O trabalho estará concluído quando for identificado por que o objeto lib se torna null e seus campos aninhados forem preservados no Elasticsearch, com um teste de regressão se a área de testes relevante for encontrada.
Escrita pelo modelo de indexação a partir do texto da issue.
Descrição
1、kafka中的数据格式为：
{
"distinct_id": "16c6a9eeabd205-08b9c3c13daa25-36f661a-269280-16c6a9eeabe1fd",
"lib": {
"$lib": "js",
"$lib_method": "code",
"$lib_version": "1.14.2"
}
}
2、sink到ES中的数据为
{
"_index": "flink2es",
"_type": "mytype_1",
"_id": "16c6a9eeabd205-08b9c3c13daa25-36f661a-269280-16c6a9eeabe1fd",
"_score": 1,
"_source": {
"lib": null,
"distinct_id": "16c6a9eeabd205-08b9c3c13daa25-36f661a-269280-16c6a9eeabe1fd"
}
}
请问嵌套格式的数据为什么是null？（这里指的：lib字段）
- Linguagem predominante
- Java
- Estrelas
- 2k
- Forks
- 913
- Métricas de merge de PRs
- Nenhum PR com merge em 30d
Guia de contribuição
Nenhum guia de contribuição indexado para este repositório
Primeiros passos
- Leia a issue inteira e depois o guia de contribuição do projeto.
- Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
- Faça um fork do repositório e trabalhe em uma branch.
- Abra um pull request que referencie o número da issue.
Mais de DTStack/flinkStreamSQL
-
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 20/100
DTStack/flinkStreamSQL#467 · 1 comentário ·
-
Dificuldade 4/5 3-5 dias Facilidade para iniciantes 25/100
DTStack/flinkStreamSQL#437 · 3 comentários ·
-
Dificuldade 3/5 1-2 dias Facilidade para iniciantes 38/100
DTStack/flinkStreamSQL#432 · 1 comentário ·
-
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法 Aberta
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 15/100
DTStack/flinkStreamSQL#430 · 1 comentário ·
Todas as issues de DTStack/flinkStreamSQL
Issues semelhantes
-
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 65/100
-
bug
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 75/100
-
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 75/100
elastic/gradle-plugins#157 ·
-
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 75/100
cryptomator/hub#497 ·
-
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 75/100
johanhaleby/occurrent#1120 ·