cluster-name: daily #集群名
transports: localhost:9300 #es集群地址
index: flink-test #写死索引名
#index-field: first #指定索引列
failure-handler: IGNORE #写入失败处理策略,参考FailureHandler
config: #es sink的额外配置
bulk.flush.max.actions: 100
cluster-name: daily #集群名
transports: localhost:9300 #es集群地址
index: flink-test #写死索引名
#index-field: first #指定索引列
failure-handler: IGNORE #写入失败处理策略,参考FailureHandler
config: #es sink的额外配置
bulk.flush.max.actions: 100