[jira] [Commented] (FLINK-4927) Implement FLI-6 YARN Resource Manager

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15704581#comment-15704581 ] ASF GitHub Bot commented on FLINK-4927: --- Github user shuai-xu commented on a diff in the pull

[GitHub] flink pull request #2808: [FLINK-4927] [yarn]Implement FLI-6 YARN Resource M...

2016-11-28 Thread shuai-xu
Github user shuai-xu commented on a diff in the pull request: https://github.com/apache/flink/pull/2808#discussion_r89955907 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -0,0 +1,551 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #2808: [FLINK-4927] [yarn]Implement FLI-6 YARN Resource M...

2016-11-28 Thread shuai-xu
Github user shuai-xu commented on a diff in the pull request: https://github.com/apache/flink/pull/2808#discussion_r89955140 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -0,0 +1,551 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-4927) Implement FLI-6 YARN Resource Manager

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15704565#comment-15704565 ] ASF GitHub Bot commented on FLINK-4927: --- Github user shuai-xu commented on a diff in the pull

[jira] [Commented] (FLINK-4927) Implement FLI-6 YARN Resource Manager

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15704562#comment-15704562 ] ASF GitHub Bot commented on FLINK-4927: --- Github user shuai-xu commented on a diff in the pull

[GitHub] flink pull request #2808: [FLINK-4927] [yarn]Implement FLI-6 YARN Resource M...

2016-11-28 Thread shuai-xu
Github user shuai-xu commented on a diff in the pull request: https://github.com/apache/flink/pull/2808#discussion_r89955045 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -0,0 +1,551 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Created] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5185: - Summary: Decouple BatchTableSourceScan with TableSourceTable Key: FLINK-5185 URL: https://issues.apache.org/jira/browse/FLINK-5185 Project: Flink Issue Type:

[jira] [Created] (FLINK-5184) Error result of compareSerialized in RowComparator class

2016-11-28 Thread godfrey he (JIRA)
godfrey he created FLINK-5184: - Summary: Error result of compareSerialized in RowComparator class Key: FLINK-5184 URL: https://issues.apache.org/jira/browse/FLINK-5184 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15704428#comment-15704428 ] ASF GitHub Bot commented on FLINK-5128: --- GitHub user Renkai opened a pull request:

[GitHub] flink pull request #2893: [FLINK-5128]Get Kafka partitions in FlinkKafkaProd...

2016-11-28 Thread Renkai
GitHub user Renkai opened a pull request: https://github.com/apache/flink/pull/2893 [FLINK-5128]Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set You can merge this pull request into a Git repository by running: $ git pull

[GitHub] flink pull request #2828: [FLINK-5093] java.util.ConcurrentModificationExcep...

2016-11-28 Thread ifndef-SleePy
Github user ifndef-SleePy closed the pull request at: https://github.com/apache/flink/pull/2828 --- 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

[jira] [Commented] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15704401#comment-15704401 ] ASF GitHub Bot commented on FLINK-5093: --- Github user ifndef-SleePy closed the pull request at:

[jira] [Commented] (FLINK-5076) Shutting down TM when shutting down new mini cluster

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15704389#comment-15704389 ] ASF GitHub Bot commented on FLINK-5076: --- Github user ifndef-SleePy closed the pull request at:

[GitHub] flink pull request #2817: [FLINK-5076] Shutting down TM when shutting down m...

2016-11-28 Thread ifndef-SleePy
Github user ifndef-SleePy closed the pull request at: https://github.com/apache/flink/pull/2817 --- 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

[jira] [Commented] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15704328#comment-15704328 ] ASF GitHub Bot commented on FLINK-4669: --- Github user shijinkui commented on the issue:

[GitHub] flink issue #2541: [FLINK-4669] scala api createLocalEnvironment() function ...

2016-11-28 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2541 @StephanEwen review it again please. --- 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

[GitHub] flink pull request #2880: [FLINK-5171] [runtime] fix wrong use of Preconditi...

