[jira] [Created] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers

[Shang Yuanchun (Jira)]

Ted Yu created FLINK-4999:
-----------------------------

             Summary: Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers
                 Key: FLINK-4999
                 URL: https://issues.apache.org/jira/browse/FLINK-4999
             Project: Flink
          Issue Type: Bug
            Reporter: Ted Yu
            Priority: Minor


{code}
    // re-try 3 times, if fails, return 0 for "unknown"
    for (int retry = 0; retry < 3; retry++) {
...
      catch (Exception ignored) {}
{code}
There is no synchronization around accessing inputChannels currently. Therefore the method expects potential exception.

Upon the 3rd try, synchronization should be taken w.r.t. inputChannels so that the return value is accurate.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)