修改tidb地址，负载均衡

eda/smart_rank/dist_periodic_update_smart_rank.py

@@ -113,7 +113,7 @@ if __name__ == '__main__':
             .set("spark.tispark.plan.allow_index_double_read", "false") \
             .set("spark.tispark.plan.allow_index_read", "true") \
             .set("spark.sql.extensions", "org.apache.spark.sql.TiExtensions") \
-            .set("spark.tispark.pd.addresses", "172.16.40.158:2379").set("spark.io.compression.codec", "lzf") \
+            .set("spark.tispark.pd.addresses", "172.16.40.170:2379").set("spark.io.compression.codec", "lzf") \
             .set("spark.driver.maxResultSize", "8g").set("spark.sql.avro.compression.codec", "snappy")
 
         spark = SparkSession.builder.config(conf=sparkConf).enableHiveSupport().getOrCreate()

eda/smart_rank/dist_update_portrait_market.py

@@ -148,7 +148,7 @@ def compute_ai_scan(x):
 
 def get_user_tag_score(cl_id, all_word_tags, size=10):
     try:
-        db_jerry_test = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
+        db_jerry_test = pymysql.connect(host='172.16.40.170', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
                                         db='jerry_test', charset='utf8')
         cur_jerry_test = db_jerry_test.cursor()
 
@@ -218,7 +218,7 @@ def get_user_tag_score(cl_id, all_word_tags, size=10):
 
 if __name__ == '__main__':
     try:
-        db_jerry_test = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
+        db_jerry_test = pymysql.connect(host='172.16.40.170', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
                                         db='jerry_test', charset='utf8')
         cur_jerry_test = db_jerry_test.cursor()
 
@@ -237,7 +237,7 @@ if __name__ == '__main__':
             .set("spark.tispark.plan.allow_index_double_read", "false") \
             .set("spark.tispark.plan.allow_index_read", "true") \
             .set("spark.sql.extensions", "org.apache.spark.sql.TiExtensions") \
-            .set("spark.tispark.pd.addresses", "172.16.40.158:2379").set("spark.io.compression.codec", "lzf") \
+            .set("spark.tispark.pd.addresses", "172.16.40.170:2379").set("spark.io.compression.codec", "lzf") \
             .set("spark.driver.maxResultSize", "8g").set("spark.sql.avro.compression.codec", "snappy")
 
         spark = SparkSession.builder.config(conf=sparkConf).enableHiveSupport().getOrCreate()

eda/smart_rank/dist_update_user_history_order_tags.py

@@ -109,7 +109,7 @@ if __name__ == '__main__':
             .set("spark.tispark.plan.allow_index_double_read", "false") \
             .set("spark.tispark.plan.allow_index_read", "true") \
             .set("spark.sql.extensions", "org.apache.spark.sql.TiExtensions") \
-            .set("spark.tispark.pd.addresses", "172.16.40.158:2379").set("spark.io.compression.codec", "lzf") \
+            .set("spark.tispark.pd.addresses", "172.16.40.170:2379").set("spark.io.compression.codec", "lzf") \
             .set("spark.driver.maxResultSize", "8g").set("spark.sql.avro.compression.codec", "snappy")
 
         spark = SparkSession.builder.config(conf=sparkConf).enableHiveSupport().getOrCreate()

eda/smart_rank/dist_update_user_portrait.py

@@ -144,7 +144,7 @@ def get_user_tag_score(cl_id, size=10):
 
 if __name__ == '__main__':
     try:
-        db_jerry_test = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
+        db_jerry_test = pymysql.connect(host='172.16.40.170', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
                                         db='jerry_test', charset='utf8')
         cur_jerry_test = db_jerry_test.cursor()
 
@@ -166,7 +166,7 @@ if __name__ == '__main__':
             .set("spark.tispark.plan.allow_index_double_read", "false") \
             .set("spark.tispark.plan.allow_index_read", "true") \
             .set("spark.sql.extensions", "org.apache.spark.sql.TiExtensions") \
-            .set("spark.tispark.pd.addresses", "172.16.40.158:2379").set("spark.io.compression.codec", "lzf") \
+            .set("spark.tispark.pd.addresses", "172.16.40.170:2379").set("spark.io.compression.codec", "lzf") \
             .set("spark.driver.maxResultSize", "8g").set("spark.sql.avro.compression.codec", "snappy")
 
         spark = SparkSession.builder.config(conf=sparkConf).enableHiveSupport().getOrCreate()

eda/smart_rank/dist_update_user_portrait_service.py

@@ -276,7 +276,7 @@ def get_user_service_portrait(cl_id, all_word_tags, all_tag_tag_type, all_3tag_2
 
 if __name__ == '__main__':
     try:
-        db_jerry_test = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
+        db_jerry_test = pymysql.connect(host='172.16.40.170', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
                                         db='jerry_test', charset='utf8')
         cur_jerry_test = db_jerry_test.cursor()
 
@@ -300,7 +300,7 @@ if __name__ == '__main__':
             .set("spark.tispark.plan.allow_index_double_read", "false") \
             .set("spark.tispark.plan.allow_index_read", "true") \
             .set("spark.sql.extensions", "org.apache.spark.sql.TiExtensions") \
-            .set("spark.tispark.pd.addresses", "172.16.40.158:2379").set("spark.io.compression.codec", "lzf") \
+            .set("spark.tispark.pd.addresses", "172.16.40.170:2379").set("spark.io.compression.codec", "lzf") \
             .set("spark.driver.maxResultSize", "8g").set("spark.sql.avro.compression.codec", "snappy")
 
         spark = SparkSession.builder.config(conf=sparkConf).enableHiveSupport().getOrCreate()