[
https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000903#comment-17000903
]
Robert Metzger commented on FLINK-15327:
----------------------------------------
[~pnowojski]: I had an offline chat with [~sewen] about this. He mentioned to
me that in the past, we were not printing exceptions during cancellation, to
avoid polluting the log. It seems that the behavior of this has changed with
the {{LegacySourceFunctionThread}}. Should we change it back?
> 'Walkthrough DataStream Scala nightly' sometimes fails with
> InterruptedException
> --------------------------------------------------------------------------------
>
> Key: FLINK-15327
> URL: https://issues.apache.org/jira/browse/FLINK-15327
> Project: Flink
> Issue Type: Bug
> Components: Examples, Tests
> Affects Versions: 1.11.0
> Reporter: Robert Metzger
> Assignee: Robert Metzger
> Priority: Major
> Labels: pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> The "Walkthrough DataStream Scala nightly end-to-end test"
> (test_datastream_walkthroughs.sh) failed with the following error found in
> the log
>
>
> {code:java}
> 2019-12-19 12:57:03,131 WARN
> org.apache.flink.streaming.runtime.tasks.StreamTask - Error while
> canceling task.
> java.lang.RuntimeException: java.lang.InterruptedException: sleep interrupted
> at
> org.apache.flink.walkthrough.common.source.TransactionSource$RateLimitedIterator.next(TransactionSource.java:60)
> at
> org.apache.flink.streaming.api.functions.source.FromIteratorFunction.run(FromIteratorFunction.java:43)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
> at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:196)
> Caused by: java.lang.InterruptedException: sleep interrupted
> at java.lang.Thread.sleep(Native Method)
> at
> org.apache.flink.walkthrough.common.source.TransactionSource$RateLimitedIterator.next(TransactionSource.java:58)
> ... 4 more
> {code}
>
> Run:
> [https://dev.azure.com/rmetzger/Flink/_build/results?buildId=3742&view=logs&j=b1623ac9-0979-5b0d-2e5e-1377d695c991&t=48867695-c47f-5af3-2f21-7845611247b9]
> I assume this error happens only rarely.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
