[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

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

[jira] [Commented] (FLINK-4754) Make number of retained checkpoints user configurable

2017-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901360#comment-15901360 ] ASF GitHub Bot commented on FLINK-4754: --- 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:

[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-5985) Flink treats every task as stateful (making topology changes impossible)

2017-03-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901356#comment-15901356 ] Ufuk Celebi commented on FLINK-5985: Is it possible to share the driver program (privately works as

[GitHub] flink issue #3374: [FLINK-4754] [checkpoints] Make number of retained checkp...

2017-03-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3374 Looks good in general. I would suggest two improvements: 1. Migrate the config parameter to `CoreOptions` 2. Add a test --- If your project is set up for it, you can reply to

[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-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:

[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-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:

[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

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

2017-03-08 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3364#discussion_r104926612 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSlideTimeWindowAggReduceCombineFunction.scala --- @@

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

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

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

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

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

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

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

2017-03-08 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3364#discussion_r104927085 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetTumbleTimeWindowAggReduceGroupFunction.scala --- @@

[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=15901344#comment-15901344 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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-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-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

[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-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 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-5431) time format for akka status

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

[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

[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=15901423#comment-15901423 ] ASF GitHub Bot commented on FLINK-5984: --- Github user shaoxuan-wang commented on the issue:

[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

[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] [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 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

[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 pull request #3364: [FLINK-5047] [table] Add sliding group-windows for...

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

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

2017-03-08 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3364#discussion_r104919295 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetWindowAggregate.scala --- @@ -312,6 +320,108 @@ class

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

2017-03-08 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3364#discussion_r104925837 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -186,6 +200,130 @@ object

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

2017-03-08 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3364#discussion_r104925916 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -186,6 +200,130 @@ object

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

2017-03-08 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3364#discussion_r104925507 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -186,6 +200,130 @@ object

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

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

[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=15901338#comment-15901338 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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=15901337#comment-15901337 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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=15901345#comment-15901345 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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=15901340#comment-15901340 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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=15901341#comment-15901341 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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=15901346#comment-15901346 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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=15901343#comment-15901343 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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=15901339#comment-15901339 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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=15901342#comment-15901342 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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=15901347#comment-15901347 ] ASF GitHub Bot commented on FLINK-5047: --- Github user fhueske commented on a diff in the pull

[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 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-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:

[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=15902279#comment-15902279 ] ASF GitHub Bot commented on FLINK-5971: --- Github user KurtYoung commented on a diff in the pull

[GitHub] flink issue #3334: FLINK-4810 Checkpoint Coordinator should fail ExecutionGr...

2017-03-08 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/3334 @StephanEwen I saw in another JIRA one of your comment where you talked about refactoring CheckPointcoordinator and Pendingcheckpoint. So you woud this PR to wait till then? --- If your

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-08 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902261#comment-15902261 ] Yuhong Hong commented on FLINK-5658: Hi [~sunjincheng121], i agree with you, i have already rewrite

[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=15902280#comment-15902280 ] 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_r105068133 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java --- @@ -28,6 +28,10 @@ @PublicEvolving public class

[jira] [Commented] (FLINK-5976) Refactoring duplicate Tokenizer in flink-test

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

[GitHub] flink issue #3485: FLINK-5976 [tests] Deduplicate Tokenizer in tests

2017-03-08 Thread liuyuzhong7
Github user liuyuzhong7 commented on the issue: https://github.com/apache/flink/pull/3485 @StephanEwen It's a good idea. We can remove many duplicate code in flink-tests in this way. But I found it also duplicate in other modules. How to solve it in other modules.

[jira] [Commented] (FLINK-6002) Documentation: 'MacOS X' under 'Download and Start Flink' 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=15902328#comment-15902328 ] ASF GitHub Bot commented on FLINK-6002: --- Github user clarkyzl commented on the issue:

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902390#comment-15902390 ] sunjincheng commented on FLINK-5658: Hi, [~Yuhong_kyo], sounds good to me. The [partitioned] PR[#3397

[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=15902563#comment-15902563 ] ASF GitHub Bot commented on FLINK-3679: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3487: [FLINK-5980] Expose max-parallelism value in RuntimeConte...

2017-03-08 Thread ifndef-SleePy
Github user ifndef-SleePy commented on the issue: https://github.com/apache/flink/pull/3487 Thank you, Stephan and zentol. Good question and suggestion. I didn't consider it too much for batch jobs. Also I think it's a bad idea that naming the variable "numberOfKeyGroups" in

[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_r105068068 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java --- @@ -0,0 +1,37 @@ +/* + * Licensed to the Apache

[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=15902546#comment-15902546 ] ASF GitHub Bot commented on FLINK-3679: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

2017-03-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6004: --- Description: It is quite clear from the fix of FLINK-3679 that in reality, users

[jira] [Created] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

2017-03-08 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6004: -- Summary: Allow FlinkKinesisConsumer to skip corrupted messages Key: FLINK-6004 URL: https://issues.apache.org/jira/browse/FLINK-6004 Project: Flink

[jira] [Updated] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

2017-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6004: Component/s: Streaming Connectors > Allow FlinkKinesisConsumer to skip corrupted messages >

[jira] [Commented] (FLINK-5832) Support for simple hive UDF

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

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

2017-03-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-3679. Resolution: Fixed Fix Version/s: 1.3.0 Resolved for {{master}} with

[jira] [Commented] (FLINK-5980) Expose max-parallelism value in RuntimeContext

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

[GitHub] flink pull request #3456: [FLINK-5832] [table] Support for simple hive UDF

2017-03-08 Thread clarkyzl
Github user clarkyzl commented on a diff in the pull request: https://github.com/apache/flink/pull/3456#discussion_r105095839 --- Diff: flink-libraries/flink-table/pom.xml --- @@ -92,6 +92,11 @@ under the License. +

[jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2017-03-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822346#comment-15822346 ] Ted Yu edited comment on FLINK-5486 at 3/9/17 1:28 AM: --- Lock on State.bucketStates

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

2017-03-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902554#comment-15902554 ] Tzu-Li (Gordon) Tai commented on FLINK-3679: I'm a bit hesitant whether or not we want to

[jira] [Resolved] (FLINK-5583) Support flexible error handling in the Kafka consumer

2017-03-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-5583. Resolution: Fixed Fix Version/s: 1.3.0 Resolved for {{master}} with

[GitHub] flink pull request #3314: [FLINK-3679] DeserializationSchema should handle z...

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

[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 @haohui - one suggestion for future contributions for easier reviews: We usually use follow-up commits that addresses review comments, instead of force pushing the whole branch. For reviewers,

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

2017-03-08 Thread clarkyzl
Github user clarkyzl commented on the issue: https://github.com/apache/flink/pull/3497 +1 LGTM. Thanks @phoenixjiangnan --- 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

[jira] [Assigned] (FLINK-5053) Incremental / lightweight snapshots for checkpoints

2017-03-08 Thread Xiaogang Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi reassigned FLINK-5053: --- Assignee: Xiaogang Shi > Incremental / lightweight snapshots for checkpoints >

[jira] [Assigned] (FLINK-5998) Un-fat Hadoop from Flink fat jar

2017-03-08 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-5998: - Assignee: Haohui Mai > Un-fat Hadoop from Flink fat jar > > >

[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=15902429#comment-15902429 ] ASF GitHub Bot commented on FLINK-4545: --- Github user wenlong88 commented on a diff in the pull

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

2017-03-08 Thread wenlong88
Github user wenlong88 commented on a diff in the pull request: https://github.com/apache/flink/pull/3467#discussion_r105081191 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java --- @@ -265,11 +281,15 @@ public String toString()

[jira] [Commented] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

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

[jira] [Updated] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation

2017-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5995: Component/s: (was: Core) State Backends, Checkpointing

[jira] [Commented] (FLINK-5991) Expose Broadcast Operator State through public APIs

2017-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902577#comment-15902577 ] Aljoscha Krettek commented on FLINK-5991: - I prefer to only expose it on the operator state store

[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

[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:

[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-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 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-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 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=15901718#comment-15901718 ] ASF GitHub Bot commented on FLINK-5635: --- Github user patricklucas commented on a diff in the pull

[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:

[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] [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] [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 +#

[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:

  1   2   3   4   >