diff --git a/source/libs/function/src/udfd.c b/source/libs/function/src/udfd.c
index 4e16d5e70853f9c4bf69fb0e48175507944dfaad..0f761d3d7db87bf60302751ab3d3c1ad7c53e57d 100644
--- a/source/libs/function/src/udfd.c
+++ b/source/libs/function/src/udfd.c
@@ -580,7 +580,10 @@ void udfdProcessCallRequest(SUvUdfWork *uvUdf, SUdfRequest *request) {
   switch (call->callType) {
     case TSDB_UDF_CALL_SCALA_PROC: {
       SUdfColumn output = {0};
-
+      output.colMeta.bytes = udf->outputLen;
+      output.colMeta.type = udf->outputType;
+      output.colMeta.precision = 0;
+      output.colMeta.scale = 0;
       SUdfDataBlock input = {0};
       convertDataBlockToUdfDataBlock(&call->block, &input);
       code = udf->scriptPlugin->udfScalarProcFunc(&input, &output, udf->scriptUdfCtx);
diff --git a/source/libs/function/test/udf1.c b/source/libs/function/test/udf1.c
index 71d30b67557847dcdf451cefb20c7b144d214cf8..a395fc99a9a5622a3487c7de9cf04ea8c11f30d2 100644
--- a/source/libs/function/test/udf1.c
+++ b/source/libs/function/test/udf1.c
@@ -14,11 +14,6 @@ DLL_EXPORT int32_t udf1_init() { return 0; }
 DLL_EXPORT int32_t udf1_destroy() { return 0; }
 
 DLL_EXPORT int32_t udf1(SUdfDataBlock *block, SUdfColumn *resultCol) {
-  SUdfColumnMeta *meta = &resultCol->colMeta;
-  meta->bytes = 4;
-  meta->type = TSDB_DATA_TYPE_INT;
-  meta->scale = 0;
-  meta->precision = 0;
 
   SUdfColumnData *resultData = &resultCol->colData;
   resultData->numOfRows = block->numOfRows;