[flink] branch master updated: [FLINK-18277][elasticsearch] Fix the returned value of Elasticsearch6DynamicSink#asSummaryString()

[jark]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new da33f94  [FLINK-18277][elasticsearch] Fix the returned value of 
Elasticsearch6DynamicSink#asSummaryString()
da33f94 is described below

commit da33f940a42aa72d27ca1af6b84290c74ea9a9c1
Author: Qishang Zhong <zhongo...@gmail.com>
AuthorDate: Fri Jun 12 21:22:52 2020 +0800

    [FLINK-18277][elasticsearch] Fix the returned value of 
Elasticsearch6DynamicSink#asSummaryString()
    
    This closes #12633
---
 .../connectors/elasticsearch/table/Elasticsearch6DynamicSink.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java
 
b/flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java
index 4e9a8f85..b7fd44d 100644
--- 
a/flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java
+++ 
b/flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java
@@ -157,7 +157,7 @@ final class Elasticsearch6DynamicSink implements 
DynamicTableSink {
 
        @Override
        public String asSummaryString() {
-               return "Elasticsearch7";
+               return "Elasticsearch6";
        }
 
        /**