).Flink 1.10 
本机模式).方法org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.queueChannel
  调用toNotify.complete(null); 直接调用 
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.DefaultActionSuspension.resume()).上面resume()是怎么被调用的,想知道这个调用的过程

回复