From 76a2320a65fede3db7a64eeffb97d06fe5568ee2 Mon Sep 17 00:00:00 2001
From: liyou <303181885@qq.com>
Date: Fri, 12 Dec 2025 23:33:34 +0800
Subject: [PATCH] fix mt udf issue

---
 cpp/connector/kafka/sink/KafkaWriter.cpp | 1 +
 cpp/connector/kafka/sink/KafkaWriter.h   | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/cpp/connector/kafka/sink/KafkaWriter.cpp b/cpp/connector/kafka/sink/KafkaWriter.cpp
index 6b7738d..3fe7362 100644
--- a/cpp/connector/kafka/sink/KafkaWriter.cpp
+++ b/cpp/connector/kafka/sink/KafkaWriter.cpp
@@ -78,6 +78,7 @@ void KafkaWriter::write(String *element)
     }
     auto record = recordSerializer->Serialize(element);
     ProduceRecord(record);
+    delete element;
 }
 
 void KafkaWriter::write(Row *element)
diff --git a/cpp/connector/kafka/sink/KafkaWriter.h b/cpp/connector/kafka/sink/KafkaWriter.h
index 17696ba..1e78fd1 100644
--- a/cpp/connector/kafka/sink/KafkaWriter.h
+++ b/cpp/connector/kafka/sink/KafkaWriter.h
@@ -139,7 +139,7 @@ private:
         while (timer_worker_thread_flag.load()) {
             clock_gettime(CLOCK_MONOTONIC, &end);
             // 计算时间差
-            long ns = (end.tv_sec - start.tv_sec) * 1000000000L + (end.tv_nsec - start.tv_nsec);
+            uint64_t ns = (end.tv_sec - start.tv_sec) * 1000000000L + (end.tv_nsec - start.tv_nsec);
             if (ns >= 5000000000L) {
                 handleRecord();
                 start = end;
-- 
Gitee