2016-11-28 Thread shuai-xu
Github user shuai-xu closed the pull request at: https://github.com/apache/flink/pull/2880 --- 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-5171) Wrong use of Preconditions.checkState in TaskManagerRunner

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15704030#comment-15704030 ] ASF GitHub Bot commented on FLINK-5171: --- Github user shuai-xu closed the pull request at:

[jira] [Commented] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15703870#comment-15703870 ] ASF GitHub Bot commented on FLINK-5170: --- Github user shuai-xu closed the pull request at:

[GitHub] flink pull request #2879: [FLINK-5170] [runtime] fix mis judge of hostname i...

2016-11-28 Thread shuai-xu
Github user shuai-xu closed the pull request at: https://github.com/apache/flink/pull/2879 --- 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] [Comment Edited] (FLINK-4692) Add tumbling group-windows for batch tables

2016-11-28 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15698090#comment-15698090 ] Jark Wu edited comment on FLINK-4692 at 11/29/16 1:49 AM: -- Hi [~fhueske]

[GitHub] flink pull request #2892: [FLINK-5109] fix invalid content-encoding header o...

2016-11-28 Thread Hapcy
GitHub user Hapcy opened a pull request: https://github.com/apache/flink/pull/2892 [FLINK-5109] fix invalid content-encoding header of webmonitor Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-5109) Invalid Content-Encoding Header in REST API responses

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15703481#comment-15703481 ] ASF GitHub Bot commented on FLINK-5109: --- GitHub user Hapcy opened a pull request:

[jira] [Commented] (FLINK-5164) Hadoop-compat IOFormat tests fail on Windows

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15703251#comment-15703251 ] ASF GitHub Bot commented on FLINK-5164: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2889: [FLINK-5164] Disable some Hadoop-compat tests on Windows

2016-11-28 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2889 Thanks @zentol. Maybe add comments with a the link to the Hadoop wiki to the `assumeTrue` calls? Looks good to merge otherwise. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15703228#comment-15703228 ] ASF GitHub Bot commented on FLINK-4825: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2884: [FLINK-4825] [table] Implement a RexExecutor that uses Fl...

