apache / apache/seatunnel

SeaTunnelServer.getCheckpointService() is null

Open
#9,622 0 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

when i submit a job, response error info:
{
"status": "fail",
"message": "Cannot invoke \"org.apache.seatunnel.engine.server.CheckpointService.getLatestCheckpointData(String)\" because the return value of \"org.apache.seatunnel.engine.server.SeaTunnelServer.getCheckpointService()\" is null"
}

### SeaTunnel Version

2.3.11

### SeaTunnel Config

```conf
env {
parallelism = 1
job.mode = "STREAMING"
checkpoint.interval = 10000
job.retry.times = 5
job.retry.interval.seconds = 5
}

source {
MySQL-CDC {
base-url = "jdbc:mysql://10.0.0.211:3306/vbzd"
username = "root"
password = "1234"
table-names = ["vbzd.user_use_record"]

startup.mode = "initial"
}
}

sink {
jdbc {
url = "jdbc:mysql://10.0.0.214:3306/test_vbzd?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true"
driver = "com.mysql.cj.jdbc.Driver"
user = "root"
password = "1234"
generate_sink_sql = true
database = test_vbzd
table = user_use_record
primary_keys = ["id"]
field_ide = UPPERCASE
schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST"
data_save_mode="APPEND_DATA"
}
}
```

### Running Command

```shell
no commond,use restfull api
```

### Error Exception

```log
Cannot invoke \"org.apache.seatunnel.engine.server.CheckpointService.getLatestCheckpointData(String)\" because the return value of \"org.apache.seatunnel.engine.server.SeaTunnelServer.getCheckpointService()\" is null
```

### Zeta or Flink or Spark Version

Zeta 2.3.11

### Java or Scala Version

_No response_

### Screenshots

_No response_

### Are you willing to submit PR?

- [ ] 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 by tracing the REST API job-submission path to SeaTunnelServer.getCheckpointService() and the call to CheckpointService.getLatestCheckpointData(String) in the Zeta 2.3.11 server. Reproduce the failure with the supplied MySQL-CDC streaming configuration and identify why the checkpoint service is null; done means submission no longer raises this exception and checkpoint lookup works.

Written by the indexing model from the issue text.

Assessment

Tech stack
java, mysql
Domain
backend, databases, distributed-systems
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
25/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.