-
Notifications
You must be signed in to change notification settings - Fork 1.7k
Closed
Labels
bugSomething isn't workingSomething isn't working
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
When i submit a sync task of kafka, task failed and thrown a nullpoint exception.
What you expected to happen
Task should succeed.
How to reproduce
Job content:
{
"job": {
"content": [
{
"reader": {
"parameter": {
"topic": "tiezhu_in_one",
"mode": "earliest-offset",
"offset": "EARLIEST",
"groupId": "*",
"codec": "json",
"column": [
{
"name": "id",
"type": "int"
},
{
"name": "name",
"type": "String"
}
],
"consumerSettings": {
"bootstrap.servers": "flink01:9092,flink02:9092,flink03:9092",
"auto.commit.enable": "false"
}
},
"name": "kafkasource"
},
"writer": {
"name": "streamwriter",
"parameter": {
"print": true
}
}
}
],
"setting": {
"restore": {
"isRestore": true,
"isStream": true
},
"speed": {
"readerChannel": 1,
"writerChannel": 1
}
}
}
}
Anything else
No response
Version
master
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working
