[GitHub] flink issue #3497: [FLINK-6002] Documentation: 'MacOS X' section in Quicksta...

2017-03-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3497 +1 to merge. --- 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

[jira] [Commented] (FLINK-4545) Flink automatically manages TM network buffer

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901930#comment-15901930 ] ASF GitHub Bot commented on FLINK-4545: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3467: [FLINK-4545] preparations for removing the network buffer...

2017-03-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3467 I think this is a good change, merging this... @zhijiangW Managing the buffers changes in some followup PR, first adjusting the local pools, then the global pool. Managing buffers in a

[jira] [Comment Edited] (FLINK-5785) Add an Imputer for preparing data

2017-03-08 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901830#comment-15901830 ] Stavros Kontopoulos edited comment on FLINK-5785 at 3/8/17 8:26 PM:

[jira] [Comment Edited] (FLINK-5785) Add an Imputer for preparing data

2017-03-08 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901830#comment-15901830 ] Stavros Kontopoulos edited comment on FLINK-5785 at 3/8/17 8:25 PM:

[jira] [Comment Edited] (FLINK-5785) Add an Imputer for preparing data

2017-03-08 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901830#comment-15901830 ] Stavros Kontopoulos edited comment on FLINK-5785 at 3/8/17 8:25 PM:

[jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901887#comment-15901887 ] ASF GitHub Bot commented on FLINK-5929: --- Github user sjwiesman commented on the issue:

[GitHub] flink issue #3479: [FLINK-5929] Allow Access to Per-Window State in ProcessW...

2017-03-08 Thread sjwiesman
Github user sjwiesman commented on the issue: https://github.com/apache/flink/pull/3479 @aljoscha I made the changes you asked for. Just a heads up, there are a number of files that were superficially changed when migrating from apply -> process but are otherwise untouched. --- If

[jira] [Commented] (FLINK-5731) Split up CI builds

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901867#comment-15901867 ] ASF GitHub Bot commented on FLINK-5731: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #3344: FLINK-5731 Spilt up tests into three disjoint groups

2017-03-08 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3344 I agree that we have this issue again. If you want faster feedback on your pull requests, I recommend setting up travis for your flink fork. Then, every time you push to your repo, you'll

[jira] [Comment Edited] (FLINK-5785) Add an Imputer for preparing data

2017-03-08 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901830#comment-15901830 ] Stavros Kontopoulos edited comment on FLINK-5785 at 3/8/17 7:25 PM:

[jira] [Commented] (FLINK-6002) Documentation: 'MacOS X' under 'Download and Start Flink' in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901831#comment-15901831 ] Bowen Li commented on FLINK-6002: - Hi guys, how to assign this issue to myself? > Documentation: 'MacOS

[GitHub] flink pull request #3484: [FLINK-4460] Side Outputs in Flink

2017-03-08 Thread chenqin
Github user chenqin commented on a diff in the pull request: https://github.com/apache/flink/pull/3484#discussion_r104997566 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java --- @@ -60,6 +60,7 @@ import

[jira] [Commented] (FLINK-4460) Side Outputs in Flink

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901828#comment-15901828 ] ASF GitHub Bot commented on FLINK-4460: --- Github user chenqin commented on a diff in the pull

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

2017-03-08 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901830#comment-15901830 ] Stavros Kontopoulos commented on FLINK-5785: [~beera] If you do that please follow my approach

[jira] [Updated] (FLINK-6002) Documentation: 'MacOS X' under 'Download and Start Flink' in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Summary: Documentation: 'MacOS X' under 'Download and Start Flink' in Quickstart page is not rendered

[jira] [Commented] (FLINK-6002) "Setup: Download and Start Flink" / "MacOS X" in Quickstart page is not rendered correctly

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901803#comment-15901803 ] ASF GitHub Bot commented on FLINK-6002: --- GitHub user phoenixjiangnan opened a pull request:

[GitHub] flink pull request #3497: [FLINK-6002] 'MacOS X' section in Quickstart page ...

2017-03-08 Thread phoenixjiangnan
GitHub user phoenixjiangnan opened a pull request: https://github.com/apache/flink/pull/3497 [FLINK-6002] 'MacOS X' section in Quickstart page is not rendered correctly Currently, ["MacOS X" section under "Setup: Download and Start Flink" in Quickstart

[jira] [Commented] (FLINK-4460) Side Outputs in Flink

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901801#comment-15901801 ] ASF GitHub Bot commented on FLINK-4460: --- Github user chenqin commented on a diff in the pull

[GitHub] flink pull request #3484: [FLINK-4460] Side Outputs in Flink

2017-03-08 Thread chenqin
Github user chenqin commented on a diff in the pull request: https://github.com/apache/flink/pull/3484#discussion_r104996349 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java --- @@ -85,6 +86,7 @@ private Set sources;

[jira] [Commented] (FLINK-4460) Side Outputs in Flink

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901795#comment-15901795 ] ASF GitHub Bot commented on FLINK-4460: --- Github user chenqin commented on a diff in the pull

[GitHub] flink pull request #3484: [FLINK-4460] Side Outputs in Flink

2017-03-08 Thread chenqin
Github user chenqin commented on a diff in the pull request: https://github.com/apache/flink/pull/3484#discussion_r104995971 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java --- @@ -333,32 +356,41 @@ public void addEdge(Integer

[jira] [Commented] (FLINK-6001) NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness

2017-03-08 Thread Vladislav Pernin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901756#comment-15901756 ] Vladislav Pernin commented on FLINK-6001: - Another reproducer version without a "sleeping map" but

[jira] [Updated] (FLINK-6002) "Setup: Download and Start Flink" / "MacOS X" in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Description: On

[jira] [Updated] (FLINK-6002) "Setup: Download and Start Flink" / "MacOS X" in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Description: On

[jira] [Updated] (FLINK-6002) "Setup: Download and Start Flink" / "MacOS X" in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Description: On

[jira] [Updated] (FLINK-6002) "Setup: Download and Start Flink" / "MacOS X" in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Affects Version/s: 1.2.0 Priority: Trivial (was: Major) Fix Version/s: 1.2.1

[jira] [Created] (FLINK-6002) Setup: Download and Start Flink/MacOS X in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6002: --- Summary: Setup: Download and Start Flink/MacOS X in Quickstart page is not rendered correctly Key: FLINK-6002 URL: https://issues.apache.org/jira/browse/FLINK-6002 Project:

[GitHub] flink pull request #3494: [FLINK-5635] [docker] Improve Docker tooling

2017-03-08 Thread patricklucas
Github user patricklucas commented on a diff in the pull request: https://github.com/apache/flink/pull/3494#discussion_r104986831 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -36,22 +31,24 @@ ENV PATH $PATH:$FLINK_HOME/bin EXPOSE 8081 EXPOSE 6123 +#

[jira] [Commented] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901718#comment-15901718 ] ASF GitHub Bot commented on FLINK-5635: --- Github user patricklucas commented on a diff in the pull

[jira] [Commented] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901705#comment-15901705 ] ASF GitHub Bot commented on FLINK-5635: --- Github user iemejia commented on a diff in the pull

[GitHub] flink pull request #3494: [FLINK-5635] [docker] Improve Docker tooling

2017-03-08 Thread iemejia
Github user iemejia commented on a diff in the pull request: https://github.com/apache/flink/pull/3494#discussion_r104984654 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -36,22 +31,24 @@ ENV PATH $PATH:$FLINK_HOME/bin EXPOSE 8081 EXPOSE 6123 +#

[GitHub] flink pull request #3494: [FLINK-5635] [docker] Improve Docker tooling

2017-03-08 Thread patricklucas
Github user patricklucas commented on a diff in the pull request: https://github.com/apache/flink/pull/3494#discussion_r104982158 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -36,22 +31,24 @@ ENV PATH $PATH:$FLINK_HOME/bin EXPOSE 8081 EXPOSE 6123 +#

[jira] [Commented] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901687#comment-15901687 ] ASF GitHub Bot commented on FLINK-5635: --- Github user patricklucas commented on a diff in the pull

[GitHub] flink issue #3493: [FLINK-3026] Publish the flink docker container to the do...

2017-03-08 Thread iemejia
Github user iemejia commented on the issue: https://github.com/apache/flink/pull/3493 I oups not the ubuntu, the non-alpine one :) --- 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

[jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901677#comment-15901677 ] ASF GitHub Bot commented on FLINK-3026: --- Github user iemejia commented on the issue:

[jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901673#comment-15901673 ] ASF GitHub Bot commented on FLINK-3026: --- Github user iemejia commented on the issue:

[GitHub] flink issue #3493: [FLINK-3026] Publish the flink docker container to the do...

2017-03-08 Thread iemejia
Github user iemejia commented on the issue: https://github.com/apache/flink/pull/3493 I will, and add the commits for the ubuntu image, probably I will create a JIRA for this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901670#comment-15901670 ] ASF GitHub Bot commented on FLINK-5635: --- Github user iemejia commented on a diff in the pull

[GitHub] flink pull request #3494: [FLINK-5635] [docker] Improve Docker tooling

2017-03-08 Thread iemejia
Github user iemejia commented on a diff in the pull request: https://github.com/apache/flink/pull/3494#discussion_r104980420 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -36,22 +31,24 @@ ENV PATH $PATH:$FLINK_HOME/bin EXPOSE 8081 EXPOSE 6123 +#

[jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901665#comment-15901665 ] ASF GitHub Bot commented on FLINK-3026: --- Github user patricklucas commented on the issue:

[GitHub] flink issue #3493: [FLINK-3026] Publish the flink docker container to the do...

2017-03-08 Thread patricklucas
Github user patricklucas commented on the issue: https://github.com/apache/flink/pull/3493 Since this PR is no longer directly related to publishing official Docker images, could you change its title? (See my reply to your comment on #3494) --- If your project is set up for it, you

[jira] [Commented] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901660#comment-15901660 ] ASF GitHub Bot commented on FLINK-5635: --- Github user patricklucas commented on a diff in the pull

[GitHub] flink pull request #3494: [FLINK-5635] [docker] Improve Docker tooling

2017-03-08 Thread patricklucas
Github user patricklucas commented on a diff in the pull request: https://github.com/apache/flink/pull/3494#discussion_r104979246 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -36,22 +31,24 @@ ENV PATH $PATH:$FLINK_HOME/bin EXPOSE 8081 EXPOSE 6123 +#

[jira] [Commented] (FLINK-3679) Allow Kafka consumer to skip corrupted messages

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901624#comment-15901624 ] ASF GitHub Bot commented on FLINK-3679: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3314: [FLINK-3679] DeserializationSchema should handle zero or ...

2017-03-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3314 I've made some final general improvements in https://github.com/tzulitai/flink/tree/PR-FLINK-3679. Doing a Travis run before merging:

[jira] [Commented] (FLINK-6001) NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness

2017-03-08 Thread Vladislav Pernin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901616#comment-15901616 ] Vladislav Pernin commented on FLINK-6001: - I have simplified the reproducer but it fails less

[jira] [Commented] (FLINK-5731) Split up CI builds

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901611#comment-15901611 ] ASF GitHub Bot commented on FLINK-5731: --- Github user addisonj commented on the issue:

[GitHub] flink issue #3344: FLINK-5731 Spilt up tests into three disjoint groups

2017-03-08 Thread addisonj
Github user addisonj commented on the issue: https://github.com/apache/flink/pull/3344 Even with this in place, I am still regularly seeing timeouts on quite a few PRs. In addition to the travis queue being backed up, its taking 12+ hours to get feedback which is mostly just build

[GitHub] flink issue #3489: [FLINK-5983] [table] Convert FOR into WHILE loops for agg...

2017-03-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3489 Thanks @fhueske. I could not find anything suspicious. I will rebase and merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Updated] (FLINK-6001) NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness

2017-03-08 Thread Vladislav Pernin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladislav Pernin updated FLINK-6001: Description: I try to isolate the problem in a small and simple reproducer by extracting

[jira] [Commented] (FLINK-1579) Create a Flink History Server

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901581#comment-15901581 ] ASF GitHub Bot commented on FLINK-1579: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-5984) Add resetAccumulator method for AggregateFunction

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901574#comment-15901574 ] ASF GitHub Bot commented on FLINK-5984: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3460: [FLINK-1579] Implement History Server

2017-03-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3460 @uce I've addressed the remaining comments. Still undecided on the handler re-use; tests/documentation still missing. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink issue #3496: [FLINK-5984] [table] add resetAccumulator method for Aggr...

2017-03-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3496 Thanks @shaoxuan-wang. The PR looks good. FLINK-5983 has been merged and FLINK-5963 will be merged soon. It would be great if you could rebase your code on the master once that was done.

[jira] [Commented] (FLINK-5983) Replace for/foreach/map in aggregates by while loops

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901566#comment-15901566 ] ASF GitHub Bot commented on FLINK-5983: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3489: [FLINK-5983] [table] Convert FOR into WHILE loops ...

2017-03-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3489 --- 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

[jira] [Resolved] (FLINK-5983) Replace for/foreach/map in aggregates by while loops

2017-03-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-5983. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 1.3.0:

[jira] [Created] (FLINK-6001) NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness

2017-03-08 Thread Vladislav Pernin (JIRA)
Vladislav Pernin created FLINK-6001: --- Summary: NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness Key: FLINK-6001 URL: https://issues.apache.org/jira/browse/FLINK-6001

[jira] [Commented] (FLINK-5983) Replace for/foreach/map in aggregates by while loops

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901545#comment-15901545 ] ASF GitHub Bot commented on FLINK-5983: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

2017-03-08 Thread Anna Beer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901539#comment-15901539 ] Anna Beer commented on FLINK-5785: -- I just started to try it > Add an Imputer for preparing data >

[jira] [Commented] (FLINK-5963) Remove preparation mapper of DataSetAggregate

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901518#comment-15901518 ] ASF GitHub Bot commented on FLINK-5963: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3472: [FLINK-5963] [table] Remove prepare mapper of DataSetAggr...

2017-03-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3472 Thanks for the reviews @shaoxuan-wang and @sunjincheng121. Will merge this PR --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-5804) Add [non-partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901515#comment-15901515 ] ASF GitHub Bot commented on FLINK-5804: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3491: [FLINK-5804] [table] Add support for procTime non-partiti...

2017-03-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3491 Thanks for the update @sunjincheng121. The PR looks good to merge. --- 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

[GitHub] flink issue #3389: [FLINK-5881] [table] ScalarFunction(UDF) should support v...

2017-03-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3389 Thanks @clarkyzl. I will review the PR tomorrow. --- 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

[jira] [Commented] (FLINK-5594) Use higher-resolution graphic on Flink project site homepage

2017-03-08 Thread Mike Winters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901507#comment-15901507 ] Mike Winters commented on FLINK-5594: - Addressed by this PR:

[jira] [Commented] (FLINK-5881) ScalarFunction(UDF) should support variable types and variable arguments

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901488#comment-15901488 ] ASF GitHub Bot commented on FLINK-5881: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-5047) Add sliding group-windows for batch tables

2017-03-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901480#comment-15901480 ] Timo Walther commented on FLINK-5047: - Fixed for time-based windows in 1.3.0:

[jira] [Commented] (FLINK-5047) Add sliding group-windows for batch tables

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901477#comment-15901477 ] ASF GitHub Bot commented on FLINK-5047: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3364: [FLINK-5047] [table] Add sliding group-windows for...

2017-03-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3364 --- 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

[jira] [Commented] (FLINK-5047) Add sliding group-windows for batch tables

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901463#comment-15901463 ] ASF GitHub Bot commented on FLINK-5047: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #3364: [FLINK-5047] [table] Add sliding group-windows for...

2017-03-08 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3364#discussion_r104948259 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/IncrementalAggregateAllWindowFunction.scala --- @@ -53,7

[jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901447#comment-15901447 ] ASF GitHub Bot commented on FLINK-3155: --- Github user kdombeck commented on a diff in the pull

[GitHub] flink pull request #3490: [FLINK-3155] Update Docker to use the latest 1.1.x...

2017-03-08 Thread kdombeck
Github user kdombeck commented on a diff in the pull request: https://github.com/apache/flink/pull/3490#discussion_r104945513 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -22,7 +22,7 @@ FROM java:8-jre-alpine RUN apk add --no-cache bash snappy # Configure

[jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901439#comment-15901439 ] ASF GitHub Bot commented on FLINK-3155: --- Github user kdombeck commented on the issue:

[GitHub] flink issue #3490: [FLINK-3155] Update Docker to use the latest 1.1.x versio...

2017-03-08 Thread kdombeck
Github user kdombeck commented on the issue: https://github.com/apache/flink/pull/3490 Added to existing Jira [issue](https://issues.apache.org/jira/browse/FLINK-3155) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901431#comment-15901431 ] ASF GitHub Bot commented on FLINK-5414: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3338: [FLINK-5414] [table] Bump up Calcite version to 1....

2017-03-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3338 --- 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

[jira] [Resolved] (FLINK-5414) Bump up Calcite version to 1.11

2017-03-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-5414. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 1.3.0:

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901430#comment-15901430 ] ASF GitHub Bot commented on FLINK-5414: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3426: [FLINK-5414] [table] Bump up Calcite version to 1....

2017-03-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3426 --- 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

[jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible)

2017-03-08 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901424#comment-15901424 ] Gyula Fora commented on FLINK-5985: --- I was somehow assuming that this affects all jobs. Unfortunately I

[jira] [Commented] (FLINK-5984) Add resetAccumulator method for AggregateFunction

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901423#comment-15901423 ] ASF GitHub Bot commented on FLINK-5984: --- Github user shaoxuan-wang commented on the issue:

[GitHub] flink issue #3496: [FLINK-5984] [table] add resetAccumulator method for Aggr...

2017-03-08 Thread shaoxuan-wang
Github user shaoxuan-wang commented on the issue: https://github.com/apache/flink/pull/3496 @fhueske , do you have plan to merge FLINK-5983 and FLINK-5963 very soon? This PR probably need rebase once your two PRs are merged, as changes are overlapped. --- If your project is set up

[jira] [Commented] (FLINK-5984) Add resetAccumulator method for AggregateFunction

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901405#comment-15901405 ] ASF GitHub Bot commented on FLINK-5984: --- GitHub user shaoxuan-wang opened a pull request:

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901402#comment-15901402 ] ASF GitHub Bot commented on FLINK-5414: --- Github user twalthr commented on the issue:

[jira] [Assigned] (FLINK-5177) Improve nullability handling

2017-03-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-5177: --- Assignee: Timo Walther > Improve nullability handling > - > >

[GitHub] flink pull request #3496: [FLINK-5984] [table] add resetAccumulator method f...

2017-03-08 Thread shaoxuan-wang
GitHub user shaoxuan-wang opened a pull request: https://github.com/apache/flink/pull/3496 [FLINK-5984] [table] add resetAccumulator method for AggregateFunction Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink issue #3426: [FLINK-5414] [table] Bump up Calcite version to 1.11

2017-03-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3426 Thanks for the update @haohui. I fixed the decimal issues by applying changes from @wuchong's PR. I think for now we should not do the primitive checking for scalar functions, this should be part of

[jira] [Commented] (FLINK-5971) JobLeaderIdService should time out registered jobs

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901398#comment-15901398 ] ASF GitHub Bot commented on FLINK-5971: --- Github user KurtYoung commented on a diff in the pull

[GitHub] flink pull request #3488: [FLINK-5971] [flip-6] Add timeout for registered j...

2017-03-08 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3488#discussion_r104937304 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java --- @@ -0,0 +1,37 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-6000) Can not start HA cluster with start-cluster.sh

2017-03-08 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6000: --- Summary: Can not start HA cluster with start-cluster.sh Key: FLINK-6000 URL: https://issues.apache.org/jira/browse/FLINK-6000 Project: Flink Issue

[jira] [Updated] (FLINK-5177) Improve nullability handling

2017-03-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-5177: Description: Currently, all fields of the Table API are marked as nullable by default. A lot of

[jira] [Commented] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-08 Thread Stefano Bortoli (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901391#comment-15901391 ] Stefano Bortoli commented on FLINK-5653: What is the plan for this issue? > Add processing time

[jira] [Updated] (FLINK-5984) Add resetAccumulator method for AggregateFunction

2017-03-08 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5984: - Summary: Add resetAccumulator method for AggregateFunction (was: Allow reusing of accumulators

[GitHub] flink issue #3468: [FLINK-5824] Fix String/byte conversions without explicit...

2017-03-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3468 Good change, thanks! Merging this... --- 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

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901388#comment-15901388 ] ASF GitHub Bot commented on FLINK-5824: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5781) Generation HTML from ConfigOption

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901378#comment-15901378 ] ASF GitHub Bot commented on FLINK-5781: --- GitHub user dawidwys opened a pull request:

[GitHub] flink pull request #3495: [FLINK-5781] Generation HTML from ConfigOption

2017-03-08 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3495 [FLINK-5781] Generation HTML from ConfigOption Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your

<    1   2   3   4   >