Commit f04053b4 authored by litaolemo's avatar litaolemo

update

parent d8ededfe
...@@ -202,10 +202,10 @@ for redis_count,spark_res in enumerate(sql_res): ...@@ -202,10 +202,10 @@ for redis_count,spark_res in enumerate(sql_res):
else: else:
bulk_dict[1000][1] += 1 bulk_dict[1000][1] += 1
if redis_count % 5000 == 0: # if redis_count % 5000 == 0:
print(redis_count,bulk_dict) # print(redis_count,bulk_dict)
print(temp_null_count) # print(temp_null_count)
print(second_demands_tag_count,projects_demands_tag_count) # print(second_demands_tag_count,projects_demands_tag_count)
print(total_tag_count) print(total_tag_count)
print(total_tag_count_pro) print(total_tag_count_pro)
# print(bulk_dict) # print(bulk_dict)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment