Till Rohrmann created FLINK-9128: ------------------------------------ Summary: Add support for scheduleRunAsync for FencedRpcEndpoints Key: FLINK-9128 URL: https://issues.apache.org/jira/browse/FLINK-9128 Project: Flink Issue Type: Sub-task Components: Distributed Coordination Affects Versions: 1.5.0 Reporter: Till Rohrmann Assignee: Till Rohrmann Fix For: 1.5.0
Currently, the {{FencedRpcEndpoint}} cannot send a {{scheduleRunAsync}} message because it is not properly wrapped in a {{LocalFencedMessage}}. Due to this, the message will be dropped and the code will not be executed. -- This message was sent by Atlassian JIRA (v7.6.3#76005)