[GitHub] flink issue #2938: [FLINK-4692] [tableApi] Add tumbling group-windows for ba...

2017-01-06 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2938 Sure, I will look at it today @twalthr . --- 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 ena

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15806762#comment-15806762 ] ASF GitHub Bot commented on FLINK-4692: --- Github user wuchong commented on the issue:

[jira] [Updated] (FLINK-5425) JobManager replaced by IP in metrics

2017-01-06 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey updated FLINK-5425: - Description: In metrics at the jobmanager level and below, the "" scope variable is being replace

[jira] [Created] (FLINK-5425) JobManager replaced by IP in metrics

2017-01-06 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5425: Summary: JobManager replaced by IP in metrics Key: FLINK-5425 URL: https://issues.apache.org/jira/browse/FLINK-5425 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-5322) Clean up yarn configuration documentation

2017-01-06 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15806496#comment-15806496 ] Shannon Carey edited comment on FLINK-5322 at 1/7/17 2:11 AM: --

[jira] [Commented] (FLINK-5322) Clean up yarn configuration documentation

2017-01-06 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15806496#comment-15806496 ] Shannon Carey commented on FLINK-5322: -- Another important note: quoting strings doesn

[GitHub] flink issue #3057: [FLINK-5364] Rework JAAS configuration to support user-su...

2017-01-06 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3057 Thanks for the review, I'll address these comments ASAP. --- 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 ha

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805812#comment-15805812 ] ASF GitHub Bot commented on FLINK-5364: --- Github user EronWright commented on the iss

[jira] [Commented] (FLINK-5424) Improve Restart Strategy Logging

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805642#comment-15805642 ] ASF GitHub Bot commented on FLINK-5424: --- GitHub user rehevkor5 opened a pull request

[GitHub] flink pull request #3079: [FLINK-5424] Improve Restart Strategy Logging

2017-01-06 Thread rehevkor5
GitHub user rehevkor5 opened a pull request: https://github.com/apache/flink/pull/3079 [FLINK-5424] Improve Restart Strategy Logging - Added toString for FailureRateRestartStrategy (important for JobManager's "Using restart strategy $restartStrategy" log message) - Added expl

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805618#comment-15805618 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3057: [FLINK-5364] Rework JAAS configuration to support user-su...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3057 @EronWright Thanks for explaining. It figured it out concurrently by looking at the updated documentation you wrote ;-) The docs are good, helped a lot! --- If your project is set up for it, yo

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805606#comment-15805606 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805603#comment-15805603 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805605#comment-15805605 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805609#comment-15805609 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805602#comment-15805602 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805600#comment-15805600 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805608#comment-15805608 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805607#comment-15805607 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805601#comment-15805601 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805604#comment-15805604 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95008182 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java --- @@ -71,163 +64,93 @@ */ public static voi

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r94997947 --- Diff: docs/internals/flink_security.md --- @@ -24,64 +24,109 @@ specific language governing permissions and limitations under the License. --

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95009675 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java --- @@ -0,0 +1,120 @@ +/* + * Licensed to the A

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95009232 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java --- @@ -71,163 +64,93 @@ */ public static voi

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95003470 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/DynamicConfiguration.java --- @@ -0,0 +1,112 @@ +/* + * Licensed to the A

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95010038 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/JaasModule.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the Apa

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r94997957 --- Diff: docs/internals/flink_security.md --- @@ -24,64 +24,109 @@ specific language governing permissions and limitations under the License. --

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95007256 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java --- @@ -71,163 +64,93 @@ */ public static voi

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95007014 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java --- @@ -71,163 +64,93 @@ */ public static voi

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95007601 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java --- @@ -71,163 +64,93 @@ */ public static voi

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r94994079 --- Diff: docs/internals/flink_security.md --- @@ -24,64 +24,109 @@ specific language governing permissions and limitations under the License. --

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805599#comment-15805599 ] ASF GitHub Bot commented on FLINK-5364: --- Github user EronWright commented on the iss

