Merge branch '1.8_v3.10.15_lianlian' into hotfix_1.8_3.10.x_30145

kanata163 · kanata163 · commit 08e661a51d0d · 2020-09-07T11:46:19.000+08:00
* 1.8_v3.10.15_lianlian:
  修改查询频率
diff --git a/flinkx-core/src/main/java/com/dtstack/flinkx/latch/BaseLatch.java b/flinkx-core/src/main/java/com/dtstack/flinkx/latch/BaseLatch.java
@@ -28,7 +28,7 @@
  */
 public abstract class BaseLatch {
 
-    protected static int MAX_RETRY_TIMES = 100;
+    protected static int MAX_RETRY_TIMES = 30;
 
     /**
      * 从Flink REST API获取累加器里的值
@@ -52,7 +52,7 @@ public void waitUntil(int val) {
     }
 
     protected void sleep() {
-        SysUtil.sleep(300);
+        SysUtil.sleep(1000);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -28,7 +28,7 @@`
`28`	`28`	`*/`
`29`	`29`	`public abstract class BaseLatch {`
`30`	`30`
`31`		`- protected static int MAX_RETRY_TIMES = 100;`
	`31`	`+ protected static int MAX_RETRY_TIMES = 30;`
`32`	`32`
`33`	`33`	`/**`
`34`	`34`	`* 从Flink REST API获取累加器里的值`
`@@ -52,7 +52,7 @@ public void waitUntil(int val) {`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`protected void sleep() {`
`55`		`- SysUtil.sleep(300);`
	`55`	`+ SysUtil.sleep(1000);`
`56`	`56`	`}`
`57`	`57`
`58`	`58`	`/**`