fix

Pyspark_job/export_es/es_asin_profit_rate.py

@@ -267,7 +267,7 @@ class EsAsinProfitRate(object):
     # ------------------------------------------------------------------ #
     def get_es_read_options(self, include_crawl_date=False):
         # es.mapping.date.rich=false：date字段以原始字符串返回，避免转为timestamp带来的精度问题
-        fields = "asin,price,profit_key,profit_rate_extra,tracking_since,tracking_since_type"
+        fields = "asin,price,profit_key,profit_rate_extra.ocean_profit,profit_rate_extra.air_profit,tracking_since,tracking_since_type"
         if include_crawl_date:
             fields += ",asin_crawl_date"
         return {