From 9f1693029a62bb8726198270c0972e0275ba0c34 Mon Sep 17 00:00:00 2001
From: guange <8863824@gmail.com>
Date: Fri, 18 Jan 2019 15:37:11 +0800
Subject: [PATCH] .

---
 chapter3/spark.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/chapter3/spark.py b/chapter3/spark.py
index 5e51f27..4044f42 100644
--- a/chapter3/spark.py
+++ b/chapter3/spark.py
@@ -92,7 +92,7 @@ def collect_from_type(spark):
     for row in df.rdd.collect():
         if row["from_type"]:
             data[row["from_type"]] = row["N"]
-    mysql_execute("update datas set data = '{}' where `key` = 'from_type'".format( json.dumps(data) ))
+    mysql_execute("update datas set data = '{}' where `key` = 'from_type'".format( json.dumps(data,ensure_ascii=False) ))
 
 
 if __name__ == "__main__":