Thanks for the quick reply Congxian.

The non-empty chk-N directories I looked at contained only files whose
names are UUIDs. Nothing named _metadata (unless HDFS hides files that
start with an underscore?).

Just to be clear though -- I should expect a metadata file when using
incremental checkpoints?

On Mon, Sep 14, 2020 at 10:46 PM Congxian Qiu <qcx978132...@gmail.com>
wrote:

> Hi Jeff
>    You can restore from retained checkpoint such as[1] `bin/flink run -s
> :checkpointMetaDataPath [:runArgs]` ,  you may find the metadata in the
> `chk-xxx` directory[2]
>
> [1]
> https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/checkpoints.html#resuming-from-a-retained-checkpoint
> [2]
> https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/checkpoints.html#directory-structure
> Best,
> Congxian
>
>
> Jeffrey Martin <jeffrey.martin...@gmail.com> 于2020年9月15日周二 下午1:30写道:
>
>> Hi,
>>
>> My job on Flink 1.10 uses RocksDB with incremental checkpointing enabled.
>> The checkpoints are retained on cancellation.
>>
>> How do I resume from the retained checkpoint after cancellation (e.g.,
>> when upgrading the job binary)? Docs say to use the checkpoint or savepoint
>> metadata file, but AFAICT there's no metadata file in HDFS in the various
>> directories under "$checkpointsDir/snapshots/$jobID",
>>
>> Thanks,
>>
>> Jeff Martin
>>
>>
>>
>
>

Reply via email to