DTStack / DTStack/flinkStreamSQL
es5和es的sink插件id参数不填时, 报空指针异常
未關閉
- 主要語言
- Java
- 星號
- 2k
- 分支
- 913
- PR 合併指標
- 30 天內沒有已合併 PR
描述
配置文件
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;
出现以下错误
貢獻指南
這個儲存庫沒有索引到貢獻指南
評估
這個 Issue 還沒有評估資料。