kingbase

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

@@ -83,7 +83,7 @@ public class DbDataTransferFunction extends ProcessFunction<JSONObject, Tuple3<S
         String groupKey = groupKeyBuilder.toString();
 
         //添加分表参数
-        String shardingRule = dataObj.getString("shardingRule");
+        String shardingRule = value.getString("shardingRule");
         if (StrUtil.isNotBlank(shardingRule)) {
             Map<String,Object> map = JSON.parseObject(shardingRule, Map.class);
             String strategy = MapUtil.getStr(map, "strategy");