yuxiqian commented on PR #3600:
URL: https://github.com/apache/flink-cdc/pull/3600#issuecomment-2339445638
Hi @GOODBOY008, pulled, ran Oracle related tests locally, but none of these
tests worked.
Unit test cases failed with:
```
Caused by: java.io.IOException: Connection reset by peer, Authentication
lapse 0 ms.
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:870)
... 11 more
Caused by: java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:197)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at
oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:174)
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:555)
at oracle.net.ns.NIOPacket.readNIOPacket(NIOPacket.java:403)
at
oracle.net.ns.NSProtocolNIO.negotiateConnection(NSProtocolNIO.java:127)
at oracle.net.ns.NSProtocol.connect(NSProtocol.java:340)
at oracle.jdbc.driver.T4CConnection.connect(T4CConnection.java:1596)
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:588)
... 11 more
```
And E2e test case failure is similar:
```
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: Caused by: java.io.IOException: Connection reset by peer
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at sun.nio.ch.SocketDispatcher.read(Unknown Source) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at sun.nio.ch.IOUtil.readIntoNativeBuffer(Unknown Source) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at sun.nio.ch.IOUtil.read(Unknown Source) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at sun.nio.ch.IOUtil.read(Unknown Source) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at sun.nio.ch.SocketChannelImpl.read(Unknown Source) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:174) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:555) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:258) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:190) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:132) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:105) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:91)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:764)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:429) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:407)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:268) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.T4CTTIoauthenticate.doOAUTH(T4CTTIoauthenticate.java:501)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.T4CTTIoauthenticate.doOAUTH(T4CTTIoauthenticate.java:1292)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.T4CTTIoauthenticate.doOAUTH(T4CTTIoauthenticate.java:1025)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:743) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:793)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:57)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:747) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:562) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at java.sql.DriverManager.getConnection(Unknown Source)
~[java.sql:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at java.sql.DriverManager.getConnection(Unknown Source)
~[java.sql:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$0(JdbcConnection.java:192)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:636) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:147)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:87)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
io.debezium.connector.oracle.OracleConnection.<init>(OracleConnection.java:82)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:62)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.cdc.connectors.oracle.source.utils.OracleConnectionUtils.createOracleConnection(OracleConnectionUtils.java:54)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.<init>(OracleSourceFetchTaskContext.java:98)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.createFetchTaskContext(OracleDialect.java:139)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.cdc.connectors.oracle.source.OracleDialect.createFetchTaskContext(OracleDialect.java:52)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.getStreamFetcher(IncrementalSourceSplitReader.java:277)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitStreamSplit(IncrementalSourceSplitReader.java:259)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:153)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98)
~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58)
~[flink-connector-files-1.16.3.jar:1.16.3]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142)
~[flink-connector-files-1.16.3.jar:1.16.3]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105)
~[flink-connector-files-1.16.3.jar:1.16.3]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at java.util.concurrent.Executors$RunnableAdapter.call(Unknown
Source) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at java.util.concurrent.FutureTask.run(Unknown Source) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
Source) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source) ~[?:?]
51672 [docker-java-stream-53548503] INFO
org.apache.flink.cdc.connectors.tests.utils.FlinkContainerTestEnvironment -
STDOUT: ... 1 more
Test testOracleCDC[flinkVersion:
1.16.3](org.apache.flink.cdc.connectors.tests.OracleE2eITCase) failed with:
java.sql.SQLSyntaxErrorException: ORA-00942: 表格或視觀表不存在
at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:509)
at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:461)
at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1104)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:550)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:268)
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655)
at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229)
at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41)
at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:928)
at
oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1205)
at
oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1823)
at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1778)
at
oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:303)
at
org.apache.flink.cdc.connectors.tests.OracleE2eITCase.testOracleCDC(OracleE2eITCase.java:155)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.junit.runners.Suite.runChild(Suite.java:128)
at org.junit.runners.Suite.runChild(Suite.java:27)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at
org.testcontainers.containers.FailureDetectingExternalResource$1.evaluate(FailureDetectingExternalResource.java:29)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:69)
at
com.intellij.rt.junit.IdeaTestRunner$Repeater$1.execute(IdeaTestRunner.java:38)
at
com.intellij.rt.execution.junit.TestsRepeater.repeat(TestsRepeater.java:11)
at
com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:35)
at
com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:232)
at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:55)
Caused by: Error : 942, Position : 16, Sql = UPDATE debezium.products SET
DESCRIPTION='18oz carpenter hammer' WHERE ID=106, OriginalSql = UPDATE
debezium.products SET DESCRIPTION='18oz carpenter hammer' WHERE ID=106, Error
Msg = ORA-00942: 表格或視觀表不存在
at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:513)
... 57 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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
