From 5fabca448e13e897180529a674302136606554a2 Mon Sep 17 00:00:00 2001 From: Sumit Aich Date: Tue, 10 Sep 2024 16:26:51 +0530 Subject: [PATCH] fix: fix import --- .../java/com/gotocompany/dagger/core/sink/http/HttpSink.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/dagger-core/src/main/java/com/gotocompany/dagger/core/sink/http/HttpSink.java b/dagger-core/src/main/java/com/gotocompany/dagger/core/sink/http/HttpSink.java index 64335c34a..1a5587d6f 100644 --- a/dagger-core/src/main/java/com/gotocompany/dagger/core/sink/http/HttpSink.java +++ b/dagger-core/src/main/java/com/gotocompany/dagger/core/sink/http/HttpSink.java @@ -13,6 +13,8 @@ import org.apache.flink.api.connector.sink.Sink; import org.apache.flink.api.connector.sink.SinkWriter; import org.apache.flink.core.io.SimpleVersionedSerializer; +import org.apache.flink.api.connector.sink.Committer; +import org.apache.flink.api.connector.sink.GlobalCommitter; import org.apache.flink.types.Row; import java.io.IOException;