From 9084d60525bd701c3a173d2b809be706d8e979ed Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=BC=8E=E6=98=95?= Date: Thu, 18 Jul 2024 14:09:50 +0800 Subject: [PATCH] feat: remove hash function provider lifecycle method --- .../apache/flink/cdc/common/sink/HashFunctionProvider.java | 7 ------- .../cdc/runtime/partitioning/PrePartitionOperator.java | 7 ------- 2 files changed, 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 index de06c9444ef..06353882be0 100644 --- 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/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PrePartitionOperator.java b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PrePartitionOperator.java index 4137b06cfc2..26df32d887d 100644 --- a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PrePartitionOperator.java +++ b/flink-cdc-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(); - } }