diff --git a/chapter3/spark.py b/chapter3/spark.py
index 80cb0ff..1188536 100644
--- a/chapter3/spark.py
+++ b/chapter3/spark.py
@@ -82,7 +82,7 @@ def collect_top10_sells(spark):
     i = 1
     for row in df.rdd.collect():
         mysql_execute("update top10_sells set product_name = {}, good_c = {}, price={} where order_n = {} ".format(
-            row["name"], row["good_count"], int(row["price"]),i))
+            row["name"], row["good_count"], int(float(row["price"])),i))
         i += 1
 
 def collect_from_type(spark):