[jira] [Updated] (FLINK-937) Change the YARN Client to allocate all cluster resources, if no argument given

[ https://issues.apache.org/jira/browse/FLINK-937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-937: - Fix Version/s: (was: 0.9) > Change the YARN Client to allocate all cluster resources, if no arg

[jira] [Updated] (FLINK-1519) Web frontend task state mismatch when cancelling

[ https://issues.apache.org/jira/browse/FLINK-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1519: -- Fix Version/s: 0.9 > Web frontend task state mismatch when cancelling >

[jira] [Updated] (FLINK-1609) FileSystem doesn't expose current user's home directory

[ https://issues.apache.org/jira/browse/FLINK-1609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1609: -- Fix Version/s: 0.9 > FileSystem doesn't expose current user's home directory > -

[jira] [Commented] (FLINK-1558) Spurious failure in PipelinedPartitionQueueTest

[ https://issues.apache.org/jira/browse/FLINK-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362452#comment-14362452 ] Robert Metzger commented on FLINK-1558: --- I saw this (or a similar error recently on

[jira] [Updated] (FLINK-1558) Spurious failure in PipelinedPartitionQueueTest

[ https://issues.apache.org/jira/browse/FLINK-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1558: -- Fix Version/s: (was: 0.9) > Spurious failure in PipelinedPartitionQueueTest > --

[jira] [Resolved] (FLINK-1660) MultiTriggerPolicyTest timeout during test

[ https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1660. --- Resolution: Fixed Fix Version/s: 0.9 > MultiTriggerPolicyTest timeout during test > ---

[jira] [Resolved] (FLINK-1619) Add pre-aggregator for time windows

[ https://issues.apache.org/jira/browse/FLINK-1619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1619. --- Resolution: Fixed Fix Version/s: 0.9 > Add pre-aggregator for time windows > --

[jira] [Resolved] (FLINK-1643) Detect tumbling policies where trigger and eviction match

[ https://issues.apache.org/jira/browse/FLINK-1643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1643. --- Resolution: Fixed Fix Version/s: 0.9 > Detect tumbling policies where trigger and eviction matc

[jira] [Resolved] (FLINK-1657) Make count windows local automatically

[ https://issues.apache.org/jira/browse/FLINK-1657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1657. --- Resolution: Implemented > Make count windows local automatically > ---

[jira] [Resolved] (FLINK-1620) Add pre-aggregator for count windows

[ https://issues.apache.org/jira/browse/FLINK-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1620. --- Resolution: Fixed Fix Version/s: 0.9 > Add pre-aggregator for count windows > -

[jira] [Updated] (FLINK-1657) Make count windows local automatically

[ https://issues.apache.org/jira/browse/FLINK-1657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1657: -- Fix Version/s: 0.9 > Make count windows local automatically > -- > >

[jira] [Updated] (FLINK-1593) Improve exception handling int Streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-1593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1593: -- Fix Version/s: 0.9 > Improve exception handling int Streaming runtime >

[jira] [Updated] (FLINK-1569) Object reuse mode is not working with KeySelector functions.

[ https://issues.apache.org/jira/browse/FLINK-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1569: -- Fix Version/s: 0.9 > Object reuse mode is not working with KeySelector functions. >

[jira] [Updated] (FLINK-1625) Add cancel method to user defined sources and sinks and call them on task cancellation

[ https://issues.apache.org/jira/browse/FLINK-1625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1625: -- Fix Version/s: 0.9 > Add cancel method to user defined sources and sinks and call them on task

[jira] [Updated] (FLINK-1591) Remove window merge before flatten as an optimization

[ https://issues.apache.org/jira/browse/FLINK-1591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1591: -- Fix Version/s: 0.9 > Remove window merge before flatten as an optimization > ---

[jira] [Updated] (FLINK-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception

[ https://issues.apache.org/jira/browse/FLINK-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1646: -- Fix Version/s: 0.9 > Add name of required configuration value into the "Insufficient number of

[jira] [Updated] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

[ https://issues.apache.org/jira/browse/FLINK-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1640: -- Fix Version/s: 0.8.2 0.9 > FileOutputFormat writes to wrong path if path ends

[jira] [Updated] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

[ https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1587: -- Fix Version/s: 0.9 > coGroup throws NoSuchElementException on iterator.next() >

[jira] [Updated] (FLINK-1628) Strange behavior of "where" function during a join

[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1628: -- Fix Version/s: 0.8.2 0.9 > Strange behavior of "where" function during a join

[jira] [Updated] (FLINK-1654) Wrong scala example of POJO type in documentation

[ https://issues.apache.org/jira/browse/FLINK-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1654: -- Fix Version/s: 0.9 > Wrong scala example of POJO type in documentation > ---

[jira] [Updated] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1450: -- Fix Version/s: 0.9 > Add Fold operator to the Streaming api > --

[jira] [Updated] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1450: -- Assignee: Akshay Dixit > Add Fold operator to the Streaming api > --

[jira] [Updated] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts

[ https://issues.apache.org/jira/browse/FLINK-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1605: -- Fix Version/s: 0.9 > Create a shaded Hadoop fat jar to resolve library version conflicts > -

[jira] [Updated] (FLINK-1461) Add sortPartition operator

[ https://issues.apache.org/jira/browse/FLINK-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1461: -- Fix Version/s: 0.9 > Add sortPartition operator > -- > >

[jira] [Commented] (FLINK-1677) Properly Suppress Sysout Printing for the Degrees with exception test suite

[ https://issues.apache.org/jira/browse/FLINK-1677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362425#comment-14362425 ] ASF GitHub Bot commented on FLINK-1677: --- Github user asfgit closed the pull request

[GitHub] flink pull request: IntelliJ file ignored

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/483 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Resolved] (FLINK-1677) Properly Suppress Sysout Printing for the Degrees with exception test suite

[ https://issues.apache.org/jira/browse/FLINK-1677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1677. - Resolution: Fixed Fix Version/s: 0.9 Fixed via b891ff5f5cf034704de76f7d96b253d797b810dc and

[jira] [Resolved] (FLINK-1705) InstanceConnectionInfo returns wrong hostname when no DNS entry exists

[ https://issues.apache.org/jira/browse/FLINK-1705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1705. - Resolution: Fixed Fixed via 5308ac8325a5b31627023bfd002a9a3757d15c1f > InstanceConnectionInfo ret

[GitHub] flink pull request: [FLINK-1677][gelly] Suppressed Sysout Printing...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/475 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[GitHub] flink pull request: [FLINK-1450] Added fold operator for the Strea...

Github user akshaydixi commented on the pull request: https://github.com/apache/flink/pull/481#issuecomment-80946579 Thanks @gyfora. I'll try to not mess up commit history in future contributions! --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362328#comment-14362328 ] ASF GitHub Bot commented on FLINK-1450: --- Github user akshaydixi commented on the pul

[jira] [Resolved] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1450. --- Resolution: Implemented > Add Fold operator to the Streaming api > ---

[GitHub] flink pull request: [FLINK-1450] Added fold operator for the Strea...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/481#issuecomment-80941940 Hey, I squashed some of your small fix commits to your last, one and also fixed several minor issues: -I swapped the type parameter order to make the type

[jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362322#comment-14362322 ] ASF GitHub Bot commented on FLINK-1450: --- Github user gyfora commented on the pull re

[GitHub] flink pull request: [FLINK-1450] Added fold operator for the Strea...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/481 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362320#comment-14362320 ] ASF GitHub Bot commented on FLINK-1450: --- Github user asfgit closed the pull request