[jira] [Commented] (FLINK-6434) There may be allocatedSlots leak in SlotPool

2017-07-03 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16073081#comment-16073081 ] shuai.xu commented on FLINK-6434: - [~till.rohrmann] Sorry, I have not start working on it > There may be

[GitHub] flink pull request #3539: Flip1: fine gained recovery

2017-07-03 Thread shuai-xu
Github user shuai-xu closed the pull request at: https://github.com/apache/flink/pull/3539 --- 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-6927) Support pattern group in CEP

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

[GitHub] flink issue #4153: [FLINK-6927] [cep] Support pattern group in CEP

2017-07-03 Thread dianfu
Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4153 @dawidwys Thanks a lot for the review. Updated the doc. --- 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

[jira] [Commented] (FLINK-6617) Improve JAVA and SCALA logical plans consistent test

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

[GitHub] flink issue #3943: [FLINK-6617][table] Improve JAVA and SCALA logical plans ...

2017-07-03 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3943 Thanks @twalthr ! I have rebased the code and updated the PR. Thanks, SunJincheng --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

2017-07-03 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16073006#comment-16073006 ] mingleizhang commented on FLINK-6995: - Icy! Let me try it. > Add a warning to outdated documentation

[jira] [Created] (FLINK-7083) Adapt WebRuntimeMonitor to work with Flip-6 architecture

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7083: Summary: Adapt WebRuntimeMonitor to work with Flip-6 architecture Key: FLINK-7083 URL: https://issues.apache.org/jira/browse/FLINK-7083 Project: Flink Issue

[jira] [Created] (FLINK-7082) Flip-6: Generic entry point for Flink sessions

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7082: Summary: Flip-6: Generic entry point for Flink sessions Key: FLINK-7082 URL: https://issues.apache.org/jira/browse/FLINK-7082 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7081) Deploy Mesos framework with job

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7081: Summary: Deploy Mesos framework with job Key: FLINK-7081 URL: https://issues.apache.org/jira/browse/FLINK-7081 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7080) Deploy Yarn cluster with job

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7080: Summary: Deploy Yarn cluster with job Key: FLINK-7080 URL: https://issues.apache.org/jira/browse/FLINK-7080 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-7079) Refactor ClusterDescriptor to support cluster deployment with job

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7079: - Labels: flip-6 (was: ) > Refactor ClusterDescriptor to support cluster deployment with job >

[jira] [Created] (FLINK-7079) Refactor ClusterDescriptor to support cluster deployment with job

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7079: Summary: Refactor ClusterDescriptor to support cluster deployment with job Key: FLINK-7079 URL: https://issues.apache.org/jira/browse/FLINK-7079 Project: Flink

[jira] [Created] (FLINK-7078) Support fencing tokens to filter out outdated messages

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7078: Summary: Support fencing tokens to filter out outdated messages Key: FLINK-7078 URL: https://issues.apache.org/jira/browse/FLINK-7078 Project: Flink Issue

[jira] [Updated] (FLINK-4346) Implement basic RPC abstraction

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4346: - Labels: flip-6 (was: ) > Implement basic RPC abstraction > --- > >

[jira] [Created] (FLINK-7077) Implement task release to support dynamic scaling

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7077: Summary: Implement task release to support dynamic scaling Key: FLINK-7077 URL: https://issues.apache.org/jira/browse/FLINK-7077 Project: Flink Issue Type:

[jira] [Updated] (FLINK-7076) Implement container release to support dynamic scaling

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7076: - Description: In order to support dynamic scaling, the {{YarnResourceManager}} has to be able to

