修改测试文件

tensnsorflow/multi.py

@@ -198,8 +198,8 @@ def con_sql(db,sql):
 
 def test():
     sql = "select stat_date,cid_id,y,ccity_name from esmm_train_data limit 60"
-    rdd = spark.sql(sql).select("stat_date","cid_id","y","ccity_name").rdd
-    df = spark.createDataFrame(rdd).map(lambda x:(x[0],x[1],x[2],x[3]))
+    rdd = spark.sql(sql).select("stat_date","cid_id","y","ccity_name").rdd.map(lambda x:(x[0],x[1],x[2],x[3]))
+    df = spark.createDataFrame(rdd)
     df.show(6)
 
     from hdfs import InsecureClient