[GitHub] flink issue #3057: [FLINK-5364] Rework JAAS configuration to support user-su...

2017-01-06 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3057 @StephanEwen yes, this PR does the following: 1. isolate the configuration of kerberos credentials from how those credentials are used 2. modularize the security code to reflect the indepen

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805491#comment-15805491 ] ASF GitHub Bot commented on FLINK-5303: --- Github user chermenin commented on the issu

[GitHub] flink issue #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS clause...

2017-01-06 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2976 Big thanks for the review @twalthr! I fixed the code for most of the comments. I will fix the tests at this weekend. --- If your project is set up for it, you can reply to this email and have your

[jira] [Created] (FLINK-5424) Improve Restart Strategy Logging

2017-01-06 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5424: Summary: Improve Restart Strategy Logging Key: FLINK-5424 URL: https://issues.apache.org/jira/browse/FLINK-5424 Project: Flink Issue Type: Improvement

[GitHub] flink issue #3059: [docs] Clarify restart strategy defaults set by checkpoin...

2017-01-06 Thread rehevkor5
Github user rehevkor5 commented on the issue: https://github.com/apache/flink/pull/3059 The changes so far are docs-only, so the CI failure must be unrelated. --- 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 projec

[jira] [Commented] (FLINK-5355) Handle AmazonKinesisException gracefully in Kinesis Streaming Connector

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805207#comment-15805207 ] ASF GitHub Bot commented on FLINK-5355: --- GitHub user skidder opened a pull request:

[GitHub] flink pull request #3078: [FLINK-5355] Handle AmazonKinesisException gracefu...

2017-01-06 Thread skidder
GitHub user skidder opened a pull request: https://github.com/apache/flink/pull/3078 [FLINK-5355] Handle AmazonKinesisException gracefully in Kinesis Streaming Connector My Flink job that consumes from a Kinesis stream must be restarted at least once daily due to an uncaught Amazon

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805194#comment-15805194 ] ASF GitHub Bot commented on FLINK-5364: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3057: [FLINK-5364] Rework JAAS configuration to support user-su...

2017-01-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3057 @EronWright thanks a lot for this fix, I am looking though it now. From the description in the JIRAs, I take that this adds the logic that reads custom JAAS security configurations and us

[jira] [Updated] (FLINK-5178) allow BlobCache to use a distributed file system irrespective of the HA mode

