fix

Pyspark_job/export_es/es_flow_asin.py

@@ -120,9 +120,9 @@ class EsStDetail(TemplatesMysql):
         self.df_synchronize = self.df_synchronize.join(
             self.df_profit_rate, on=['asin', 'price'], how='left'
         ).withColumn(
-            "img_type", F.split(F.col("img_type"), ",")
+            "img_type_arr", F.split(F.col("img_type"), ",")
         ).withColumn(
-            "img_type", F.expr("transform(img_type, x -> cast(x as int))")
+            "img_type_arr", F.expr("transform(img_type_arr, x -> cast(x as int))")
         ).withColumn(
             'profit_key', F.concat_ws("_", F.col("asin"), F.col("price"))
         ).cache()

Pyspark_job/utils/es_util.py

@@ -228,7 +228,7 @@ class EsUtils(object):
                         "type": "short"
                     },
                     "img_type": {
-                        "type": "integer"
+                        "type": "keyword"
                     },
                     "activity_type": {
                         "type": "keyword"
@@ -486,6 +486,9 @@ class EsUtils(object):
                     "tracking_since_type": {
                         "type": "short"
                     },
+                    "img_type_arr": {
+                        "type": "integer"
+                    },
                     "profit_key": {
                         "type": "keyword"
                     },