[jira] [Updated] (FLINK-7076) Implement container release to support dynamic scaling

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7076: - Summary: Implement container release to support dynamic scaling (was: Add support for dynamic

[jira] [Created] (FLINK-7076) Add support for dynamic container allocation to ResourceManager

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7076: Summary: Add support for dynamic container allocation to ResourceManager Key: FLINK-7076 URL: https://issues.apache.org/jira/browse/FLINK-7076 Project: Flink

[jira] [Created] (FLINK-7075) Implement Flip-6 standalone mode

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7075: Summary: Implement Flip-6 standalone mode Key: FLINK-7075 URL: https://issues.apache.org/jira/browse/FLINK-7075 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-7074) Add entry point for TaskManagerRunner

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7074: Summary: Add entry point for TaskManagerRunner Key: FLINK-7074 URL: https://issues.apache.org/jira/browse/FLINK-7074 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6631) Implement FLIP-6 MesosTaskExecutorRunner

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072933#comment-16072933 ] Till Rohrmann commented on FLINK-6631: -- Most likely, we can use the {{TaskManagerRunner}} as an entry

[jira] [Updated] (FLINK-4897) Implement Dispatcher to support Flink sessions

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4897: - Description: This task is to implement the dispatcher component which reacts to calls from the

[jira] [Updated] (FLINK-4352) Refactor CLI to use RESTful client for cluster communication

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4352: - Description: We have to refactor the Flink's CLI in order to be able to use the RESTful client

[jira] [Updated] (FLINK-4352) Refactor CLI to use RESTful client for cluster communication

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4352: - Summary: Refactor CLI to use RESTful client for cluster communication (was: Refactor CLI to use

[jira] [Updated] (FLINK-4352) Refactor CLI to use RESTful client

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4352: - Component/s: Client > Refactor CLI to use RESTful client > -- > >

[jira] [Updated] (FLINK-4352) Refactor CLI to use RESTful client

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4352: - Summary: Refactor CLI to use RESTful client (was: Refactor Client to work together with Flip-6

[jira] [Updated] (FLINK-7040) Flip-6 client-cluster communication

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7040: - Description: With the new Flip-6 architecture, the client will communicate with the cluster in a

[jira] [Created] (FLINK-7073) Create RESTful JobManager endpoint

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7073: Summary: Create RESTful JobManager endpoint Key: FLINK-7073 URL: https://issues.apache.org/jira/browse/FLINK-7073 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7072) Create RESTful cluster endpoint

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7072: Summary: Create RESTful cluster endpoint Key: FLINK-7072 URL: https://issues.apache.org/jira/browse/FLINK-7072 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-7040) Flip-6 client-cluster communication

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7040: - Description: With the new Flip-6 architecture, the client will communicate with the cluster in a

[jira] [Updated] (FLINK-7071) Create RESTful client

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7071: - Labels: flip-6 (was: ) > Create RESTful client > - > > Key:

[jira] [Created] (FLINK-7071) Create RESTful client

2017-07-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7071: Summary: Create RESTful client Key: FLINK-7071 URL: https://issues.apache.org/jira/browse/FLINK-7071 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-7040) Flip-6 client-cluster communication

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7040: - Description: With the new Flip-6 architecture, the client will communicate with the cluster in a

[jira] [Updated] (FLINK-7040) Flip-6 client-cluster communication

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7040: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-4897) > Flip-6

[jira] [Updated] (FLINK-7040) Flip-6 client-cluster communication

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7040: - Labels: flip-6 (was: ) > Flip-6 client-cluster communication >

[jira] [Commented] (FLINK-7037) Remove scala suffix from flink-examples module

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

[GitHub] flink issue #4221: [FLINK-7037] Remove scala suffic from flink-examples modu...

2017-07-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4221 @greghogan fixed --- 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

[jira] [Commented] (FLINK-7037) Remove scala suffix from flink-examples module

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

[GitHub] flink pull request #4221: [FLINK-7037] Remove scala suffic from flink-exampl...

2017-07-03 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/4221#discussion_r125350366 --- Diff: flink-examples/flink-examples-table/pom.xml --- @@ -24,7 +24,7 @@ under the License. org.apache.flink -

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

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

[GitHub] flink issue #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka...

2017-07-03 Thread vidhu5269
Github user vidhu5269 commented on the issue: https://github.com/apache/flink/pull/4015 I also see that a few of the continuous-integration builds have failed. Is there something I should do in that regard? --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

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

[GitHub] flink issue #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka...

2017-07-03 Thread vidhu5269
Github user vidhu5269 commented on the issue: https://github.com/apache/flink/pull/4015 Hi @tzulitai Apologies for such a long delay. It took me quite a while to come back to this. I ran the updated connector on the cluster and didn't see any dependency conflicts.

[jira] [Commented] (FLINK-7047) Reorganize build profiles

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

[GitHub] flink issue #4233: [FLINK-7047] [travis] Reorganize build profiles

2017-07-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4233 I've moved a few more modules into the misc. group: * flink-metrics * flink-java8 * flink-streaming-contrib * flink-scala-shell For the core group we now only compile modules

[jira] [Commented] (FLINK-7015) Separate OperatorConfig from StreamConfig

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

[GitHub] flink issue #4241: [FLINK-7015] [streaming] separate OperatorConfig from Str...

2017-07-03 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4241 In general, it is a good idea to clean that up a bit. That code needed some refactoring. As @aljoscha pointed out, that is an intricate part, so we need to review that carefully. To be

[jira] [Commented] (FLINK-4286) Have Kafka examples that use the Kafka 0.9 connector

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

[GitHub] flink issue #3270: [FLINK-4286] Have Kafka examples that use the Kafka 0.9 c...

2017-07-03 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3270 Thank you! --- 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

[GitHub] flink pull request #3270: [FLINK-4286] Have Kafka examples that use the Kafk...

2017-07-03 Thread mylog00
Github user mylog00 closed the pull request at: https://github.com/apache/flink/pull/3270 --- 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-4286) Have Kafka examples that use the Kafka 0.9 connector

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

[GitHub] flink issue #3270: [FLINK-4286] Have Kafka examples that use the Kafka 0.9 c...

2017-07-03 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/3270 Many merge conflicts. --- 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

[jira] [Commented] (FLINK-4286) Have Kafka examples that use the Kafka 0.9 connector

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

[jira] [Commented] (FLINK-4286) Have Kafka examples that use the Kafka 0.9 connector

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

[GitHub] flink pull request #3270: [FLINK-4286] Have Kafka examples that use the Kafk...

2017-07-03 Thread mylog00
Github user mylog00 commented on a diff in the pull request: https://github.com/apache/flink/pull/3270#discussion_r125331370 --- Diff: flink-examples/flink-examples-streaming/pom.xml --- @@ -360,6 +360,26 @@ under the License.

[jira] [Commented] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

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

[GitHub] flink issue #4213: [FLINK-7032] Overwrite inherited properties from parent p...

2017-07-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4213 @aljoscha you merge since you asked first. --- 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

[jira] [Commented] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

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

[GitHub] flink issue #3783: [FLINK-6388] Add support for DISTINCT into Code Generated...

2017-07-03 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3783 Not yet, but AFAIK is @twalthr working on that. --- 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-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-03 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125281365 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala --- @@ -37,6 +37,13 @@ class BatchQueryConfig

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-03 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125316505 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-03 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125325560 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-03 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125316569 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-03 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125322758 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[jira] [Commented] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

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

[GitHub] flink issue #4213: [FLINK-7032] Overwrite inherited properties from parent p...

2017-07-03 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4213 Ok, now we have to many committers on this. 😅 How will 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-7032) Intellij is constantly changing language level of sub projects back to 1.6

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

[GitHub] flink issue #4213: [FLINK-7032] Overwrite inherited properties from parent p...

2017-07-03 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4213 LGTM thanks for the PR @pnowojski and for confirming the issue @StefanRRichter and @aljoscha --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-6936) Add multiple targets support for custom partitioner

