添加时间备注

fansy1990 · Dec 21, 2018 · 055fa4e · 055fa4e
1 parent b77b882
commit 055fa4e
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/test_demo/src/main/java/statics/DescribeStaticsDemo.java b/test_demo/src/main/java/statics/DescribeStaticsDemo.java
@@ -12,16 +12,27 @@
  * @Email: [email protected]
  */
 public class DescribeStaticsDemo {
+    static String mainClass = "statics.DescribeStatics";
     public static void main(String[] args) throws IOException {
 //        Prepare.uploadJar();
-        first();
+//        first();
+        second();
     }
 
     public static void first() {
-        String mainClass = "statics.DescribeStatics";
         String appName = "demo_30m statics";
         String[] arguments = {"default.demo_30m", "default.demo_30m_statics", appName};
         Args innerArgs = Args.getArgs(appName, mainClass, arguments, EngineType.SPARK);
         SparkYarnJob.runAndMonitor(innerArgs);
     }
+
+    /**
+     * 1个 ApplicationMaster ； 2个子节点Executor； 耗时4.7 mins
+     */
+    public static void second(){
+        String appName = "demo_600w statics";
+        String[] arguments = {"default.demo_600w", "default.demo_600w_statics", appName};
+        Args innerArgs = Args.getArgs(appName, mainClass, arguments, EngineType.SPARK);
+        SparkYarnJob.runAndMonitor(innerArgs);
+    }
 }