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

2017-08-11 Thread Peter Ertl (JIRA)
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

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

2017-08-11 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123207#comment-16123207 ] Peter Ertl edited comment on FLINK-7430 at 8/11/17 11:21 AM: - It seems like

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

2017-08-11 Thread Peter Ertl (JIRA)
[ 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

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

2017-08-11 Thread Peter Ertl (JIRA)
[ 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

2017-08-11 Thread Peter Ertl (JIRA)
[ 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

2017-08-11 Thread Peter Ertl (JIRA)
[ 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

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

2017-08-11 Thread Peter Ertl (JIRA)
[ 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

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

2017-08-11 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123207#comment-16123207 ] Peter Ertl edited comment on FLINK-7430 at 8/11/17 11:20 AM: - It seems like

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

2017-08-11 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123207#comment-16123207 ] Peter Ertl commented on FLINK-7430: --- It seems like the task itself is finished but the output format is

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

2017-08-30 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16148230#comment-16148230 ] Peter Ertl edited comment on FLINK-7430 at 8/30/17 11:53 PM: - The current

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

2017-08-30 Thread Peter Ertl (JIRA)
[ 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] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

2017-08-30 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16148230#comment-16148230 ] Peter Ertl commented on FLINK-7430: --- The current behavior can lead to the streaming task terminating

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

2017-09-06 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16155873#comment-16155873 ] Peter Ertl commented on FLINK-7567: --- if the parallelism of the feedback stream MUST be equal to the

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

2017-09-06 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16155874#comment-16155874 ] Peter Ertl commented on FLINK-7430: --- Thanks for your great help guys! :) > ContinuousFileReaderOperator

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

2017-08-31 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16149754#comment-16149754 ] Peter Ertl commented on FLINK-7430: --- Perhaps, but I know too little about the background of restricting

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

2017-09-01 Thread Peter Ertl (JIRA)
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:

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

2017-09-05 Thread Peter Ertl (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153572#comment-16153572 ] Peter Ertl commented on FLINK-7567: --- Since this is kind of non-trivial to detect shouldn't flink somehow