Carl created FLINK-23051:
----------------------------
Summary: Savepoint an application for source of cdc-kafka, then
restart the application from the savepoint, offset not be recovered.
Key: FLINK-23051
URL: https://issues.apache.org/jira/browse/FLINK-23051
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing, Table SQL / Client
Affects Versions: 1.12.1
Environment: flink 1.12.1
Reporter: Carl
Fix For: 1.14.0
Attachments: image-2021-06-21-10-51-10-104.png,
image-2021-06-21-10-51-27-105.png, image-2021-06-21-10-52-07-814.png,
image-2021-06-21-10-52-45-724.png, image-2021-06-21-10-53-03-384.png,
image-2021-06-21-10-53-14-940.png, image-2021-06-21-10-54-30-241.png,
image-2021-06-21-10-57-11-824.png, image-2021-06-21-11-09-48-975.png,
image-2021-06-21-11-10-32-942.png
1. source: custom ogg-kafka
2. transform: group agg
3. sink: hbase
Program as follows:
!image-2021-06-21-10-54-30-241.png!
!image-2021-06-21-11-09-48-975.png!
!image-2021-06-21-10-52-07-814.png!
Execute the command in turn:
!image-2021-06-21-10-57-11-824.png!
What puzzles me is that Flink Kafka consumers don't consume source from
savepoint:
!image-2021-06-21-11-10-32-942.png!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