2016-11-28 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2884 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89882087 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/sql/CalcITCase.scala --- @@ -32,6 +32,7 @@ import

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89884351 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowJoinRule.scala --- @@ -0,0 +1,88 @@

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89883453 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowJoin.scala --- @@ -0,0 +1,229 @@ +/*

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89883134 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowJoin.scala --- @@ -0,0 +1,229 @@ +/*

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89811862 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/generated.scala --- @@ -41,3 +41,5 @@ object GeneratedExpression {

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89884314 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowJoinRule.scala --- @@ -0,0 +1,88 @@

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89883678 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowJoin.scala --- @@ -0,0 +1,229 @@ +/*

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89884981 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/MapSideJoinRunner.scala --- @@ -0,0 +1,50 @@ +/* + *

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89883549 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowJoin.scala --- @@ -0,0 +1,229 @@ +/*

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-28 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89884157 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowJoin.scala --- @@ -0,0 +1,229 @@ +/*

[jira] [Commented] (FLINK-5169) Make consumption of input channels fair

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702953#comment-15702953 ] ASF GitHub Bot commented on FLINK-5169: --- Github user uce commented on the issue:

[GitHub] flink issue #2882: [FLINK-5169] [network] Make consumption of InputChannels ...

2016-11-28 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2882 Thanks for the review, I'll address them and merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-5169) Make consumption of input channels fair

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702943#comment-15702943 ] ASF GitHub Bot commented on FLINK-5169: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5169) Make consumption of input channels fair

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702944#comment-15702944 ] ASF GitHub Bot commented on FLINK-5169: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5169) Make consumption of input channels fair

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702946#comment-15702946 ] ASF GitHub Bot commented on FLINK-5169: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #2882: [FLINK-5169] [network] Make consumption of InputCh...

2016-11-28 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2882#discussion_r89805572 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java --- @@ -518,7 +518,8 @@ void

[GitHub] flink pull request #2882: [FLINK-5169] [network] Make consumption of InputCh...

2016-11-28 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2882#discussion_r89810526 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java --- @@ -53,10 +52,10 @@

[GitHub] flink pull request #2882: [FLINK-5169] [network] Make consumption of InputCh...

2016-11-28 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2882#discussion_r89806640 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java --- @@ -52,12 +51,10 @@ --- End

[jira] [Commented] (FLINK-4098) Iteration support in Python API

2016-11-28 Thread Geoffrey Mon (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702931#comment-15702931 ] Geoffrey Mon commented on FLINK-4098: - A working implementation is available here:

[jira] [Commented] (FLINK-4861) Package optional project artifacts

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702837#comment-15702837 ] ASF GitHub Bot commented on FLINK-4861: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts

2016-11-28 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2664 @StephanEwen @rmetzger, why would a user copy an optional fat jar rather than having it included in their uber jar? By creating fat jars, do we not have the potential for duplicate

[jira] [Updated] (FLINK-4897) Implement Dispatcher

2016-11-28 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-4897: Component/s: Mesos > Implement Dispatcher > > > Key:

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

2016-11-28 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/2891 [FLINK-5129] make the BlobServer use a distributed file system Previously, the BlobServer held a local copy and in case high availability (HA) is set, it also copied jar files to a distributed

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

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

[jira] [Created] (FLINK-5182) Implement SSL file-shipping

2016-11-28 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5182: --- Summary: Implement SSL file-shipping Key: FLINK-5182 URL: https://issues.apache.org/jira/browse/FLINK-5182 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request #2788: [FLINK-5026] Rename TimelyFlatMap to Process

2016-11-28 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/2788 --- 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] [Closed] (FLINK-5026) Rename TimelyFlatMap to Process

2016-11-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5026. --- Resolution: Fixed Changed in 910f733f5ec52d2dd1e9dcc4ec6a4844cae2f2b4 > Rename TimelyFlatMap

[jira] [Commented] (FLINK-5026) Rename TimelyFlatMap to Process

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702624#comment-15702624 ] ASF GitHub Bot commented on FLINK-5026: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2788: [FLINK-5026] Rename TimelyFlatMap to Process

2016-11-28 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2788 Manually merged --- 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-5026) Rename TimelyFlatMap to Process

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702622#comment-15702622 ] ASF GitHub Bot commented on FLINK-5026: --- Github user aljoscha closed the pull request at:

[jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution

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

[GitHub] flink pull request #2823: [FLINK-4872] [types] Type erasure problem exclusiv...

2016-11-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2823 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (FLINK-5142) Resource leak in CheckpointCoordinator

2016-11-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5142. - Resolution: Fixed Fixed via e2c53cf85c1af73c040d96dbd24b9e2cf3e8cdf6 > Resource leak in

[jira] [Closed] (FLINK-5142) Resource leak in CheckpointCoordinator

2016-11-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5142. --- > Resource leak in CheckpointCoordinator > -- > >

[jira] [Closed] (FLINK-3932) Implement State Backend Security

2016-11-28 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan closed FLINK-3932. -- Resolution: Fixed > Implement State Backend Security >

[jira] [Updated] (FLINK-4918) Add SSL support to Mesos artifact server

2016-11-28 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-4918: Issue Type: Sub-task (was: Task) Parent: FLINK-1984 > Add SSL support to Mesos artifact

[jira] [Closed] (FLINK-5181) Add Tests in StateBackendTestBase that verify Default-Value Behaviour

2016-11-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5181. --- Resolution: Fixed Done in 60a4ab32e1662310da4633a97e02dca62431952e > Add Tests in

[GitHub] flink pull request #2855: Add Tests in StateBackendTestBase that verify Defa...

2016-11-28 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/2855 --- 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] [Updated] (FLINK-4826) Add keytab based kerberos support for Mesos environment

2016-11-28 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-4826: Component/s: Mesos > Add keytab based kerberos support for Mesos environment >

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support for Mesos environment

2016-11-28 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-4826: Issue Type: Sub-task (was: Task) Parent: FLINK-1984 > Add keytab based kerberos support

[GitHub] flink issue #2766: [FLINK-4898] Refactor HTTP handlers and Netty server/clie...

2016-11-28 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/2766 @mxm some duplication remains, yes - the KvState server/client still use a separate implementation (that was clearly cut/pasted). --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-4898) Refactor HTTP handlers and Netty server/client

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702467#comment-15702467 ] ASF GitHub Bot commented on FLINK-4898: --- Github user EronWright commented on the issue:

[jira] [Commented] (FLINK-4898) Refactor HTTP handlers and Netty server/client

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702459#comment-15702459 ] ASF GitHub Bot commented on FLINK-4898: --- Github user EronWright commented on the issue:

[GitHub] flink issue #2766: [FLINK-4898] Refactor HTTP handlers and Netty server/clie...

2016-11-28 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/2766 @uce happy to further discuss this PR, why it helps with making the Netty client/server code more reusable. Also provides some REST foundation code to be used later for FLINK-4897. --- If

[GitHub] flink issue #2827: [FLINK-4921] Upgrade to Mesos 1.0.1

2016-11-28 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/2827 We do lose back-compat but gain an important feature, the ability to ship files to sub-directories within the container. I've used this ability for FLINK-5091. --- If your project is set up

[jira] [Commented] (FLINK-4921) Upgrade to Mesos 1.0.1

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702429#comment-15702429 ] ASF GitHub Bot commented on FLINK-4921: --- Github user EronWright commented on the issue:

[jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos

2016-11-28 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-1984: Component/s: Mesos > Integrate Flink with Apache Mesos > - > >

[jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos

2016-11-28 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-1984: Fix Version/s: 1.2.0 > Integrate Flink with Apache Mesos > - > >

[jira] [Resolved] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService

2016-11-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5093. -- Resolution: Fixed Fixed via 029db00c1d74222fd9f67b08213668fd0eea1e4d >

[GitHub] flink issue #2828: [FLINK-5093] java.util.ConcurrentModificationException is...

2016-11-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2828 I've merged your PR. Thanks for your contribution @ifndef-SleePy. You can close this PR now. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Resolved] (FLINK-5076) Shutting down TM when shutting down new mini cluster

2016-11-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5076. -- Resolution: Fixed Fixed via dc8254d4b3eb7333d1e3a2717e01bab051da33a1 > Shutting down TM when

[jira] [Commented] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702403#comment-15702403 ] ASF GitHub Bot commented on FLINK-5093: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2817: [FLINK-5076] Shutting down TM when shutting down mini clu...

2016-11-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2817 I've merged your PR. You can close it now @ifndef-SleePy. --- 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

[jira] [Commented] (FLINK-5076) Shutting down TM when shutting down new mini cluster

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702399#comment-15702399 ] ASF GitHub Bot commented on FLINK-5076: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified

2016-11-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702393#comment-15702393 ] ASF GitHub Bot commented on FLINK-5170: --- Github user tillrohrmann commented on the issue:

[jira] [Resolved] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified

2016-11-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5170. -- Resolution: Fixed Fixed via 8265b545cff2fb5e6ca3771effd46a2fda488576 > getAkkaConfig will use

[GitHub] flink issue #2879: [FLINK-5170] [runtime] fix mis judge of hostname in AkkaU...

2016-11-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2879 I've merged your PR. You can close it @shuai-xu now. --- 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

[jira] [Resolved] (FLINK-5171) Wrong use of Preconditions.checkState in TaskManagerRunner

2016-11-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5171. -- Resolution: Fixed Fixed via 09ec78a5bd5db1b74c267c8a69e182543135a161 > Wrong use of

  1   2   3   4   >