체크포인트 지정 활성화 - Managed Service for Apache Flink
체크포인트 간격 설정체크포인트 유형 설정

Amazon Managed Service for Apache Flink(Amazon MSF)는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려져 있었습니다.

체크포인트 지정 활성화

환경 설정을 사용하여 체크포인트를 활성화할 수 있습니다. 체크포인트에 대한 자세한 내용은 Managed Service for Apache Flink Developer Guide의 Fault Tolerance를 참조하세요.

체크포인트 간격 설정

다음 Scala 코드 예제는 애플리케이션의 체크포인트 간격을 1분으로 설정합니다.

// start a checkpoint every 1 minute
stenv.enableCheckpointing(60000)

다음 Python 코드 예제는 애플리케이션의 체크포인트 간격을 1분으로 설정합니다.

st_env.get_config().get_configuration().set_string(
    "execution.checkpointing.interval", "1min"
)

체크포인트 유형 설정

다음 Scala 코드 예제는 애플리케이션의 체크포인트 모드를 EXACTLY_ONCE(기본값)(으)로 설정합니다.

// set mode to exactly-once (this is the default)
stenv.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE)

다음 Python 코드 예제는 애플리케이션의 체크포인트 모드를 EXACTLY_ONCE(기본값)으(로) 설정합니다.

st_env.get_config().get_configuration().set_string(
    "execution.checkpointing.mode", "EXACTLY_ONCE"
)