apache / apache/seatunnel

[Bug] [Oracle-cdc] Oracle实时同步到Oracle时,只创建了表。没有插入数据

Open
#9,907 6 comments 0 reactions 0 assignees View on GitHub
bug
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

Image

Image

Image

Image

[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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.