Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug][Sort] Fix the error that occurs when adding a table during whole database synchronization in Oracle. #7708

Closed
2 tasks done
e-mhui opened this issue Mar 27, 2023 · 0 comments · Fixed by #7709
Closed
2 tasks done
Assignees
Labels
component/sort type/bug Something is wrong
Milestone

Comments

@e-mhui
Copy link
Contributor

e-mhui commented Mar 27, 2023

What happened

2023-03-27 16:22:06.074 [debezium-reader-0] INFO  org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor [] - Table XE.FLINKUSER.VOTE_RECORD_03 is new and will be captured.
2023-03-27 16:22:06.136 [debezium-reader-0] INFO  org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.connector.oracle.OracleConnection [] - Database Version: Oracle Database 11g Express Edition Release 11.2.0.2.0 - 64bit Production
2023-03-27 16:22:07.254 [pool-19-thread-1] INFO  org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.jdbc.JdbcConnection [] - Connection gracefully closed
2023-03-27 16:22:12.404 [debezium-reader-0] ERROR org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.connector.oracle.logminer.LogMinerHelper [] - Mining session stopped due to the org.apache.inlong.sort.cdc.oracle.shaded.org.apache.kafka.connect.errors.DataException: file is not a valid field name
2023-03-27 16:22:12.405 [debezium-reader-0] ERROR org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.pipeline.ErrorHandler [] - Producer failure
org.apache.inlong.sort.cdc.oracle.shaded.org.apache.kafka.connect.errors.DataException: file is not a valid field name
	at org.apache.inlong.sort.cdc.oracle.shaded.org.apache.kafka.connect.data.Struct.lookupField(Struct.java:254) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.org.apache.kafka.connect.data.Struct.getCheckType(Struct.java:261) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.org.apache.kafka.connect.data.Struct.getString(Struct.java:158) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.org.apache.inlong.sort.cdc.base.relational.JdbcSourceEventDispatcher$SchemaChangeEventReceiver.schemaChangeRecordValue(JdbcSourceEventDispatcher.java:190) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.org.apache.inlong.sort.cdc.base.relational.JdbcSourceEventDispatcher$SchemaChangeEventReceiver.schemaChangeEvent(JdbcSourceEventDispatcher.java:220) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:113) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.org.apache.inlong.sort.cdc.base.relational.JdbcSourceEventDispatcher.dispatchSchemaChangeEvent(JdbcSourceEventDispatcher.java:149) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.org.apache.inlong.sort.cdc.base.relational.JdbcSourceEventDispatcher.dispatchSchemaChangeEvent(JdbcSourceEventDispatcher.java:64) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.dispatchSchemaChangeEventAndGetTableForNewCapturedTable(LogMinerQueryResultProcessor.java:336) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.getTableForDmlEvent(LogMinerQueryResultProcessor.java:323) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.processResult(LogMinerQueryResultProcessor.java:257) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:280) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.source.reader.fetch.OracleStreamFetchTask$RedoLogSplitReadTask.execute(OracleStreamFetchTask.java:125) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.source.reader.fetch.OracleStreamFetchTask.execute(OracleStreamFetchTask.java:73) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at org.apache.inlong.sort.cdc.oracle.shaded.org.apache.inlong.sort.cdc.base.source.reader.external.IncrementalSourceStreamFetcher.lambda$submitTask$0(IncrementalSourceStreamFetcher.java:86) ~[pool-1-thread-10-1679904897888-test-0308sort-connector-oracle-cdc-1.5.0-SNAPSHOT.jar:2.3.0]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_332]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_332]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_332]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_332]
	at java.lang.Thread.run(Thread.java:750) [?:1.8.0_332]

What you expected to happen

Successfully synchronized data.

How to reproduce

Run whole database synchronization in Oracle.

Environment

No response

InLong version

master

InLong Component

InLong Sort

Are you willing to submit PR?

  • Yes, I am willing to submit a PR!

Code of Conduct

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
component/sort type/bug Something is wrong
Projects
None yet
3 participants