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)
