You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/06/14 14:48:12 UTC
[flink] branch release-1.11 updated: [FLINK-18277][elasticsearch]
Fix the returned value of Elasticsearch6DynamicSink#asSummaryString()
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new 823b023 [FLINK-18277][elasticsearch] Fix the returned value of Elasticsearch6DynamicSink#asSummaryString()
823b023 is described below
commit 823b02319d33a83a3621fedac165bd250c33d155
Author: Qishang Zhong <zh...@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";
}
/**