update feature

spark/featureEng.py

@@ -379,10 +379,10 @@ def getEsConn():
 
 def getClickSql(start, end):
     sql = """
-    SELECT DISTINCT t1.partition_date, t1.cl_id device_id, t1.card_id,t1.time_stamp,t1.page_stay 
+    SELECT DISTINCT t1.partition_date, t1.cl_id device_id, t1.card_id,t1.time_stamp,t1.page_stay,t1.cl_type as os
       FROM
         (
-            select partition_date,cl_id,business_id as card_id,time_stamp,page_stay,cl_type as os
+            select partition_date,cl_id,business_id as card_id,time_stamp,page_stay,cl_type
             from online.bl_hdfs_maidian_updates
             where action = 'page_view'
             AND partition_date>='{startDay}' and partition_date<='{endDay}'