DTStack / DTStack/flinkStreamSQL
最新版本读取kafka数据sink到ES,如果kafka数据是嵌套json,字段值在es中为null
- Vorherrschende Sprache
- Java
- Sterne
- 2k
- Forks
- 913
- PR-Merge-Kennzahlen
- Keine gemergten PRs in 30 T.
Beschreibung
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字段)
Beitragsleitfaden
Für dieses Repository ist kein Beitragsleitfaden indexiert
Bewertung
Dieses Issue wurde noch nicht bewertet.