auto tag

recommend-feature-produce/pom.xml

@@ -113,10 +113,15 @@
             <artifactId>snappy-java</artifactId>
             <version>1.1.8.4</version>
         </dependency>
+<!--        <dependency>-->
+<!--            <groupId>com.squareup.okhttp3</groupId>-->
+<!--            <artifactId>okhttp</artifactId>-->
+<!--            <version>3.14.9</version>-->
+<!--        </dependency>-->
         <dependency>
-            <groupId>com.squareup.okhttp3</groupId>
+            <groupId>com.squareup.okhttp</groupId>
             <artifactId>okhttp</artifactId>
-            <version>3.14.9</version>
+            <version>2.7.5</version>
         </dependency>
     </dependencies>
     <build>

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

@@ -8,7 +8,7 @@ import com.tzld.piaoquan.recommend.feature.produce.service.ODPSService;
 import com.tzld.piaoquan.recommend.feature.produce.service.RedisService;
 import com.tzld.piaoquan.recommend.feature.produce.util.JSONUtils;
 import lombok.extern.slf4j.Slf4j;
-import okhttp3.*;
+import com.squareup.okhttp.*;
 import org.apache.commons.collections.MapUtils;
 import org.apache.commons.lang3.math.NumberUtils;
 import org.apache.spark.SparkConf;
@@ -34,11 +34,13 @@ public class ODPSToRedis {
 
 //        argMap.put("project", "loghubods");
 //        argMap.put("table", "alg_video_source_feature_day");
-//        argMap.put("dt", "20250210");
+//        argMap.put("dt", "20250610");
 //        argMap.put("hh", "13");
 //        argMap.put("mi", "00");
 //        argMap.put("env", "test");
 //        argMap.put("odpsBatchSize", "300000");
+//        argMap.put("retry", "1");
+
 
         if (MapUtils.isEmpty(argMap)) {
             log.error("args is empty");
@@ -87,7 +89,7 @@ public class ODPSToRedis {
                                 .build();
                         OkHttpClient client = new OkHttpClient();
                         client.newCall(request).execute();
-                    } catch (Exception e) {
+                    } catch (Throwable e) {
                         log.error("send feishu alert error ", e);
                     }
                     Map<String, String> partitionMap = odpsService.getLastestPartition(config, argMap);