kino update

spark/sources/Sinks.py

@@ -2,6 +2,9 @@ from common import Constants
 import os
 
 # 写出到 MySQL
+from sources import Sources
+
+
 def sinkMySql(sinkDF, driver, url, user, password, table, mode=Constants.SAVE_MODE_OVERWRITE):
     sinkDF.write.mode(mode) \
         .format("jdbc") \

spark/sources/Sources.py

 import pymysql
-import exception.MyErrorException as ex
 from pyspark import SparkContext
 from sources import Sinks