[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14975823#comment-14975823 ] ASF GitHub Bot commented on FLINK-7: Github user ChengXiangLi commented on a diff in the

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-10-26 Thread ChengXiangLi
Github user ChengXiangLi commented on a diff in the pull request: https://github.com/apache/flink/pull/1255#discussion_r43088529 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -1223,6 +1230,51 @@ public long count() throws Exception {

[jira] [Commented] (FLINK-2920) Apply JMH on KryoVersusAvroMinibenchmark class.

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14975656#comment-14975656 ] ASF GitHub Bot commented on FLINK-2920: --- GitHub user gallenvara opened a pull reques

[GitHub] flink pull request: [FLINK-2920] [tests] Apply JMH on KryoVersusAv...

2015-10-26 Thread gallenvara
GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/1302 [FLINK-2920] [tests] Apply JMH on KryoVersusAvroMinibenchmark class. JMH is a Java harness for building, running, and analysing nano/micro/milli/macro benchmarks.Use JMH to replace the old micro

[jira] [Closed] (FLINK-1611) [REFACTOR] Rename classes and packages in test that contains Nephele

2015-10-26 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra closed FLINK-1611. Resolution: Fixed Fix Version/s: 0.10 This seemed to be fixed. > [REFACTOR] Rename classes a

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

2015-10-26 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14975242#comment-14975242 ] Flavio Pompermaier commented on FLINK-1827: --- A lot of improvements regarding Fli

[jira] [Closed] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class

2015-10-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2889. Resolution: Fixed Fix Version/s: 1.0 Fixed with 75a5257412606ac70113850439457cce7da3b2e6 > A

[jira] [Closed] (FLINK-2890) Apply JMH on StringSerializationSpeedBenchmark class.

2015-10-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2890. Resolution: Fixed Fix Version/s: 1.0 Fixed with 75a5257412606ac70113850439457cce7da3b2e6 > A

[jira] [Closed] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

2015-10-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2827. Resolution: Fixed Fix Version/s: 1.0 Fixed with 6a8e90b3621bb96304b325a4ae8f7f5575ec909a > P

[jira] [Closed] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class.

2015-10-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2919. Resolution: Fixed Fix Version/s: 1.0 Fixed with 7265d81ff95aff4ddfbcbd4ef25869ea8f159769 > A

[jira] [Closed] (FLINK-2853) Apply JMH on MutableHashTablePerformanceBenchmark class.

2015-10-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2853. Resolution: Fixed Fix Version/s: 1.0 Fixed with e5ee55bdaf0dcd6e3dc38b52964a8570b22dd671 > A

[jira] [Commented] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

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

[jira] [Commented] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class

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

[jira] [Commented] (FLINK-2853) Apply JMH on MutableHashTablePerformanceBenchmark class.

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

[jira] [Commented] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class.

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

[jira] [Commented] (FLINK-2890) Apply JMH on StringSerializationSpeedBenchmark class.

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

[GitHub] flink pull request: [FLINK-2827] Closing FileInputStream through t...

2015-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1276 --- 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: [FLINK-2890] [tests] Apply JMH on StringSerial...

2015-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1284 --- 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: [FLINK-2919] [tests] Apply JMH on FieldAccessM...

2015-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1300 --- 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: [FLINK-2853] [tests] Apply JMH on MutableHashT...

2015-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1267 --- 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: [FLINK-2889] [tests] Apply JMH on LongSerializ...

2015-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1283 --- 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-2909) Gelly Graph Generators

2015-10-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974985#comment-14974985 ] Greg Hogan commented on FLINK-2909: --- My thought was to initially implement one or two of

[jira] [Commented] (FLINK-2922) Add Queryable Window Operator

2015-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974914#comment-14974914 ] Aljoscha Krettek commented on FLINK-2922: - I don't exactly know what you mean by t

[jira] [Commented] (FLINK-2922) Add Queryable Window Operator

