[jira] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16155874#comment-16155874 ] Peter Ertl commented on FLINK-7430: --- Thanks for your great help guys! :) > ContinuousFi

[jira] [Commented] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work

[ https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16155873#comment-16155873 ] Peter Ertl commented on FLINK-7567: --- if the parallelism of the feedback stream MUST be e

[jira] [Commented] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work

[ https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153572#comment-16153572 ] Peter Ertl commented on FLINK-7567: --- Since this is kind of non-trivial to detect shouldn

[jira] [Created] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work

Peter Ertl created FLINK-7567: - Summary: DataStream#iterate() on env.fromElements() / env.fromCollection() does not work Key: FLINK-7567 URL: https://issues.apache.org/jira/browse/FLINK-7567 Project: Flin

[jira] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149754#comment-16149754 ] Peter Ertl commented on FLINK-7430: --- Perhaps, but I know too little about the background

[jira] [Updated] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Ertl updated FLINK-7430: -- Priority: Critical (was: Major) > ContinuousFileReaderOperator swallows exceptions > --

[jira] [Comment Edited] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148230#comment-16148230 ] Peter Ertl edited comment on FLINK-7430 at 8/30/17 11:53 PM: -

[jira] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148230#comment-16148230 ] Peter Ertl commented on FLINK-7430: --- The current behavior can lead to the streaming task

[jira] [Comment Edited] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123207#comment-16123207 ] Peter Ertl edited comment on FLINK-7430 at 8/11/17 11:21 AM: -

[jira] [Comment Edited] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123207#comment-16123207 ] Peter Ertl edited comment on FLINK-7430 at 8/11/17 11:20 AM: -

[jira] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123207#comment-16123207 ] Peter Ertl commented on FLINK-7430: --- It seems like the task itself is finished but the o

[jira] [Updated] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Ertl updated FLINK-7430: -- Description: The class *ContinuousFileReaderOperator* is swallowing exceptions as the following example

[jira] [Updated] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Ertl updated FLINK-7430: -- Description: The class *ContinuousFileReaderOperator* is swallowing exceptions as the following example

[jira] [Updated] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Ertl updated FLINK-7430: -- Description: The class *ContinuousFileReaderOperator* is swallowing exception as the following example

[jira] [Updated] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Ertl updated FLINK-7430: -- Environment: - macOS 10.12.6 - Oracle JDK 1.8.0_144 - Flink 1.3.2 > ContinuousFileReaderOperator swallo

[jira] [Updated] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Ertl updated FLINK-7430: -- Description: The class ContinuousFileReaderOperator is swallowing exception as the following example de

[jira] [Created] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

Peter Ertl created FLINK-7430: - Summary: ContinuousFileReaderOperator swallows exceptions Key: FLINK-7430 URL: https://issues.apache.org/jira/browse/FLINK-7430 Project: Flink Issue Type: Bug