防止null point

src/main/java/com/dsk/flink/dsc/common/function/CanalMapToTsGroupFunction.java

@@ -20,7 +20,7 @@ public class CanalMapToTsGroupFunction implements MapFunction<JSONObject, Tuple3
         String table = value.getString("table");
         JSONArray pkNames = value.getJSONArray("pkNames");
         Set<String> pkNameSet = new HashSet<>();
-        long ts = value.getLong("ts");
+        long ts = value.getLong("ts") == null ? System.currentTimeMillis() : value.getLong("ts");
         if (CollUtil.isNotEmpty(pkNames)) {
             pkNames.forEach(name -> pkNameSet.add(String.valueOf(name)));
         }