LuNing Wang created FLINK-28107: ----------------------------------- Summary: Support id of document is null Key: FLINK-28107 URL: https://issues.apache.org/jira/browse/FLINK-28107 Project: Flink Issue Type: Bug Components: API / Python, Connectors / ElasticSearch Affects Versions: 1.16.0 Reporter: LuNing Wang Fix For: 1.16.0
``` es7_sink = Elasticsearch7SinkBuilder() \ .set_emitter(ElasticsearchEmitter.static_index('foo')) \ .set_hosts(['localhost:9200']) \ ``` Caused by: java.lang.NullPointerException at org.apache.flink.connector.elasticsearch.sink.SimpleElasticsearchEmitter$StaticIndexRequestGenerator.apply(SimpleElasticsearchEmitter.java:68) at org.apache.flink.connector.elasticsearch.sink.SimpleElasticsearchEmitter$StaticIndexRequestGenerator.apply(SimpleElasticsearchEmitter.java:55) at org.apache.flink.connector.elasticsearch.sink.SimpleElasticsearchEmitter.emit(SimpleElasticsearchEmitter.java:52) at org.apache.flink.connector.elasticsearch.sink.SimpleElasticsearchEmitter.emit(SimpleElasticsearchEmitter.java:30) at org.apache.flink.connector.elasticsearch.sink.ElasticsearchWriter.write(ElasticsearchWriter.java:123) at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.processElement(SinkWriterOperator.java:158) -- This message was sent by Atlassian Jira (v8.20.7#820007)