diff --git a/source/libs/function/src/udfd.c b/source/libs/function/src/udfd.c index 6d01768369..3e03e1acb6 100644 --- a/source/libs/function/src/udfd.c +++ b/source/libs/function/src/udfd.c @@ -605,7 +605,7 @@ SUdf *udfdGetOrCreateUdf(const char *udfName) { int64_t currTime = taosGetTimestampSec(); bool expired = false; if (pUdfHash) { - expired = currTime - (*pUdfHash)->lastFetchTime > 10 * 1000; + expired = currTime - (*pUdfHash)->lastFetchTime > 10 * 1000 * 1000; // 10s if (!expired) { ++(*pUdfHash)->refCount; SUdf *udf = *pUdfHash; @@ -903,7 +903,7 @@ void udfdProcessRpcRsp(void *parent, SRpcMsg *pMsg, SEpSet *pEpSet) { msgInfo->code = udfdSaveFuncBodyToFile(pFuncInfo, udf); if (msgInfo->code == 0) { - udf->lastFetchTime = taosGetTimestampMs(); + udf->lastFetchTime = taosGetTimestampUs(); } tFreeSFuncInfo(pFuncInfo); taosArrayDestroy(retrieveRsp.pFuncInfos); diff --git a/tests/system-test/2-query/odbc.py b/tests/system-test/2-query/odbc.py index f9232dddf8..9ff4a26ac0 100644 --- a/tests/system-test/2-query/odbc.py +++ b/tests/system-test/2-query/odbc.py @@ -22,7 +22,7 @@ class TDTestCase: tdSql.execute("insert into db.ctb using db.stb tags(1) (ts, c1) values (now, 1)") tdSql.query("select count(*) from information_schema.ins_columns") - tdSql.checkData(0, 0, 274) + tdSql.checkData(0, 0, 275) tdSql.query("select * from information_schema.ins_columns where table_name = 'ntb'") tdSql.checkRows(14)