Skip to content

Move and alter Flink savepoint files so that Flink job can start from a relocated savepoint

License

Notifications You must be signed in to change notification settings

CarlKarlssonSchmidt/flink-state-metadata

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

8 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Flink State Metadata Manipulation

Download

Download state-metadata-1.0.0.jar from Maven Central.

Usage

usage: java -jar state-metadata-1.0.0.jar --input.file old_metadata --output.file _metadata \
  --input.uri s3://old-bucket/old-savepoints/savepoint-b9888f-a23df1784fa3 \
  --output.uri s3://new-bucket/new-savepoints/savepoint-b9888f-a23df1784fa3

Requirements

Java and Maven

Build

mvn clean package

This repository is part of the example how-to guide: https://michalklempa.com/2020/03/move-flink-savepoint-to-different-s3-bucket/

About

Move and alter Flink savepoint files so that Flink job can start from a relocated savepoint

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages

  • Java 100.0%