diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
index 6d393f6..e8e1826 100644
--- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
+++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
@@ -285,8 +285,8 @@ public class MySqlDataSource extends BaseDataAbsSource {
 
             while (resultSet.next()) {
                 for (int i = 1; i <= columnCount; i++) {
+                    log.info("喜欢次数为===={}",i);
                     if (resultSet.isFirst()) {
-                        log.info("进入第一次if判断");
                         String columnTypeName = metaData.getColumnTypeName(i);
                         DatabaseMetaData metaDataColumns = conn.getMetaData();
                         ResultSet columns = metaDataColumns.getColumns(null, null, metaData.getTableName(i), metaData.getColumnName(i));
@@ -294,7 +294,6 @@ public class MySqlDataSource extends BaseDataAbsSource {
 
                         while (columns.next()) {
                             remarks = columns.getString("REMARKS");
-                            log.info("字段备注:" + remarks);
                         }
                         DataValue build = DataValue.builder()
                                 .key(metaData.getColumnName(i))
@@ -307,7 +306,6 @@ public class MySqlDataSource extends BaseDataAbsSource {
                             dataValues[c - 1][i - 1] = build;
                         }
                     } else {
-                        log.info("进入第二次elese判断");
                         DataValue build = DataValue.builder()
                                 .key(metaData.getColumnName(i))
                                 .label(map.get(i).getLabel())
@@ -323,7 +321,7 @@ public class MySqlDataSource extends BaseDataAbsSource {
                     c++;
                 }
             }
-            log.info("返回日志");
+            log.info("返回数据{}",dataValues.length);
             return dataValues;
         } catch (SQLException e) {
             throw new RuntimeException(e);