[
https://issues.apache.org/jira/browse/FLINK-7665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321632#comment-17321632
]
Flink Jira Bot commented on FLINK-7665:
---------------------------------------
This issue and all of its Sub-Tasks have not been updated for 180 days. So, it
has been labeled "stale-minor". If you are still affected by this bug or are
still interested in this issue, please give an update and remove the label. In
7 days the issue will be closed automatically.
> 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)
