You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ri...@apache.org on 2022/01/22 06:47:08 UTC
[incubator-seatunnel] branch dev updated: [Improve] Use the correct init size for Map in ES Flink Connector (#1122)
This is an automated email from the ASF dual-hosted git repository.
rickyhuo pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 7376665 [Improve] Use the correct init size for Map in ES Flink Connector (#1122)
7376665 is described below
commit 7376665d3ffc7023dec6ab39e71db514bdf85abb
Author: Benedict Jin <as...@apache.org>
AuthorDate: Sat Jan 22 14:47:02 2022 +0800
[Improve] Use the correct init size for Map in ES Flink Connector (#1122)
* [Improve] Use the correct init size for Map in ES Flink Connector
* Address comment
---
.../src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java b/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
index 1638e1b..54db14b 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
@@ -47,6 +47,8 @@ import java.util.Map;
public class Elasticsearch implements FlinkStreamSink<Row, Row>, FlinkBatchSink<Row, Row> {
+ private static final int DEFAULT_CONFIG_SIZE = 3;
+
private Config config;
private String indexName;
@@ -67,7 +69,7 @@ public class Elasticsearch implements FlinkStreamSink<Row, Row>, FlinkBatchSink<
@Override
public void prepare(FlinkEnvironment env) {
- Config defaultConfig = ConfigFactory.parseMap(new HashMap<String, String>(2) {
+ Config defaultConfig = ConfigFactory.parseMap(new HashMap<String, String>(DEFAULT_CONFIG_SIZE) {
{
put("index", "seatunnel");
put("index_type", "log");