Zhu Zhu created FLINK-8382: ------------------------------ Summary: sheduleRunAsync with a positive schedule delay does not work in JobMaster Key: FLINK-8382 URL: https://issues.apache.org/jira/browse/FLINK-8382 Project: Flink Issue Type: Bug Components: Distributed Coordination Affects Versions: 1.5.0 Reporter: Zhu Zhu
Here's the process of invoking scheduleRunAsync in JM: 1. The method scheduleRunAsync in JobMaster will forward a RunAsync message to FencedAkkaRpcActor. 2. FencedAkkaRpcActor handles it with method handleRunAsync from its parent class AkkaRpcActor: If the schedule delay is positive, handleRunAsync will schedule a raw RunAsync message without a FencedMessage/UnfencedMessage wrapped. 3. Later when FencedAkkaRpcActor receives the scheduled raw RunAsync message, it will discard it for not recognizing the message type. Thus the scheduleRunAsync does work. -- This message was sent by Atlassian JIRA (v6.4.14#64029)