You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@devlake.apache.org by ab...@apache.org on 2022/11/22 02:45:44 UTC
[incubator-devlake] branch main updated: refactor: make some log level to debug to reduce (#3775)
This is an automated email from the ASF dual-hosted git repository.
abeizn pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
The following commit(s) were added to refs/heads/main by this push:
new 09ad7b028 refactor: make some log level to debug to reduce (#3775)
09ad7b028 is described below
commit 09ad7b028a9071aea405af5b3b23637fede644ee
Author: long2ice <ji...@merico.dev>
AuthorDate: Tue Nov 22 10:45:38 2022 +0800
refactor: make some log level to debug to reduce (#3775)
---
plugins/starrocks/tasks/tasks.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/plugins/starrocks/tasks/tasks.go b/plugins/starrocks/tasks/tasks.go
index b0fc77f67..c16887a7b 100644
--- a/plugins/starrocks/tasks/tasks.go
+++ b/plugins/starrocks/tasks/tasks.go
@@ -218,7 +218,7 @@ func createTmpTable(starrocks *sql.DB, db dal.Dal, starrocksTmpTable string, tab
}
}
tableSql := fmt.Sprintf("drop table if exists %s; create table if not exists `%s` ( %s ) %s", starrocksTmpTable, starrocksTmpTable, strings.Join(columns, ","), extra)
- c.GetLogger().Info(tableSql)
+ c.GetLogger().Debug(tableSql)
_, err = errors.Convert01(starrocks.Exec(tableSql))
return columnMap, orderBy, err
}
@@ -334,7 +334,7 @@ func loadData(starrocks *sql.DB, c core.SubTaskContext, starrocksTable, starrock
if result["Status"] != "Success" {
c.GetLogger().Error(nil, "load %s failed: %s", table, string(b))
} else {
- c.GetLogger().Info("load %s success: %s, limit: %d, offset: %d", table, b, config.BatchSize, offset)
+ c.GetLogger().Debug("load %s success: %s, limit: %d, offset: %d", table, b, config.BatchSize, offset)
}
offset += len(data)
}