org.apache.flink.runtime.taskmanager.JobManagerCommunicationFactory to org.apache.flink.runtime.io.network.partition.ResultPartitionConsumableNotifier