[improve][writer][tdengine] remove unused variable.

wgzhao · Feb 2, 2024 · 2cd981a · 2cd981a
1 parent a9f5b5a
commit 2cd981a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...riter/src/main/java/com/wgzhao/addax/plugin/writer/tdenginewriter/DefaultDataHandler.java b/...riter/src/main/java/com/wgzhao/addax/plugin/writer/tdenginewriter/DefaultDataHandler.java
@@ -343,7 +343,7 @@ else if (column.getType() == Column.Type.STRING) {
             count++;
         }
 
-        SchemalessWriter writer = null;
+        SchemalessWriter writer;
         try {
             writer = new SchemalessWriter(conn);
         } catch (SQLException e) {

diff --git a/...iter/src/main/java/com/wgzhao/addax/plugin/writer/tdenginewriter/OpentsdbDataHandler.java b/...iter/src/main/java/com/wgzhao/addax/plugin/writer/tdenginewriter/OpentsdbDataHandler.java
@@ -54,7 +54,7 @@ public OpentsdbDataHandler(Configuration config)
     @Override
     public int handle(RecordReceiver lineReceiver, TaskPluginCollector collector)
     {
-        int count = 0;
+        int count;
         try (Connection conn = DriverManager.getConnection(jdbcUrl, user, password);) {
             LOG.info("connection[ jdbcUrl: " + jdbcUrl + ", username: " + user + "] established.");
             writer = new SchemalessWriter(conn);