You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Robert Metzger (Jira)" <ji...@apache.org> on 2019/12/20 14:12: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=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)