We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cccbebd commit 5fabca4Copy full SHA for 5fabca4
dagger-core/src/main/java/com/gotocompany/dagger/core/sink/http/HttpSink.java
@@ -13,6 +13,8 @@
13
import org.apache.flink.api.connector.sink.Sink;
14
import org.apache.flink.api.connector.sink.SinkWriter;
15
import org.apache.flink.core.io.SimpleVersionedSerializer;
16
+import org.apache.flink.api.connector.sink.Committer;
17
+import org.apache.flink.api.connector.sink.GlobalCommitter;
18
import org.apache.flink.types.Row;
19
20
import java.io.IOException;
0 commit comments