[
https://issues.apache.org/jira/browse/FLINK-7665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-7665:
----------------------------------
Labels: stale-minor (was: )
> Use wait/notify in ContinuousFileReaderOperator
> -----------------------------------------------
>
> Key: FLINK-7665
> URL: https://issues.apache.org/jira/browse/FLINK-7665
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Common
> Affects Versions: 1.4.0
> Reporter: Ufuk Celebi
> Priority: Minor
> Labels: stale-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
(v8.3.4#803005)
