diff --git a/src/client/src/tscProfile.c b/src/client/src/tscProfile.c index ebdf3bd91d9f6bd77b67a79bdfb00e32568a8043..770e61e27827f06fc22e0d73831041a86b8f3bf8 100644 --- a/src/client/src/tscProfile.c +++ b/src/client/src/tscProfile.c @@ -76,8 +76,8 @@ void tscSaveSlowQuery(SSqlObj *pSql) { tscTrace("%p query time:%ld sql:%s", pSql, pSql->res.useconds, pSql->sqlstr); char *sql = malloc(200); - int len = snprintf(sql, 200, "insert into sys.slowquery values(now, '%s', %lld, %lld, '", pSql->pTscObj->user, - pSql->stime, pSql->res.useconds); + int len = snprintf(sql, 200, "insert into %s.slowquery values(now, '%s', %lld, %lld, '", tsMonitorDbName, + pSql->pTscObj->user, pSql->stime, pSql->res.useconds); int sqlLen = snprintf(sql + len, TSDB_SHOW_SQL_LEN, "%s", pSql->sqlstr); if (sqlLen > TSDB_SHOW_SQL_LEN - 1) { sqlLen = len + TSDB_SHOW_SQL_LEN - 1;