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

Amazon Managed Service for Apache Flink는 이전에 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"
)