Oneway Chen created FLINK-20210: ----------------------------------- Summary: "RequestFactory" interface in flink elasticsearch connector doesn't support "routing" param Key: FLINK-20210 URL: https://issues.apache.org/jira/browse/FLINK-20210 Project: Flink Issue Type: Improvement Components: Connectors / ElasticSearch Reporter: Oneway Chen
_org.apache.flink.streaming.connectors.elasticsearch.table.RequestFactory_ This interface doesn't support the "routing" param in its three functions. When the "routing" param is obligatory, such as Parent-Child Mapping, it will be quite inconvenient to use the connector directly. So is it possible to extend this interface? accordingly, this classes may be changed: _org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSink_ _org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch7DynamicSink_ _org.apache.flink.streaming.connectors.elasticsearch.table.RowElasticsearchSinkFunction_ -- This message was sent by Atlassian Jira (v8.3.4#803005)