[GitHub] flink pull request #5241: [FLINK-8325][table] Add COUNT(*),COUNT(1) supporte...

2018-01-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5241 ---

[jira] [Commented] (FLINK-8325) Add COUNT AGG support constant parameter, i.e. COUNT(*), COUNT(1)

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

[jira] [Closed] (FLINK-8325) Add COUNT AGG support constant parameter, i.e. COUNT(*), COUNT(1)

2018-01-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8325. Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 Fixed for 1.4.1 with aa5e4918

[GitHub] flink issue #5322: [hotfix] [REST] Fix WebMonitorEndpoint that missing param...

2018-01-21 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5322 Thanks for this fix @ifndef-SleePy. Merging it. ---

[GitHub] flink pull request #5322: [hotfix] [REST] Fix WebMonitorEndpoint that missin...

2018-01-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5322 ---

[GitHub] flink pull request #5307: [FLINK-8431] [mesos] Allow to specify # GPUs for T...

2018-01-21 Thread eastcirclek
Github user eastcirclek commented on a diff in the pull request: https://github.com/apache/flink/pull/5307#discussion_r162807064 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/scheduler/Offer.java --- @@ -81,11 +82,14 @@ public Offer(Protos.Offer offer) {

[jira] [Commented] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

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

[GitHub] flink pull request #5307: [FLINK-8431] [mesos] Allow to specify # GPUs for T...

2018-01-21 Thread eastcirclek
Github user eastcirclek commented on a diff in the pull request: https://github.com/apache/flink/pull/5307#discussion_r162809581 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/scheduler/Offer.java --- @@ -156,6 +164,16 @@ public long getOfferedTime() { r

[GitHub] flink pull request #5307: [FLINK-8431] [mesos] Allow to specify # GPUs for T...

2018-01-21 Thread eastcirclek
Github user eastcirclek commented on a diff in the pull request: https://github.com/apache/flink/pull/5307#discussion_r162809586 --- Diff: flink-mesos/pom.xml --- @@ -88,7 +88,7 @@ under the License. com.netflix.fenzo

[jira] [Commented] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

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

[jira] [Commented] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

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

[GitHub] flink pull request #5312: [FLINK-8344][WIP] Add support for HA to RestCluste...

2018-01-21 Thread satybald
Github user satybald commented on a diff in the pull request: https://github.com/apache/flink/pull/5312#discussion_r162814676 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/LeaderHolder.java --- @@ -0,0 +1,74 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-8344) Add support for HA to RestClusterClient

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

[GitHub] flink pull request #5328: [hotfix][codestyle] Refactor equals for StreamReco...

2018-01-21 Thread satybald
GitHub user satybald opened a pull request: https://github.com/apache/flink/pull/5328 [hotfix][codestyle] Refactor equals for StreamRecord ## What is the purpose of the change Removing nested `IF`s for `StreamRecord#equals` method without changing the comparison logic.

[GitHub] flink pull request #4623: [FLINK-7551] [REST] Add versioning

2018-01-21 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/4623 ---

[jira] [Commented] (FLINK-7551) Add VERSION to the REST urls.

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

[jira] [Commented] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4

2018-01-21 Thread jia liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333788#comment-16333788 ] jia liu commented on FLINK-8248: [~dawidwys] [~kkl0u], I'm sorry to reply you so late. I'v

[jira] [Closed] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4

2018-01-21 Thread jia liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jia liu closed FLINK-8248. -- Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 > RocksDB state backend Checkpointing is

[GitHub] flink issue #5319: [FLINK-8463] [rest] Remove blocking of IO executor in Res...

2018-01-21 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5319 💯 ---

[jira] [Commented] (FLINK-8463) Remove unnecessary thread blocking in RestClient#submitRequest

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

[jira] [Commented] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE

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

[GitHub] flink pull request #5329: [FLINK-8409] [kafka] Fix potential NPE in KafkaCon...

2018-01-21 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5329 [FLINK-8409] [kafka] Fix potential NPE in KafkaConsumerThread ## What is the purpose of the change This PR fixes a race condition that may lead to a NPE in the async callbacks for Kafka of

[jira] [Created] (FLINK-8470) DelayTrigger and DelayAndCountTrigger in Flink Streaming Window API

2018-01-21 Thread Vijay Kansal (JIRA)
Vijay Kansal created FLINK-8470: --- Summary: DelayTrigger and DelayAndCountTrigger in Flink Streaming Window API Key: FLINK-8470 URL: https://issues.apache.org/jira/browse/FLINK-8470 Project: Flink