build(deps): bump ob-partition-calculator to 1.8.0

oceanbase · Nov 27, 2023 · eabae73 · eabae73
1 parent 66c384a
commit eabae73
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 13 deletions.
diff --git a/flink-connector-oceanbase/pom.xml b/flink-connector-oceanbase/pom.xml
@@ -44,7 +44,7 @@ under the License.
         <dependency>
             <groupId>com.oceanbase</groupId>
             <artifactId>ob-partition-calculator</artifactId>
-            <version>1.7.0-RELEASE</version>
+            <version>1.8.0-RELEASE</version>
         </dependency>
 
         <dependency>

diff --git a/...nbase/src/main/java/com/oceanbase/connector/flink/connection/OceanBaseConnectionPool.java b/...nbase/src/main/java/com/oceanbase/connector/flink/connection/OceanBaseConnectionPool.java
@@ -21,7 +21,6 @@
 import com.oceanbase.connector.flink.dialect.OceanBaseOracleDialect;
 import com.oceanbase.partition.calculator.enums.ObServerMode;
 import com.oceanbase.partition.calculator.helper.TableEntryExtractor;
-import com.oceanbase.partition.calculator.helper.TableEntryExtractorV4;
 import com.oceanbase.partition.calculator.model.TableEntry;
 import com.oceanbase.partition.calculator.model.TableEntryKey;
 
@@ -116,17 +115,12 @@ public OceanBaseTablePartInfo getTablePartInfo() {
             }
             TableEntry tableEntry;
             try (Connection connection = getConnection()) {
-                if (getConnectionInfo().getVersion().isV4()) {
-                    tableEntry =
-                            new TableEntryExtractorV4()
-                                    .queryTableEntry(
-                                            connection, getConnectionInfo().getTableEntryKey());
-                } else {
-                    tableEntry =
-                            new TableEntryExtractor()
-                                    .queryTableEntry(
-                                            connection, getConnectionInfo().getTableEntryKey());
-                }
+                tableEntry =
+                        new TableEntryExtractor()
+                                .queryTableEntry(
+                                        connection,
+                                        getConnectionInfo().getTableEntryKey(),
+                                        getConnectionInfo().getVersion().isV4());
                 if (tableEntry == null) {
                     throw new RuntimeException(
                             "Failed to get table entry with key: "