diff --git a/spark/featureEngSk.py b/spark/featureEngSk.py
index b82fcdccbcd2d2c83b033b3b2954ae2147b421d5..369e8a406f94682e3e81f99b973bb635dfdb4b72 100644
--- a/spark/featureEngSk.py
+++ b/spark/featureEngSk.py
@@ -299,7 +299,7 @@ def getUserProfileFeature(samples_iEsF_iStatisticF, spark, startDay, endDay):
     where date >= {startDay} and date <= {endDay}
     """.format(startDay = startDay, endDay = endDay)
 
-    userProfileFeatureDF = spark.read.jdbc('jdbc:mysql://172.16.30.136:3306/doris_olap', table_query, column = 'cl_id', numPartitions = 100,
+    userProfileFeatureDF = spark.read.jdbc('jdbc:mysql://172.16.30.136:3306/doris_olap', table_query, numPartitions = 100,
              properties = { 'user': 'doris_olap', 'password': 'bA27hXasdfswuolap', 'driver': 'com.mysql.jdbc.Driver' })
 
     userProfileFeatureDF.show(100, False)