[jira] [Created] (FLINK-7665) Use wait/notify in ContinuousFileReaderOperator

["Ufuk Celebi (JIRA)" <ji...@apache.org>]

Ufuk Celebi created FLINK-7665:
----------------------------------

             Summary: Use wait/notify in ContinuousFileReaderOperator
                 Key: FLINK-7665
                 URL: https://issues.apache.org/jira/browse/FLINK-7665
             Project: Flink
          Issue Type: Improvement
          Components: Streaming Connectors
    Affects Versions: 1.4.0
            Reporter: Ufuk Celebi
            Priority: Minor


{{ContinuousFileReaderOperator}} has the following loop to receive input splits:
{code}
synchronized (checkpointLock) {
  if (currentSplit == null) {
    currentSplit = this.pendingSplits.poll();
    if (currentSplit == null) {
      if (this.shouldClose) {
        isRunning = false;
      } else {
        checkpointLock.wait(50);
      }
      continue;
    }
  }
}
{code}

I think we can replace this with a {{wait()}} and {{notify()}} in {{addSplit}} and {{close}}.

If there is a reason to keep the {{wait(50)}}, feel free to close this issue. :-)



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)