2017-01-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5178: --- Summary: allow BlobCache to use a distributed file system irrespective of the HA mode (was: allow Blo

[jira] [Updated] (FLINK-5178) allow BlobCache touse a distributed file system irrespective of the HA mode

2017-01-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5178: --- Description: After FLINK-5129, high availability (HA) mode adds the ability for the BlobCache instance

[jira] [Closed] (FLINK-3746) WebRuntimeMonitorITCase.testNoCopyFromJar failing intermittently

2017-01-06 Thread Boris Osipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Osipov closed FLINK-3746. --- Resolution: Fixed Was fixed with FLINK-4255 > WebRuntimeMonitorITCase.testNoCopyFromJar failing inter

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15805007#comment-15805007 ] ASF GitHub Bot commented on FLINK-5423: --- GitHub user Fokko opened a pull request:

[GitHub] flink pull request #3077: [FLINK-5423] Implement Stochastic Outlier Selectio...

2017-01-06 Thread Fokko
GitHub user Fokko opened a pull request: https://github.com/apache/flink/pull/3077 [FLINK-5423] Implement Stochastic Outlier Selection Implemented the Stochastic Outlier Selection algorithm in the Machine Learning library, including the test code. Added documentation. Thank

[jira] [Created] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-06 Thread Fokko Driesprong (JIRA)
Fokko Driesprong created FLINK-5423: --- Summary: Implement Stochastic Outlier Selection Key: FLINK-5423 URL: https://issues.apache.org/jira/browse/FLINK-5423 Project: Flink Issue Type: Improv

[GitHub] flink pull request #3076: [FLINK-5129] make the BlobServer use a distributed...

2017-01-06 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3076 [FLINK-5129] make the BlobServer use a distributed file system Make the BlobCache use the BlobServer's distributed file system in HA mode: previously even in HA mode and if the cache has access to the

[jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804969#comment-15804969 ] ASF GitHub Bot commented on FLINK-5129: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-06 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2976#discussion_r94960996 --- Diff: docs/dev/table_api.md --- @@ -3744,6 +3745,50 @@ MIN(value) + Grouping functions + Description +

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-06 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2976#discussion_r94960370 --- Diff: docs/dev/table_api.md --- @@ -1442,7 +1443,7 @@ Although not every SQL feature is implemented yet, some string combinations are {% highli

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-06 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2976#discussion_r94961010 --- Diff: docs/dev/table_api.md --- @@ -3744,6 +3745,50 @@ MIN(value) + Grouping functions + Description +

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-06 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2976#discussion_r94964350 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateReduceGroupFunction.scala --- @@ -87,6 +90,17 @@ class

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-06 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2976#discussion_r94965456 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -349,6 +354,19 @@ object AggregateUt

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-06 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2976#discussion_r94966326 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/batch/sql/GroupingSetsTest.java --- @@ -0,0 +1,188 @@ +/* + * Lic

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-06 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2976#discussion_r94963463 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateReduceGroupFunction.scala --- @@ -20,26 +20,29 @@ pack

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804952#comment-15804952 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804953#comment-15804953 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804948#comment-15804948 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-06 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2976#discussion_r94962145 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetAggregateRule.scala --- @@ -50,30 +48,48 @@ class DataS

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804954#comment-15804954 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804947#comment-15804947 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-06 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2976#discussion_r94969330 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/batch/sql/GroupingSetsTest.java --- @@ -0,0 +1,188 @@ +/* + * Lic

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804951#comment-15804951 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804955#comment-15804955 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804949#comment-15804949 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804950#comment-15804950 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-5247) Fix incorrect check in allowedLateness() method. Make it a no-op for non-event time windows.

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804939#comment-15804939 ] ASF GitHub Bot commented on FLINK-5247: --- Github user kl0u commented on the issue:

[GitHub] flink issue #2929: [FLINK-5247] Fix incorrect check in allowedLateness() met...

2017-01-06 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2929 Hi @mindprince . What do you mean "in the file"? The allowed lateness can always be specified in the program by the developer, right? So logging a message is always a valid approach. --- If your proje

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804925#comment-15804925 ] ASF GitHub Bot commented on FLINK-5296: --- GitHub user kl0u opened a pull request:

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

2017-01-06 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/3075 [FLINK-5296] Expose the old AlignedWindowOperators through special as… This PR allows the user to use the deprecated `AccumulatingProcessingTimeWindowOperator` and `AggregatingProcessingTimeWindowOp

[jira] [Updated] (FLINK-5329) Metric list is being cut off in the WebFrontend

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5329: Priority: Blocker (was: Major) > Metric list is being cut off in the WebFrontend >

[jira] [Commented] (FLINK-5422) Check for name collisions in the Rolling/BucketingSink

2017-01-06 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804903#comment-15804903 ] Kostas Kloudas commented on FLINK-5422: --- Currently in the Rolling/Bucketing Sink use

[jira] [Created] (FLINK-5422) Check for name collisions in the Rolling/BucketingSink

2017-01-06 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5422: - Summary: Check for name collisions in the Rolling/BucketingSink Key: FLINK-5422 URL: https://issues.apache.org/jira/browse/FLINK-5422 Project: Flink Issue

[GitHub] flink issue #3039: [FLINK-5280] Update TableSource to support nested data

2017-01-06 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/3039 @fhueske @wuchong Makes sense to me as well. I'll try to update the PR during the weekend. --- If your project is set up for it, you can reply to this email and have your reply appear on G

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804881#comment-15804881 ] ASF GitHub Bot commented on FLINK-5280: --- Github user mushketyk commented on the issu

[jira] [Updated] (FLINK-5419) Taskmanager metrics not accessible via REST

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5419: Priority: Major (was: Blocker) > Taskmanager metrics not accessible via REST >

[jira] [Closed] (FLINK-5359) Job Exceptions view doesn't scroll

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5359. --- Resolution: Fixed 1.2: 7251a4ca9539200ba4c894c116800fdc7cecca9f 1.3: 6d963642acb18905103427df4

[jira] [Closed] (FLINK-5381) Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config)

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5381. --- Resolution: Fixed 1.2: 7251a4ca9539200ba4c894c116800fdc7cecca9f 1.3: 6d963642acb18905103427df4

[jira] [Closed] (FLINK-5267) TaskManager logs not scrollable

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5267. --- Resolution: Fixed 1.2: 7251a4ca9539200ba4c894c116800fdc7cecca9f 1.3: 6d963642acb18905103427df4

[jira] [Updated] (FLINK-4148) incorrect calculation distance in QuadTree

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4148: Component/s: Machine Learning Library > incorrect calculation distance in QuadTree > ---

[jira] [Closed] (FLINK-4148) incorrect calculation distance in QuadTree

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4148. --- Resolution: Fixed > incorrect calculation distance in QuadTree > -

[jira] [Closed] (FLINK-5119) Last taskmanager heartbeat not showing in web frontend

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5119. --- Resolution: Fixed 1.2: b93f80afc7c50c7fefc850b620bb571523343595 1.3: 71544e9629be608121a34b245

[jira] [Closed] (FLINK-4148) incorrect calculation distance in QuadTree

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4148. --- Resolution: Fixed 1.2: 9d99f2bd4a29b748905e55a774ff04f933b6b00f 1.3: 6e920fcd6601b82e821f59fb0

[jira] [Closed] (FLINK-5412) Enable RocksDB tests on Windows

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5412. --- Resolution: Fixed Fix Version/s: 1.2.0 1.2: aaf9612791284633727a0951d0d45292ef5e233c 1.

[jira] [Reopened] (FLINK-4148) incorrect calculation distance in QuadTree

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-4148: - > incorrect calculation distance in QuadTree > -- > >

[jira] [Updated] (FLINK-4148) incorrect calculation distance in QuadTree

2017-01-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4148: Fix Version/s: 1.3.0 1.2.0 > incorrect calculation distance in QuadTree >

[jira] [Commented] (FLINK-5119) Last taskmanager heartbeat not showing in web frontend

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804815#comment-15804815 ] ASF GitHub Bot commented on FLINK-5119: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5381) Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config)

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804817#comment-15804817 ] ASF GitHub Bot commented on FLINK-5381: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5412) Enable RocksDB tests on Windows

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804816#comment-15804816 ] ASF GitHub Bot commented on FLINK-5412: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2442: [FLINK-4148] incorrect calculation minDist distanc...

2017-01-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2442 --- 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 enab

[GitHub] flink pull request #3070: [FLINK-5119][web-frontend] Fix problems in display...

2017-01-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3070 --- 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 enab

[jira] [Commented] (FLINK-4148) incorrect calculation distance in QuadTree

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804818#comment-15804818 ] ASF GitHub Bot commented on FLINK-4148: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5160) SecurityContextTest#testCreateInsecureHadoopCtx fails on windows

2017-01-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804814#comment-15804814 ] ASF GitHub Bot commented on FLINK-5160: --- Github user asfgit closed the pull request

[GitHub] flink pull request #3069: [FLINK-5381][web-frontend] Fix scrolling issues

2017-01-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3069 --- 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 enab

[GitHub] flink pull request #3066: [FLINK-5160] [refactor] SecurityUtils use Operatin...

2017-01-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3066 --- 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 enab

[GitHub] flink pull request #3067: [FLINK-5412] Enable RocksDB tests on Windows OS

2017-01-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3067 --- 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 enab

[GitHub] flink issue #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS clause...

2017-01-06 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2976 I would like to shepherd 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 your project does not have this feature enabled an

  1   2   3   >