DTStack / DTStack/flinkStreamSQL
es5和es的sink插件id参数不填时, 报空指针异常
- Vorherrschende Sprache
- Java
- Sterne
- 2k
- Forks
- 913
- PR-Merge-Kennzahlen
- Keine gemergten PRs in 30 T.
Beschreibung
配置文件
CREATE TABLE kafka(
id varchar
)WITH(
bootstrapServers='10.10.14.117:9092',
timezone='Asia/Shanghai',
groupId='ddd',
parallelism='1',
topic='ddd',
offsetReset='latest',
sourcedatatype='dt_nest',
type='kafka');
CREATE TABLE es(
id varchar
)WITH(
sourceid='b93d1e56-0b17-4855-a60f-bd18fd245a78',
cluster='aiops-cluster',
address='10.10.14.51:9200',
parallelism='1',
index='myresult',
estype='_doc',
authMesh='false',
type='elasticsearch');
insert into es select id from kafka;
出现以下错误
Beitragsleitfaden
Für dieses Repository ist kein Beitragsleitfaden indexiert
Bewertung
Dieses Issue wurde noch nicht bewertet.