2015-10-26 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974818#comment-14974818 ] Gyula Fora commented on FLINK-2922: --- I think this could be implemented nicely with the s

[jira] [Created] (FLINK-2925) Client does not show root cause of Exception

2015-10-26 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2925: -- Summary: Client does not show root cause of Exception Key: FLINK-2925 URL: https://issues.apache.org/jira/browse/FLINK-2925 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-2925) Client shows incomplete cause of Exception

2015-10-26 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2925: --- Summary: Client shows incomplete cause of Exception (was: Client does not show root cause of Exceptio

[jira] [Created] (FLINK-2924) Create database state backend

2015-10-26 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2924: - Summary: Create database state backend Key: FLINK-2924 URL: https://issues.apache.org/jira/browse/FLINK-2924 Project: Flink Issue Type: Improvement Compo

[jira] [Created] (FLINK-2923) Make it possible to mix-and-match StateBackends with KvState implementations

2015-10-26 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2923: - Summary: Make it possible to mix-and-match StateBackends with KvState implementations Key: FLINK-2923 URL: https://issues.apache.org/jira/browse/FLINK-2923 Project: Flink

[GitHub] flink pull request: Add org.apache.httpcomponents:(httpcore, httpc...

2015-10-26 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1301 Add org.apache.httpcomponents:(httpcore, httpclient) to dependency management Hadoop 2.4.0 has `httpcomponents` dependencies, which breaks Flink on Amazon EMR AMI 3.9, because 4.1.2 is missing a method

[jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974646#comment-14974646 ] ASF GitHub Bot commented on FLINK-2797: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs...

2015-10-26 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-151224527 I took a look at this again because I wanted to merge it for 0.10. However, I think it still needs a bit of work. The `ContextEnvironmentFactory` shouldn't hold the state fo

[jira] [Commented] (FLINK-2853) Apply JMH on MutableHashTablePerformanceBenchmark class.

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974538#comment-14974538 ] ASF GitHub Bot commented on FLINK-2853: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974534#comment-14974534 ] ASF GitHub Bot commented on FLINK-2827: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-2890) Apply JMH on StringSerializationSpeedBenchmark class.

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974539#comment-14974539 ] ASF GitHub Bot commented on FLINK-2890: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2890] [tests] Apply JMH on StringSerial...

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1284#issuecomment-151208210 I'm going to merge this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] flink pull request: [FLINK-2853] [tests] Apply JMH on MutableHashT...

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1267#issuecomment-151208136 I'm going to merge this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class.

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974533#comment-14974533 ] ASF GitHub Bot commented on FLINK-2919: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2889] [tests] Apply JMH on LongSerializ...

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1283#issuecomment-151208005 I'm going to merge this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974537#comment-14974537 ] ASF GitHub Bot commented on FLINK-2889: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2919] [tests] Apply JMH on FieldAccessM...

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1300#issuecomment-151207830 I'm going to merge this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] flink pull request: [FLINK-2827] Closing FileInputStream through t...

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1276#issuecomment-151207922 I'm going to merge this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class.

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974495#comment-14974495 ] ASF GitHub Bot commented on FLINK-2919: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2919] [tests] Apply JMH on FieldAccessM...

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1300#issuecomment-151196004 Looks good to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this fe

[jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974487#comment-14974487 ] ASF GitHub Bot commented on FLINK-2797: --- Github user sachingoel0101 commented on a d

[GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs...

2015-10-26 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r43015201 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -304,4 +368,60 @@ public String getDescription() {

[jira] [Commented] (FLINK-2922) Add Queryable Window Operator

2015-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974474#comment-14974474 ] Aljoscha Krettek commented on FLINK-2922: - The idea is, for example, that the regu

[jira] [Commented] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974467#comment-14974467 ] ASF GitHub Bot commented on FLINK-2889: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2889] [tests] Apply JMH on LongSerializ...

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1283#issuecomment-151191115 Thanks for the update. Looks good to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Commented] (FLINK-2922) Add Queryable Window Operator

2015-10-26 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974438#comment-14974438 ] Gyula Fora commented on FLINK-2922: --- I don't immediately see a lot of use cases for this

[jira] [Commented] (FLINK-2900) Remove Record-API dependencies from Hadoop Compat module

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974414#comment-14974414 ] ASF GitHub Bot commented on FLINK-2900: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2900] [hadoop-compat] Remove Record API...

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1293#issuecomment-151179551 Any comments? Otherwise I would merge this PR tomorrow. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974402#comment-14974402 ] ASF GitHub Bot commented on FLINK-7: Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1255#issuecomment-151177199 Hi, I left a few comments inside. I don't think we need the special user code to extract keys. The comparators provide this functionality and can be generated within

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974395#comment-14974395 ] ASF GitHub Bot commented on FLINK-7: Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974391#comment-14974391 ] ASF GitHub Bot commented on FLINK-7: Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-10-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1255#discussion_r43008448 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java --- @@ -1138,12 +1138,13 @@ private DistributionPatte

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-10-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1255#discussion_r43008620 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java --- @@ -1264,11 +1264,10 @@ public static void logAndThrowException(E

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-10-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1255#discussion_r43006432 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -1223,6 +1230,51 @@ public long count() throws Exception { fi

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974366#comment-14974366 ] ASF GitHub Bot commented on FLINK-7: Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-10-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1255#discussion_r43005310 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/functions/AssignRangeIndex.java --- @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Soft

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974353#comment-14974353 ] ASF GitHub Bot commented on FLINK-7: Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-10-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1255#discussion_r43004309 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/functions/AssignRangeIndex.java --- @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Soft

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974346#comment-14974346 ] ASF GitHub Bot commented on FLINK-7: Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-10-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1255#discussion_r43004130 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/functions/AssignRangeIndex.java --- @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Soft

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974343#comment-14974343 ] ASF GitHub Bot commented on FLINK-7: Github user fhueske commented on a diff in the pull

[jira] [Created] (FLINK-2922) Add Queryable Window Operator

2015-10-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2922: --- Summary: Add Queryable Window Operator Key: FLINK-2922 URL: https://issues.apache.org/jira/browse/FLINK-2922 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974232#comment-14974232 ] ASF GitHub Bot commented on FLINK-2017: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

2015-10-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1097#issuecomment-151142957 Going through FLINK-2017, I interpreted the semantics of `check` and `checkAndPopulate` as follows: - `check` verifies that all required parameters are provided and v

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

2015-10-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1097#discussion_r42993834 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameter.java --- @@ -0,0 +1,149 @@ +/* + * Licensed to the Apache Softwa

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

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

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974183#comment-14974183 ] ASF GitHub Bot commented on FLINK-2918: --- Github user smarthi commented on the pull r

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

2015-10-26 Thread smarthi
Github user smarthi commented on the pull request: https://github.com/apache/flink/pull/1299#issuecomment-151130141 Also need to add a method for the new Hadoop API, the present PR only deals with Hadoop v1 --- If your project is set up for it, you can reply to this email and have yo

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

2015-10-26 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1299#issuecomment-151125493 LGTM. The `readAsSequenceFile` is nice syntactic sugar to add. But we should add documentation to the online documentation since it's the user facing API which we e

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974167#comment-14974167 ] ASF GitHub Bot commented on FLINK-2918: --- Github user tillrohrmann commented on the p

[jira] [Updated] (FLINK-2850) Limit the types of jobs which can run in detached mode

2015-10-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2850: -- Issue Type: Sub-task (was: Bug) Parent: FLINK-2797 > Limit the types of jobs wh

[jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974019#comment-14974019 ] ASF GitHub Bot commented on FLINK-2797: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs...

2015-10-26 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42979520 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -304,4 +368,60 @@ public String getDescription() {

[jira] [Resolved] (FLINK-2411) Add basic graph summarization algorithm

2015-10-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2411. -- Resolution: Implemented Fix Version/s: 1.0 > Add basic graph summarization algorithm > --

[jira] [Commented] (FLINK-2411) Add basic graph summarization algorithm

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

[GitHub] flink pull request: [FLINK-2411] [gelly] Add Summarization Algorit...

2015-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1269 --- 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-2591) Add configuration parameter for default number of yarn containers

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14973986#comment-14973986 ] ASF GitHub Bot commented on FLINK-2591: --- Github user willmiao commented on the pull

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-10-26 Thread willmiao
Github user willmiao commented on the pull request: https://github.com/apache/flink/pull/1121#issuecomment-151092573 hi @rmetzger , I believe I find the reason why my test failed. A test will fail if we don’t specify “-t” argument(_which is an optional argument_) in the c

[jira] [Commented] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14973982#comment-14973982 ] ASF GitHub Bot commented on FLINK-2827: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2827] Closing FileInputStream through t...

2015-10-26 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1276#issuecomment-151091135 Looks good! --- 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 enable

[jira] [Created] (FLINK-2921) Add online documentation of sample methods

2015-10-26 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2921: Summary: Add online documentation of sample methods Key: FLINK-2921 URL: https://issues.apache.org/jira/browse/FLINK-2921 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

2015-10-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14973972#comment-14973972 ] Vasia Kalavri commented on FLINK-2905: -- Hi [~mju], several {{Graph}} methods use the

[jira] [Updated] (FLINK-2435) Add support for custom CSV field parsers

2015-10-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2435: -- Fix Version/s: 1.0 > Add support for custom CSV field parsers >

[jira] [Commented] (FLINK-2909) Gelly Graph Generators

2015-10-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14973937#comment-14973937 ] Vasia Kalavri commented on FLINK-2909: -- Hi [~greghogan], thank you for opening this i

[GitHub] flink pull request: [FLINK-2411] [gelly] Add Summarization Algorit...

2015-10-26 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1269#issuecomment-151077098 I'll 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 this feature

[jira] [Commented] (FLINK-2411) Add basic graph summarization algorithm

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14973926#comment-14973926 ] ASF GitHub Bot commented on FLINK-2411: --- Github user vasia commented on the pull req

[jira] [Closed] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation

2015-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2891. --- Resolution: Fixed Fixed for both types of window operations now. > Key for Keyed State is not

[jira] [Updated] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows

2015-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2870: Fix Version/s: (was: 0.10) > Add support for accumulating/discarding for Event-Time Wind

[jira] [Created] (FLINK-2920) Apply JMH on KryoVersusAvroMinibenchmark class.

2015-10-26 Thread GaoLun (JIRA)
GaoLun created FLINK-2920: - Summary: Apply JMH on KryoVersusAvroMinibenchmark class. Key: FLINK-2920 URL: https://issues.apache.org/jira/browse/FLINK-2920 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request: [FLINK-2919] [tests] Apply JMH on FieldAccessM...

2015-10-26 Thread gallenvara
Github user gallenvara commented on the pull request: https://github.com/apache/flink/pull/1300#issuecomment-151048797 Result (without JMH): ![fieldaccessmini](https://cloud.githubusercontent.com/assets/12931563/10723423/a52c8a00-7bf5-11e5-9784-b7d4cb25f77d.PNG) Result (with JM

[jira] [Commented] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class.

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14973847#comment-14973847 ] ASF GitHub Bot commented on FLINK-2919: --- Github user gallenvara commented on the pul

[jira] [Commented] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class.

2015-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14973843#comment-14973843 ] ASF GitHub Bot commented on FLINK-2919: --- GitHub user gallenvara opened a pull reques

[GitHub] flink pull request: [FLINK-2919] [tests] Apply JMH on FieldAccessM...

2015-10-26 Thread gallenvara
GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/1300 [FLINK-2919] [tests] Apply JMH on FieldAccessMinibenchmark class. JMH is a Java harness for building, running, and analysing nano/micro/milli/macro benchmarks.Use JMH to replace the old micro ben