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);

Reply via email to