This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 313bace10 [minor][doc][cdc-connector][oracle] Update
OracleSchema#getTableSchema doc description
313bace10 is described below
commit 313bace1064a8562004e3b273e439b387eb1a394
Author: ChengJie1053 <[email protected]>
AuthorDate: Tue Jul 23 11:32:42 2024 +0800
[minor][doc][cdc-connector][oracle] Update OracleSchema#getTableSchema doc
description
This closes #3443.
---
.../flink/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 14830e28c..64630cd20 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 class 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);