You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/02 16:01:02 UTC
[jira] [Created] (FLINK-4999) Improve accuracy of
SingleInputGate#getNumberOfQueuedBuffers
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)