测试类

Author: dapeng

launcher/src/main/test/java/com/dtstack/flink/sql/launcher/PluginLoadModeTest.java

@@ -48,8 +48,22 @@ public static void testClasspathMode() throws Exception {
         LauncherMain.main(sql);
     }
 
+    
+    public static void testRocSql() throws Exception{
+        String[] sql = new String[]{"-mode", "local", "-sql", "/Users/roc/Documents/flink_sql/sql/zy_sql/hbase_side.sql", "-name", "roc",
+                "-localSqlPluginPath", "/Users/roc/workspace/git_code/flinkStreamSQL/plugins",
+                "-remoteSqlPluginPath", "/Users/roc/workspace/git_code/flinkStreamSQL/plugins",
+                "-flinkconf", "/Users/roc/Documents/flink_sql/flinkconf",
+                "-confProp", "{\"sql.checkpoint.cleanup.mode\":\"false\",\"sql.checkpoint.interval\":10000,\"time.characteristic\":\"EventTime\"}",
+                "-yarnconf", "/Users/roc/Documents/flink_sql/yarnconf",
+                "-flinkJarPath", "/Users/roc/Documents/flink_sql/flinkJarPath", "-queue", "c", "-pluginLoadMode", "classpath"};
+        System.setProperty("HADOOP_USER_NAME", "admin");
+        LauncherMain.main(sql);
+    }
+
     public static void main(String[] args) throws Exception {
-        testShipfileMode();
+        testRocSql();
+//        testShipfileMode();
 //        testClasspathMode();
     }
 }