Skip to content

Latest commit

 

History

History
29 lines (23 loc) · 744 Bytes

elasticsearch.md

File metadata and controls

29 lines (23 loc) · 744 Bytes
Raw

elasticsearch

es5写入端配置

参考Es5SinkDescriptor

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

es6写入端配置

参考Es6SinkDescriptor

hosts:
    - localhost:9200
index: flink-test
document-type: test
failure-handler: IGNORE
config:
    bulk-flush-max-actions: 3