feat: remove hash function provider lifecycle method

apache · Jul 18, 2024 · 9084d60 · 9084d60
1 parent 145f090
commit 9084d60
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 14 deletions.
diff --git a/flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/HashFunctionProvider.java b/flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/HashFunctionProvider.java
@@ -40,11 +40,4 @@ public interface HashFunctionProvider extends Serializable {
      * @return hash function based on the given table ID and schema
      */
     HashFunction getHashFunction(TableId tableId, Schema schema);
-
-    // --------------------------------------------------------------------------------------------
-    //  Default life cycle methods
-    // --------------------------------------------------------------------------------------------
-    default void open() {}
-
-    default void close() {}
 }
diff --git a/...runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PrePartitionOperator.java b/...runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PrePartitionOperator.java
@@ -73,7 +73,6 @@ public void open() throws Exception {
                 getContainingTask().getEnvironment().getOperatorCoordinatorEventGateway();
         schemaEvolutionClient = new SchemaEvolutionClient(toCoordinator, schemaOperatorId);
         cachedHashFunctions = createCache();
-        hashFunctionProvider.open();
     }
 
     @Override
@@ -142,10 +141,4 @@ public HashFunction load(TableId key) {
                             }
                         });
     }
-
-    @Override
-    public void close() throws Exception {
-        super.close();
-        hashFunctionProvider.close();
-    }
 }