You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "zhuxt2015 (via GitHub)" <gi...@apache.org> on 2024/09/03 12:03:35 UTC
[PR] improve query oracle partition table [flink-cdc]
zhuxt2015 opened a new pull request, #3593:
URL: https://github.com/apache/flink-cdc/pull/3593
Resolved the issue that Oracle CDC does not recognize Oracle partition tables
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table [flink-cdc]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #3593:
URL: https://github.com/apache/flink-cdc/pull/3593#issuecomment-2558273444
This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encouraged to continue work on this pull request.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table [flink-cdc]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #3593:
URL: https://github.com/apache/flink-cdc/pull/3593#issuecomment-2489789317
This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table [flink-cdc]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed pull request #3593: [FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table
URL: https://github.com/apache/flink-cdc/pull/3593
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table [flink-cdc]
Posted by "zhuxt2015 (via GitHub)" <gi...@apache.org>.
zhuxt2015 commented on PR #3593:
URL: https://github.com/apache/flink-cdc/pull/3593#issuecomment-2365169738
> Thanks for @zhuxt2015's contribution! Would you mind adding a test case to verify this change?
我参考其他测试用例写的oracle分区表的测试用例，但是运行会报错，一直没找到解决办法，您能帮忙看一下吗？
I refer to the test case of the oracle partition table written by other test cases, but the error will be reported when running, and I have not found a solution, can you help me take a look?
```
159109 [Source: test_partition_table[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: test_partition_sink[3] (1/4)#1] WARN org.apache.flink.runtime.taskmanager.Task - Source: test_partition_table[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: test_partition_sink[3] (1/4)#1 (7d49ef3353baa61a7d77363cc0d5d501_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from RUNNING to FAILED with failure cause:
org.apache.flink.util.FlinkRuntimeException: java.lang.RuntimeException: Failed to resolve Oracle database version
at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:348) ~[classes/:?]
at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.addSplits(IncrementalSourceReader.java:308) ~[classes/:?]
at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.addSplits(IncrementalSourceReader.java:248) ~[classes/:?]
at org.apache.flink.streaming.api.operators.SourceOperator.handleAddSplitsEvent(SourceOperator.java:590) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.api.operators.SourceOperator.handleOperatorEvent(SourceOperator.java:567) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.OperatorEventDispatcherImpl.dispatchEventToHandlers(OperatorEventDispatcherImpl.java:72) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.dispatchOperatorEvent(RegularOperatorChain.java:80) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$dispatchOperatorEvent$21(StreamTask.java:1492) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:398) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:367) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:352) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:229) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:858) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:807) ~[flink-streaming-java-1.18.1.jar:1.18.1]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:953) ~[flink-runtime-1.18.1.jar:1.18.1]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:932) [flink-runtime-1.18.1.jar:1.18.1]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:746) [flink-runtime-1.18.1.jar:1.18.1]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) [flink-runtime-1.18.1.jar:1.18.1]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_401]
Caused by: java.lang.RuntimeException: Failed to resolve Oracle database version
at io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:177) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52) ~[classes/:?]
at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336) ~[classes/:?]
... 20 more
Caused by: java.sql.SQLRecoverableException: IO 错误: The Network Adapter could not establish the connection
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:854) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:793) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:57) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:747) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:562) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at java.sql.DriverManager.getConnection(DriverManager.java:664) ~[?:1.8.0_401]
at java.sql.DriverManager.getConnection(DriverManager.java:208) ~[?:1.8.0_401]
at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:192) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:636) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:147) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52) ~[classes/:?]
at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336) ~[classes/:?]
... 20 more
Caused by: oracle.net.ns.NetException: The Network Adapter could not establish the connection
at oracle.net.nt.ConnStrategy.execute(ConnStrategy.java:571) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.resolver.AddrResolution.resolveAndExecute(AddrResolution.java:548) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.establishConnection(NSProtocol.java:682) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.connect(NSProtocol.java:309) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.connect(T4CConnection.java:1596) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:588) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:793) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:57) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:747) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:562) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at java.sql.DriverManager.getConnection(DriverManager.java:664) ~[?:1.8.0_401]
at java.sql.DriverManager.getConnection(DriverManager.java:208) ~[?:1.8.0_401]
at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:192) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:636) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:147) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52) ~[classes/:?]
at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336) ~[classes/:?]
... 20 more
Caused by: java.io.IOException: Connection refused, socket connect lapse 1 ms. /0:0:0:0:0:0:0:1 62469 0 1 true
at oracle.net.nt.TcpNTAdapter.connect(TcpNTAdapter.java:233) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.ConnOption.connect(ConnOption.java:174) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.ConnStrategy.execute(ConnStrategy.java:510) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.resolver.AddrResolution.resolveAndExecute(AddrResolution.java:548) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.establishConnection(NSProtocol.java:682) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.connect(NSProtocol.java:309) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.connect(T4CConnection.java:1596) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:588) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:793) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:57) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:747) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:562) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at java.sql.DriverManager.getConnection(DriverManager.java:664) ~[?:1.8.0_401]
at java.sql.DriverManager.getConnection(DriverManager.java:208) ~[?:1.8.0_401]
at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:192) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:636) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:147) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52) ~[classes/:?]
at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336) ~[classes/:?]
... 20 more
Caused by: java.net.ConnectException: Connection refused
at sun.nio.ch.Net.connect0(Native Method) ~[?:1.8.0_401]
at sun.nio.ch.Net.connect(Net.java:459) ~[?:1.8.0_401]
at sun.nio.ch.Net.connect(Net.java:451) ~[?:1.8.0_401]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:646) ~[?:1.8.0_401]
at java.nio.channels.SocketChannel.open(SocketChannel.java:189) ~[?:1.8.0_401]
at oracle.net.nt.TimeoutSocketChannel.connect(TimeoutSocketChannel.java:99) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.TimeoutSocketChannel.<init>(TimeoutSocketChannel.java:77) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.TcpNTAdapter.connect(TcpNTAdapter.java:192) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.ConnOption.connect(ConnOption.java:174) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.nt.ConnStrategy.execute(ConnStrategy.java:510) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.resolver.AddrResolution.resolveAndExecute(AddrResolution.java:548) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.establishConnection(NSProtocol.java:682) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.net.ns.NSProtocol.connect(NSProtocol.java:309) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.connect(T4CConnection.java:1596) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:588) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:793) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:57) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:747) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:562) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
at java.sql.DriverManager.getConnection(DriverManager.java:664) ~[?:1.8.0_401]
at java.sql.DriverManager.getConnection(DriverManager.java:208) ~[?:1.8.0_401]
at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:192) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:636) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510) ~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:147) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82) ~[debezium-connector-oracle-1.9.8.Final.jar:1.9.8.Final]
at org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:61) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.openJdbcConnection(OracleDialect.java:86) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollections(OracleDialect.java:103) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:113) ~[classes/:?]
at org.apache.flink.cdc.connectors.oracle.source.OracleDialect.discoverDataCollectionSchemas(OracleDialect.java:52) ~[classes/:?]
at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReader.discoverTableSchemasForStreamSplit(IncrementalSourceReader.java:336) ~[classes/:?]
... 20 more
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org