2017-07-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072665#comment-16072665 ] Aljoscha Krettek commented on FLINK-6936: - We can add a new interface {{MultiPartitioner}} (or

[jira] [Commented] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

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

[GitHub] flink issue #4213: [FLINK-7032] Overwrite inherited properties from parent p...

2017-07-03 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4213 I have added one more sentence to the comment inside the pom. @zentol commit message is already quite verbose, but I have improved commit title. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

2017-07-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072627#comment-16072627 ] Greg Hogan commented on FLINK-6995: --- [~mingleizhang] users should be directed to the most latest stable

[jira] [Commented] (FLINK-7070) Rework ScalaShellITCase#testSubmissionOfExternalLibraryStream

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

[GitHub] flink pull request #4249: [FLINK-7070] Use properly built custom jar in Scal...

2017-07-03 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4249 [FLINK-7070] Use properly built custom jar in ScalaShellITCase Before, the external jar loading tests where using the flink-ml jar without the scala shell package actually declaring this as a

[jira] [Commented] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

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

[GitHub] flink issue #4213: [FLINK-7032] Overwrite inherited properties from parent p...

2017-07-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4213 let's improve the commit message and comment in the pom as to what we're actually doing (overwriting compiler version properties) and why (IntelliJ switching back). --- If your project is set up

[jira] [Updated] (FLINK-7069) Catch exceptions for each reporter separately

2017-07-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7069: Priority: Blocker (was: Major) > Catch exceptions for each reporter separately >

[jira] [Updated] (FLINK-7069) Catch exceptions for each reporter separately

2017-07-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7069: Fix Version/s: 1.3.2 > Catch exceptions for each reporter separately >

[jira] [Commented] (FLINK-7069) Catch exceptions for each reporter separately

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

[GitHub] flink pull request #4248: [FLINK-7069] [metrics] Granular exception catching...

2017-07-03 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4248 [FLINK-7069] [metrics] Granular exception catching in MetricRegistry This PR makes the exception catching in the MetricRegistry more granular when adding or removing metrics. A reporter

[jira] [Updated] (FLINK-7040) Flip-6 client-cluster interface

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7040: - Summary: Flip-6 client-cluster interface (was: Define cluster interface) > Flip-6 client-cluster

[jira] [Updated] (FLINK-7040) Flip-6 client-cluster communication

2017-07-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7040: - Summary: Flip-6 client-cluster communication (was: Flip-6 client-cluster interface) > Flip-6

  1   2   3   >