[
https://issues.apache.org/jira/browse/FLINK-23051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366549#comment-17366549
]
Carl commented on FLINK-23051:
------------------------------
[~twalthr] it is a demo program, flink version stays constant during restore.
Then i found some info from log in taskmanager:
Resetting offset for partition optimizer-ogg-source-0 to offset 0;
Resetting offset for partition optimizer-ogg-source-1 to offset 0;
Resetting offset for partition optimizer-ogg-source-2 to offset 0;
But I've checked the savepoint file on hdfs and I confirm the savepoint file
exists.
> 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
> Priority: Major
> 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
>
> Original Estimate: 12h
> Remaining Estimate: 12h
>
> 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)
