dssm train

recommend-model-produce/src/main/java/com/tzld/piaoquan/recommend/model/produce/i2i/I2IDSSMPredict.java

@@ -15,6 +15,7 @@ import org.apache.spark.api.java.JavaRDD;
 import org.apache.spark.api.java.JavaSparkContext;
 import org.apache.spark.sql.SparkSession;
 
+import java.io.File;
 import java.util.Iterator;
 import java.util.Map;
 
@@ -42,7 +43,6 @@ public class I2IDSSMPredict {
 
         // 定义处理数据的函数
         JavaRDD<String> processedRdd = rdd.mapPartitions(lines -> {
-            log.info(System.getProperty("java.library.path"));
             System.loadLibrary("paddle_inference");
             String bucketName = "art-recommend";
             String objectName = "dyp/dssm.tar.gz";

recommend-model-produce/src/main/java/com/tzld/piaoquan/recommend/model/produce/service/OSSService.java

@@ -38,7 +38,6 @@ public class OSSService implements Serializable {
         try {
             GetObjectRequest request = new GetObjectRequest(bucketName, objectName);
             ossClient.getObject(request, new File(localFile));
-            System.out.println("");
         } catch (Exception e) {
             log.error("download error bucketName {}, localFile {}, objectName {}", bucketName, localFile, objectName, e);
         }

recommend-model-produce/src/main/java/com/tzld/piaoquan/recommend/model/produce/util/CompressUtil.java

@@ -83,7 +83,8 @@ public class CompressUtil {
                 }
             }
         } catch (Exception e) {
-            log.error("", e);
+            log.error("FileInputStream error", e);
+            log.error("FileInputStream error {}", e.getMessage());
         }
     }
 }