print log

Author: todd5167

cassandra/cassandra-side/cassandra-all-side/src/main/java/com/dtstack/flink/sql/side/cassandra/CassandraAllReqRow.java

@@ -268,7 +268,7 @@ private void loadData(Map<String, List<Map<String, Object>>> tmpCache) throws SQ
                         LOG.warn("get conn fail, wait for 5 sec and try again, connInfo:" + connInfo);
                         Thread.sleep(5 * 1000);
                     } catch (InterruptedException e1) {
-                        e1.printStackTrace();
+                        LOG.error("", e1);
                     }
                 }
 

hbase/hbase-side/hbase-all-side/src/main/java/com/dtstack/flink/sql/side/hbase/HbaseAllReqRow.java

@@ -180,14 +180,14 @@ private void loadData(Map<String, Map<String, Object>> tmpCache) throws SQLExcep
                 tmpCache.put(new String(r.getRow()), kv);
             }
         } catch (IOException e) {
-            e.printStackTrace();
+            LOG.error("", e);
         } finally {
             try {
                 conn.close();
                 table.close();
                 resultScanner.close();
             } catch (IOException e) {
-                e.printStackTrace();
+                LOG.error("", e);
             }
         }
     }

impala/impala-side/impala-side-core/src/main/java/com/dtstack/flink/sql/side/impala/table/ImpalaSideParser.java

@@ -22,6 +22,8 @@
 import com.dtstack.flink.sql.table.TableInfo;
 import com.dtstack.flink.sql.util.MathUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.math.BigDecimal;
 import java.sql.Date;
@@ -41,6 +43,7 @@
  */
 
 public class ImpalaSideParser extends RdbSideParser {
+    private static final Logger LOG = LoggerFactory.getLogger(ImpalaSideParser.class);
 
     private static final String CURR_TYPE = "impala";
 
@@ -113,7 +116,7 @@ public Map setPartitionFieldValues(String partitionfieldValuesStr){
             }
             return fieldValues;
         } catch (Exception e) {
-            e.printStackTrace();
+            LOG.error("",e);
             throw new RuntimeException(e);
         }
     }

kudu/kudu-side/kudu-all-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAllReqRow.java

@@ -152,7 +152,7 @@ private void loadData(Map<String, List<Map<String, Object>>> tmpCache) {
                         LOG.warn("get conn fail, wait for 5 sec and try again, connInfo:" + connInfo);
                         Thread.sleep(5 * 1000);
                     } catch (InterruptedException e1) {
-                        e1.printStackTrace();
+                        LOG.error("",e1);
                     }
                 }
             }

mongo/mongo-side/mongo-all-side/src/main/java/com/dtstack/flink/sql/side/mongo/MongoAllReqRow.java

@@ -229,7 +229,7 @@ private void loadData(Map<String, List<Map<String, Object>>> tmpCache) throws SQ
                         LOG.warn("get conn fail, wait for 5 sec and try again, connInfo:" + connInfo);
                         Thread.sleep(5 * 1000);
                     } catch (InterruptedException e1) {
-                        e1.printStackTrace();
+                        LOG.error("", e1);
                     }
                 }
             }

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/all/RdbAllReqRow.java

@@ -186,7 +186,7 @@ private void loadData(Map<String, List<Map<String, Object>>> tmpCache) throws SQ
                         LOG.warn("get conn fail, wait for 5 sec and try again, connInfo:" + connInfo);
                         Thread.sleep(5 * 1000);
                     } catch (InterruptedException e1) {
-                        e1.printStackTrace();
+                        LOG.error("", e1);
                     }
                 }
 

redis5/redis5-side/redis-all-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAllReqRow.java

@@ -21,6 +21,7 @@
 import com.dtstack.flink.sql.side.*;
 import com.dtstack.flink.sql.side.redis.table.RedisSideReqRow;
 import com.dtstack.flink.sql.side.redis.table.RedisSideTableInfo;
+import com.esotericsoftware.minlog.Log;
 import org.apache.calcite.sql.JoinType;
 import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
 import org.apache.flink.api.java.typeutils.RowTypeInfo;
@@ -150,7 +151,7 @@ private void loadData(Map<String, Map<String, String>> tmpCache) throws SQLExcep
                         LOG.warn("get conn fail, wait for 5 sec and try again, connInfo:" + jedisInfo);
                         Thread.sleep(5 * 1000);
                     } catch (InterruptedException e1) {
-                        e1.printStackTrace();
+                        LOG.error("", e1);
                     }
                 }
             }
@@ -207,7 +208,7 @@ private void loadData(Map<String, Map<String, String>> tmpCache) throws SQLExcep
                 try {
                     ((Closeable) jedis).close();
                 } catch (IOException e) {
-                    e.printStackTrace();
+                    Log.error("", e);
                 }
             }
             if (jedisSentinelPool != null) {