[jira] [Closed] (FLINK-6087) The file-filter is only applied to directories in ContinuousFileMonitoringFunction

[ https://issues.apache.org/jira/browse/FLINK-6087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui closed FLINK-6087. Resolution: Invalid > The file-filter is only applied to directories in >

[jira] [Commented] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

[ https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021344#comment-16021344 ] Yassine Marzougui commented on FLINK-6515: -- Yes, I used flink.version=1.4-SNAPSHOT in the user

[jira] [Commented] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

[ https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021115#comment-16021115 ] Yassine Marzougui commented on FLINK-6515: -- Hi, I'm still bumping into this issue for the branch

[jira] [Updated] (FLINK-6087) The file-filter is only applied to directories in ContinuousFileMonitoringFunction

[ https://issues.apache.org/jira/browse/FLINK-6087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-6087: - Component/s: filesystem-connector > The file-filter is only applied to directories in >

[jira] [Created] (FLINK-6087) The file-filter is only applied to directories in ContinuousFileMonitoringFunction

Yassine Marzougui created FLINK-6087: Summary: The file-filter is only applied to directories in ContinuousFileMonitoringFunction Key: FLINK-6087 URL: https://issues.apache.org/jira/browse/FLINK-6087

[jira] [Updated] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-5320: - Fix Version/s: 1.2.0 > Fix result TypeInformation in WindowedStream.fold(ACC,

[jira] [Updated] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

[ https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-5432: - Fix Version/s: 1.3.0 1.2.0 > ContinuousFileMonitoringFunction is not

[jira] [Assigned] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

[ https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui reassigned FLINK-5432: Assignee: Yassine Marzougui > ContinuousFileMonitoringFunction is not monitoring

[jira] [Created] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

Yassine Marzougui created FLINK-5432: Summary: ContinuousFileMonitoringFunction is not monitoring nested files Key: FLINK-5432 URL: https://issues.apache.org/jira/browse/FLINK-5432 Project: Flink

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802570#comment-15802570 ] Yassine Marzougui commented on FLINK-2662: -- 1.3-SNAPSHOT (Commit: 6ac5794) > CompilerException:

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802548#comment-15802548 ] Yassine Marzougui commented on FLINK-2662: -- I came across this bug again with the following code:

[jira] [Resolved] (FLINK-4967) RockDB state backend fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui resolved FLINK-4967. -- Resolution: Resolved > RockDB state backend fails on Windows >

[jira] [Commented] (FLINK-4967) RockDB state backend fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802523#comment-15802523 ] Yassine Marzougui commented on FLINK-4967: -- Just checked it for the 1.2 and confirm the rocksdb

[jira] [Updated] (FLINK-4967) RockDB state backend fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-4967: - Fix Version/s: 1.2.0 > RockDB state backend fails on Windows >

[jira] [Updated] (FLINK-5407) Savepoint for iterative Task fails.

[ https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-5407: - Attachment: SavepointBug.java I attached a simplified version of the job reproducing the

[jira] [Commented] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744775#comment-15744775 ] Yassine Marzougui commented on FLINK-5320: -- [~aljoscha] I just opened a pull request for it.

[jira] [Updated] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-5320: - Affects Version/s: 1.2.0 > Fix result TypeInformation in WindowedStream.fold(ACC,

[jira] [Updated] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-5320: - Description: The WindowedStream.fold(ACC, FoldFunction, WindowFunction) does not

[jira] [Created] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

Yassine Marzougui created FLINK-5320: Summary: Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction) Key: FLINK-5320 URL: https://issues.apache.org/jira/browse/FLINK-5320

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15687298#comment-15687298 ] Yassine Marzougui commented on FLINK-3869: -- Thank you for the feedback [~sjwiesman]. >

[jira] [Comment Edited] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683873#comment-15683873 ] Yassine Marzougui edited comment on FLINK-3869 at 11/21/16 3:35 PM:

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683873#comment-15683873 ] Yassine Marzougui commented on FLINK-3869: -- [~aljoscha] Yes, I could fix the Scala API en the end

[jira] [Comment Edited] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15669039#comment-15669039 ] Yassine Marzougui edited comment on FLINK-3869 at 11/21/16 3:35 PM:

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15669039#comment-15669039 ] Yassine Marzougui commented on FLINK-3869: -- [~aljoscha] would it be OK if I incorporate the

[jira] [Updated] (FLINK-4967) RockDB state backend fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-4967: - Labels: (was: easyfix) > RockDB state backend fails on Windows >

[jira] [Created] (FLINK-4967) RockDB state backend fails on Windows

Yassine Marzougui created FLINK-4967: Summary: RockDB state backend fails on Windows Key: FLINK-4967 URL: https://issues.apache.org/jira/browse/FLINK-4967 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-2662: - Attachment: Bug.java I ran into the same problem with Flink 1.1.3 when trying to perform