feat:添加v2同步逻辑

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/ODPSToRedis.java

@@ -126,16 +126,12 @@ public class ODPSToRedis {
         int finalPartationNum = Math.min(maxPartitionNum, calcPartationNum);
 
         log.info("argMap.maxPartitionNum: {} calcPartationNum: {}, finalPartationNum: {}", maxPartitionNum, calcPartationNum, finalPartationNum);
+        log.info("config: {}, dtsConfigV2: {}", config,dtsConfigV2);
         fieldValues.repartition(finalPartationNum).foreachPartition(iterator -> {
             redisService.mSetV2(iterator, config);
+            redisService.mSetV2(iterator, dtsConfigV2);
         });
 
-        if (Objects.nonNull(dtsConfigV2)){
-            fieldValues.repartition(finalPartationNum).foreachPartition(iterator -> {
-                redisService.mSetV2(iterator, dtsConfigV2);
-            });
-        }
-
         redisService.setMonitor(config, argMap);
 
         jsc.stop();