org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.runtime.state.RetrievableStateHandle<org.apache.flink.runtime.checkpoint.CompletedCheckpoint>, java.lang.String> to org.apache.flink.runtime.checkpoint.CompletedCheckpoint