es5和es的sink插件id参数不填时, 报空指针异常

[zihjiang]

配置文件
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;

出现以下错误

[zihjiang]

已经提交分支 解决此问题