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)