[incubator-seatunnel] branch dev updated: [Improve][Connectors]Remove DBI related operations (#1582)

[kirs]

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

kirs 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 2b560b7  [Improve][Connectors]Remove DBI related operations (#1582)
2b560b7 is described below

commit 2b560b705d900632f8bc2a0279feee38bfa26e82
Author: Kirs <k...@apache.org>
AuthorDate: Sat Mar 26 23:26:33 2022 +0800

    [Improve][Connectors]Remove DBI related operations (#1582)
    
    * [Improve][Connectors]Remove DBI related operations
    DBI is not a good recommended method, there are problems in performance and 
readability
    
    * fix codestyle
---
 .../java/org/apache/seatunnel/flink/sink/Elasticsearch.java  | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git 
a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
 
b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
index 6965947..1eccaa6 100644
--- 
a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
+++ 
b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
@@ -80,13 +80,11 @@ public class Elasticsearch implements FlinkStreamSink, 
FlinkBatchSink {
 
     @Override
     public void prepare(FlinkEnvironment env) {
-        Config defaultConfig = ConfigFactory.parseMap(new HashMap<String, 
String>(DEFAULT_CONFIG_SIZE) {
-            {
-                put(INDEX, DEFAULT_INDEX);
-                put(INDEX_TYPE, DEFAULT_INDEX_TYPE);
-                put(INDEX_TIME_FORMAT, DEFAULT_INDEX_TIME_FORMAT);
-            }
-        });
+        Map<String, String> configMap = new HashMap<>(DEFAULT_CONFIG_SIZE);
+        configMap.put(INDEX, DEFAULT_INDEX);
+        configMap.put(INDEX_TYPE, DEFAULT_INDEX_TYPE);
+        configMap.put(INDEX_TIME_FORMAT, DEFAULT_INDEX_TIME_FORMAT);
+        Config defaultConfig = ConfigFactory.parseMap(configMap);
         config = config.withFallback(defaultConfig);
     }