This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6b2e05fa6dc60a0ef6cde9398c2a776d2c7d9b32 Author: Till Rohrmann <[email protected]> AuthorDate: Tue Mar 16 11:58:52 2021 +0100 [hotfix] Annotate CheckpointsCleaner with @ThreadSafe --- .../java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java index ff2c6be..ab222e7 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java @@ -21,6 +21,8 @@ package org.apache.flink.runtime.checkpoint; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import javax.annotation.concurrent.ThreadSafe; + import java.io.Serializable; import java.util.concurrent.Executor; import java.util.concurrent.atomic.AtomicInteger; @@ -29,6 +31,7 @@ import java.util.concurrent.atomic.AtomicInteger; * Delegate class responsible for checkpoints cleaning and counting the number of checkpoints yet to * clean. */ +@ThreadSafe public class CheckpointsCleaner implements Serializable { private static final Logger LOG = LoggerFactory.getLogger(CheckpointsCleaner.class);
