[ https://issues.apache.org/jira/browse/FLINK-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zhu Zhu updated FLINK-8382: --------------------------- Description: 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 the message for not recognizing the message type*. was: 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. > 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 the message for not recognizing the message type*. -- This message was sent by Atlassian JIRA (v6.4.14#64029)