[Bug] [Oracle-cdc] Oracle实时同步到Oracle时,只创建了表。没有插入数据
- Dominant language
- Java
- Stars
- 9.7k
- Forks
- 2.4k
- Avg merge
- 3d 13h
- Merged PRs (30d)
- 203
Description
### Search before asking
- [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues.
### What happened
我使用jdbc可以同步。但是现在需要做实时。所以使用了cdc。但是只是在目标表创建了表。并没有插入数据。
### SeaTunnel Version
2.3.11
### SeaTunnel Config
```conf
env {
execution.parallelism = 1
job.mode = "STREAMING"
}
source {
Oracle-CDC {
plugin_output = "customers"
username = "logminer_user"
password = "****"
database-names = ["ORCLCDB"]
schema-names = ["HR"]
table-names = ["ORCLCDB.HR.NOE"]
base-url = "jdbc:oracle:thin:@//****/ORCLCDB"
source.reader.close.timeout = 120000
scan.startup.mode = "initial"
}
}
sink {
jdbc {
url = "jdbc:oracle:thin:@//***/ORCLCDB"
driver = "oracle.jdbc.OracleDriver"
user = "scott"
password = "****"
plugin_output = "customers"
generate_sink_sql = true
database = ORCLCDB
table = "SCOTT.NOE"
primary_keys = ["ID"]
schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST"
data_save_mode="APPEND_DATA"
}
}
```
### Running Command
```shell
/opt/seatunnel/apache-seatunnel-2.3.11/bin/seatunnel.sh --config hr.conf -m local > seatunnel_hr.log 2>&1
```
### Error Exception
```log
没有发现影响进程的错误
```
### Zeta or Flink or Spark Version
_No response_
### Java or Scala Version
java11
### Screenshots
[seatunnel_hr.log](https://github.com/user-attachments/files/22581665/seatunnel_hr.log)
### Are you willing to submit PR?
- [x] Yes I am willing to submit a PR!
### Code of Conduct
- [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
Contributor guide
No contributing guide indexed for this repository
Research direction
Start with the Oracle-CDC source and JDBC sink configuration in the attached hr.conf example, then inspect seatunnel_hr.log and the reported screenshots for evidence of where initial scanning stops. Reproduce the streaming job with scan.startup.mode set to initial; done means the target table is created and the source rows are inserted into SCOTT.NOE.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- data-engineering, databases
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Quiet
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100