[FLINK-19760] Sink API: Make the GlobalCommitter not extend the `Co…

…mmitter` This patch decouples the `GlobalCommitter` from the `Committer` interface in the new Sink API. This closes apache#13888.
kaicao · Nov 3, 2020 · 926e1bc · 926e1bc
1 parent 34d0a9c
commit 926e1bc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-core/src/main/java/org/apache/flink/api/connector/sink/GlobalCommitter.java b/flink-core/src/main/java/org/apache/flink/api/connector/sink/GlobalCommitter.java
@@ -33,7 +33,7 @@
  * @param <GlobalCommT>   The type of the aggregated committable
  */
 @Experimental
-public interface GlobalCommitter<CommT, GlobalCommT> extends Committer<GlobalCommT> {
+public interface GlobalCommitter<CommT, GlobalCommT> extends AutoCloseable {
 
 	/**
 	 * Find out which global committables need to be retried when recovering from the failure.