org.apache.flink.runtime.checkpoint.CheckpointCoordinator.ScheduledTrigger to java.util.concurrent.ScheduledFuture<?>