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 14830e28c4..64630cd20c 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. */ public TableChange getTableSchema(JdbcConnection jdbc, TableId tableId) { // read schema from cache first TableChange schema = schemasByTableId.get(tableId);