jch преди 4 дни
родител
ревизия
2ef1e3b138
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      src/main/scala/com/aliyun/odps/spark/examples/myUtils/FeatureTransformV2.java

+ 1 - 1
src/main/scala/com/aliyun/odps/spark/examples/myUtils/FeatureTransformV2.java

@@ -299,7 +299,7 @@ public class FeatureTransformV2 {
         if (videoInfo.containsKey("keywords")) {
             String keywords = videoInfo.get("keywords");
             if (null != keywords && !keywords.isEmpty()) {
-                for (String kw : keywords.split(",")) {
+                for (String kw : keywords.split("[,,、]")) {
                     kw = kw.replaceAll("(\\s+|\\t|:)", "");
                     if (!kw.isEmpty()) {
                         String featKey = String.format("%s@kw@%s", prefix, kw);