[FLINK-7665] Use wait/notify in ContinuousFileReaderOperator

• Type: Improvement
• Status: Reopened
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.4.0
• Component/s: Connectors / Common
• Assignee: Unassigned
• Reporter: Ufuk Celebi
• Created: 21/Sep/17 19:33
• Updated: 29/Jul/21 07:38

Description

ContinuousFileReaderOperator has the following loop to receive input splits:

synchronized (checkpointLock) {
  if (currentSplit == null) {
    currentSplit = this.pendingSplits.poll();
    if (currentSplit == null) {
      if (this.shouldClose) {
        isRunning = false;
      } else {
        checkpointLock.wait(50);
      }
      continue;
    }
  }
}

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.