fix: clickhouse sink add close24.01.1

1 files changed, 6 insertions, 0 deletions

diff --git a/platform-base/src/main/java/com/zdjizhi/base/sink/clickhouse/ClickhouseSink.java b/platform-base/src/main/java/com/zdjizhi/base/sink/clickhouse/ClickhouseSink.java
index 97e4a95..fb44c39 100644
--- a/platform-base/src/main/java/com/zdjizhi/base/sink/clickhouse/ClickhouseSink.java
+++ b/platform-base/src/main/java/com/zdjizhi/base/sink/clickhouse/ClickhouseSink.java
@@ -46,4 +46,10 @@ public class ClickhouseSink extends RichSinkFunction<String> {
     private Map<String, Object> objectToMap(String json) {
         return JSON.parseObject(json, TypeReference.mapType(HashMap.class, String.class, Object.class));
     }
+
+    @Override
+    public void close() throws Exception {
+        super.close();
+        this.eventBatchIntervalClickHouseSink.close();
+    }
 }