Zhang Hechuan created FLINK-37265: ------------------------------------- Summary: document of python elasticsearch connector exeample has a mistake Key: FLINK-37265 URL: https://issues.apache.org/jira/browse/FLINK-37265 Project: Flink Issue Type: Bug Components: API / DataStream, API / Python, Connectors / ElasticSearch Affects Versions: 1.20.0, 1.19.0, 1.18.0, 1.17.0 Reporter: Zhang Hechuan
Elasticsearch 7 static index: {code:java} //代码占位符 from pyflink.datastream.connectors.elasticsearch import Elasticsearch7SinkBuilder, ElasticsearchEmitter env = StreamExecutionEnvironment.get_execution_environment() env.add_jars(ELASTICSEARCH_SQL_CONNECTOR_PATH) input = ... # The set_bulk_flush_max_actions instructs the sink to emit after every element, otherwise they would be buffered es7_sink = Elasticsearch7SinkBuilder() \ .set_bulk_flush_max_actions(1) \ .set_emitter(ElasticsearchEmitter.static('foo', 'id')) \ .set_hosts(['localhost:9200']) \ .build() input.sink_to(es7_sink).name('es7 sink') "ElasticsearchEmitter" has not method named "static", it should be "static_index"{code} -- This message was sent by Atlassian Jira (v8.20.10#820010)