transactionLog 数据清洗 main类修改123

src/main/java/cn/quantgroup/dbc/spark/transactionlog/CleanningTransactionLogMain.java

@@ -19,6 +19,7 @@ import java.util.Map;
 public class CleanningTransactionLogMain {
 
     public static void main(String[] args) {
+        System.out.println("接收到参数: "+JSON.toJSONString(args));
         SparkSession ss = SparkSession.builder().appName("DBC").getOrCreate();
         System.out.println("开始加载数据");
         String hdfsPath = "hdfs:///app/user/data/user_data/feng.ren/transactionLog20191226/id=";