From 418107e0e6270a32f7530d629417f58fdefcaf89 Mon Sep 17 00:00:00 2001 From: ChengJie1053 <18033291053@163.com> Date: Sat, 29 Jun 2024 18:11:09 +0800 Subject: [PATCH 1/2] OracleSchema getTableSchema Description Modified --- .../cdc/connectors/oracle/source/utils/OracleSchema.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java index 14830e28c45..42df5f5201a 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java @@ -42,10 +42,7 @@ public OracleSchema() { this.schemasByTableId = new HashMap<>(); } - /** - * Gets table schema for the given table path. It will request to MySQL server by running `SHOW - * CREATE TABLE` if cache missed. - */ + /** Gets table schema for the given table path. It will request to Oracle server by running */ public TableChange getTableSchema(JdbcConnection jdbc, TableId tableId) { // read schema from cache first TableChange schema = schemasByTableId.get(tableId); From 3f0bf3798b5c53c0aa6007d51d0f56af8e417537 Mon Sep 17 00:00:00 2001 From: ChengJie1053 <18033291053@163.com> Date: Tue, 16 Jul 2024 19:44:15 +0800 Subject: [PATCH 2/2] optimized code --- .../flink/cdc/connectors/oracle/source/utils/OracleSchema.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java index 42df5f5201a..64630cd20c9 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java @@ -42,7 +42,7 @@ public OracleSchema() { this.schemasByTableId = new HashMap<>(); } - /** Gets table schema for the given table path. It will request to Oracle server by running */ + /** Gets table schema for the given table path. */ public TableChange getTableSchema(JdbcConnection jdbc, TableId tableId) { // read schema from cache first TableChange schema = schemasByTableId.get(tableId);