apache / apache/seatunnel

[Bug] [Module Name] Bug title

Open
#10,835 2 comments 0 reactions 1 assignee Claimed by @ZZY1-OSS View on GitHub
bug needs-info
Dominant language
Java
Stars
9.7k
Forks
2.4k
Avg merge
3d 9h
Merged PRs (30d)
204

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

Why does Seatunnel Oracle-CDC get stuck at the source when synchronizing 200 million records, always showing 0 records?

### SeaTunnel Version

2.2.13

### SeaTunnel Config

```conf
env {
job.mode = "STREAMING"
parallelism = 1
checkpoint.interval = 120000
checkpoint.timeout = 600000
}

source {
Oracle-CDC {
url = "jdbc:oracle:thin:@xxx"
database-names = ["ZAPT2"]
schema-name = "TC_RKXT"
username = "xxx"
password = "xxx"
table-names = ["KETTLE.TEMP.TEMP_RYXX"]
skip_analyze = true
snapshot.split.size = 5000
snapshot.fetch.size = 2048
chunk-key.even-distribution.factor.upper-bound = 3000
snapshot.mode = initial
exactly = false
format = "default"
table-names-config = [
{
table = "ZAPT2.TC_RKXT.T_LDRK_JBXX"
primaryKeys = ["LDRK_ID"]
snapshotSplitcolumn="LDRK_ID"
}
]
server-time-zone = "UTC"
}
}
```

### Running Command

```shell
env {
job.mode = "STREAMING"
parallelism = 1
checkpoint.interval = 120000
checkpoint.timeout = 600000
}

source {
Oracle-CDC {
url = "jdbc:oracle:thin:@xxx"
database-names = ["ZAPT2"]
schema-name = "TC_RKXT"
username = "xxx"
password = "xxx"
table-names = ["KETTLE.TEMP.TEMP_RYXX"]
skip_analyze = true
snapshot.split.size = 5000
snapshot.fetch.size = 2048
chunk-key.even-distribution.factor.upper-bound = 3000
snapshot.mode = initial
exactly = false
format = "default"
table-names-config = [
{
table = "ZAPT2.TC_RKXT.T_LDRK_JBXX"
primaryKeys = ["LDRK_ID"]
snapshotSplitcolumn="LDRK_ID"
}
]
server-time-zone = "UTC"
}
}
```

### Error Exception

```log
select MAX("LDRK ID") FROM (SELECT "LDRK ID" FROM "TC_RKXT"."TSELECTLDRK JBXX" WHERE "LDRK ID" >= :1 ORDER BY "LDRK ID" ASC) WHERE ROWNUM <= 8096

The execution statement in Oracle is just like this, and the log does not report any errors either.
```

### Zeta or Flink or Spark Version

Zeta 2.3.13

### Java or Scala Version

_No response_

### Screenshots

The source reads all 0

Image

### 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

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.