fix RTDmpFetch

src/main/java/mobvista/dmp/datasource/rtdmp/RTDmpFetch.java

@@ -122,6 +122,23 @@ public class RTDmpFetch {
         Tuple tuple = checkRules(jsonObject, startTime, endTime);
         if (tuple.getFlag()) {
             KV kv = mySqlUtil.getPartitionTime("dwh", " audience_merge_v1");
+            //  retry getPartitionTime
+            for (int i = 0; i < 5; i++) {
+                if (StringUtils.isBlank(kv.getK())) {
+                    kv = mySqlUtil.getPartitionTime("dwh", " audience_merge_v1");
+                } else {
+                    break;
+                }
+                try {
+                    Thread.sleep(10);
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+            if (StringUtils.isBlank(kv.getK())) {
+                LOGGER.info("getPartitionTime Blank !!! Please Check.");
+                System.exit(-1);
+            }
             String dt = DateUtil.format(DateUtil.parse(kv.getK().substring(0, 8), "yyyyMMdd"), "yyyy-MM-dd");
             String hour = kv.getK().substring(8, 10);
             // time of insert partition