SeaTunnelServer.getCheckpointService() is null
- 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