Skip to content

Commit 313bace

Browse files
authored
[minor][doc][cdc-connector][oracle] Update OracleSchema#getTableSchema doc description
This closes #3443.
1 parent c5f391c commit 313bace

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -42,10 +42,7 @@ public OracleSchema() {
4242
this.schemasByTableId = new HashMap<>();
4343
}
4444

45-
/**
46-
* Gets table schema for the given table path. It will request to MySQL server by running `SHOW
47-
* CREATE TABLE` if cache missed.
48-
*/
45+
/** Gets table schema for the given table path. */
4946
public TableChange getTableSchema(JdbcConnection jdbc, TableId tableId) {
5047
// read schema from cache first
5148
TableChange schema = schemasByTableId.get(tableId);

0 commit comments

Comments
 (0)