zihjiang

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

1

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

{"transform":[],"sink":[{"hosts":["192.168.100.203:9200"],"parallelism":"1","index_id_field":"","index":"filling-r","es.bulk.flush.interval.ms":1000,"source_table_name":"ElasticSearch_3692d1ca_3ba5","plugin_name":"Elasticsearch","es.bulk.flush.backoff.delay":50,"es.bulk.flush.backoff.retries":"8","es.bulk.flush.max.size.mb":2,"es.bulk.flush.max.actions":1000,"es.password":"1","name":"Elasticsearch","es.bulk.flush.backoff.enable":"true","es.username":"1"}],"source":[{"hosts":["192.168.1.242:9200"],"parallelism":"1","name":"ElasticSearch","index":"idx_1026","result_table_name":"ElasticSearch_3692d1ca_3ba5","plugin_name":"ElasticSearchSource"}],"env":{"execution.parallelism":1,"job.name":"es2es","execution.checkpoint.interval":1000}}

RT

例如ck, hive等大数据相关数据库, 用户名密码是可以为空的