java.lang.Object to org.apache.flink.util.OptionalFailure<java.lang.Object>