fix

Pyspark_job/es_handle/es_update_with_info.py

@@ -18,12 +18,9 @@ __metastore_uris__ = "thrift://hadoop16:9083"
 
 
 def get_es_index_name():
-    client = EsUtils.get_es_client()
-    index_name_list = EsUtils.get_index_names_associated_alias("us_st_detail_last_4_week", client)
-    if index_name_list:
-        index_name = str(index_name_list[0])
-        print("elasticsearch上待更新的索引名称为：", index_name)
-        return index_name
+    index_name = "us_flow_asin_30day"
+    print("elasticsearch上待更新的索引名称为：", index_name)
+    return index_name
 
 
 def update_es_fileds(df_update, index_name):