redis 结果表提交

Author: dapeng

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

@@ -48,8 +48,21 @@ public static void testClasspathMode() throws Exception {
         LauncherMain.main(sql);
     }
 
+    public static void testroc() throws Exception {
+        String[] sql = new String[]{"-mode", "local", "-sql", "/Users/roc/Documents/flink_sql/sql/result/redis_result.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();
+        testroc();
+//        testShipfileMode();
 //        testClasspathMode();
     }
 }

pom.xml

@@ -16,24 +16,24 @@
         <module>kafka11</module>
         <module>kafka</module>
         <module>mysql</module>
-<!--        <module>hbase</module>-->
-<!--        <module>elasticsearch5</module>-->
-<!--        <module>mongo</module>-->
-<!--        <module>redis5</module>-->
+        <module>hbase</module>
+        <module>elasticsearch5</module>
+        <module>mongo</module>
+        <module>redis5</module>
         <module>launcher</module>
         <module>rdb</module>
-<!--        <module>sqlserver</module>-->
-<!--        <module>oracle</module>-->
-<!--        <module>cassandra</module>-->
+        <module>sqlserver</module>
+        <module>oracle</module>
+        <module>cassandra</module>
         <module>kudu</module>
-<!--        <module>postgresql</module>-->
-<!--        <module>serversocket</module>-->
+        <module>postgresql</module>
+        <module>serversocket</module>
         <module>console</module>
-<!--        <module>clickhouse</module>-->
-<!--        <module>impala</module>-->
-<!--        <module>db2</module>-->
-<!--        <module>polardb</module>-->
-<!--        <module>elasticsearch6</module>-->
+        <module>clickhouse</module>
+        <module>impala</module>
+        <module>db2</module>
+        <module>polardb</module>
+        <module>elasticsearch6</module>
 
     </modules>