You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/01/06 14:35:00 UTC
[jira] [Commented] (FLINK-15327) 'Walkthrough DataStream Scala
nightly' sometimes fails with InterruptedException
[ https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008911#comment-17008911 ]
Arvid Heise commented on FLINK-15327:
-------------------------------------
Hi [~rmetzger] , this is independent of legacy source and more related to the recent work of Piotr on better exception handling for mailbox.
We are trying to improve that handling further by being more lenient on processing specific exceptions and I added a PR that replaces your fix with another fix. I'd like to keep the tests as they are as we really want to surpress these kind of exceptions while still avoid swallowing other exceptions during cancellation.
> '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, Runtime / Task, Tests
> Affects Versions: 1.11.0
> Reporter: Robert Metzger
> Assignee: Robert Metzger
> Priority: Major
> Labels: pull-request-available
> Time Spent: 20m
> 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)