This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from a9f2e20375f [FLINK-27523][runtime] Runtime supports producing and
consuming cached intermediate results
add 11910d52cd1 [FLINK-28107][python][connector/elasticsearch] Support id
of document is null
No new revisions were added by this update.
Summary of changes:
.../sink/MapElasticsearchEmitter.java | 81 ++++++++++++++++++
.../sink/SimpleElasticsearchEmitter.java | 95 ----------------------
.../pyflink/datastream/connectors/elasticsearch.py | 12 +--
.../pyflink/datastream/tests/test_connectors.py | 40 ++++++++-
4 files changed, 125 insertions(+), 103 deletions(-)
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/MapElasticsearchEmitter.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/SimpleElasticsearchEmitter.java
