Elasticsearch6UpsertTableSink how to trigger es delete index。

Hi，    When I use Elasticsearch6UpsertTableSink, and It seems implements delete index. Like code:             @Overridepublic void process(Tuple2, Row> element, RuntimeContext ctx, RequestIndexer indexer) { if (element.f0) { process

Re: Elasticsearch6UpsertTableSink how to trigger es delete index。

Hi, Take a look at the documentation. This [1] describes an example were a running query can produce updated results (and thus retracting the previous results). [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/dynamic_tables.html#table-to-stream-conversion