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

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

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

2015-10-22 Thread mliesenberg
Github user mliesenberg commented on the pull request: https://github.com/apache/flink/pull/1097#issuecomment-150490748 I think that might just boil down to the question whether or not there is a common enough use case for one without the other. If so, we could change it to one me

[GitHub] flink pull request: Mesos

2015-10-22 Thread cfmcgrady
Github user cfmcgrady closed the pull request at: https://github.com/apache/flink/pull/1295 --- 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 e

[GitHub] flink pull request: Mesos

2015-10-22 Thread cfmcgrady
GitHub user cfmcgrady opened a pull request: https://github.com/apache/flink/pull/1295 Mesos - remoe httpserver - add make-distribution.sh - tool for making binary distributions of flink You can merge this pull request into a Git repository by running: $ git pull https://gi

[jira] [Assigned] (FLINK-2902) Web interface sort tasks newest first

2015-10-22 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sachin Goel reassigned FLINK-2902: -- Assignee: Sachin Goel > Web interface sort tasks newest first > ---

[jira] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

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

[GitHub] flink pull request: [FLINK-1982] [record-api] Remove dependencies ...

2015-10-22 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/1294#discussion_r42818462 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/MapTaskTest.java --- @@ -38,8 +37,7 @@ import org.junit.Assert; import or

[GitHub] flink pull request: [FLINK-1982] [record-api] Remove dependencies ...

2015-10-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1294#issuecomment-150375992 Updated --- 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] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

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

[jira] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

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

[GitHub] flink pull request: [FLINK-1982] [record-api] Remove dependencies ...

2015-10-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1294#discussion_r42809588 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/MapTaskTest.java --- @@ -39,7 +38,7 @@ import org.junit.Test; @Suppr

[jira] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

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

[GitHub] flink pull request: [FLINK-1982] [record-api] Remove dependencies ...

2015-10-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1294#discussion_r42808744 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/MapTaskTest.java --- @@ -39,7 +38,7 @@ import org.junit.Test; @Suppre

[jira] [Commented] (FLINK-2901) Several flink-test ITCases depend on Record API features

2015-10-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969924#comment-14969924 ] Fabian Hueske commented on FLINK-2901: -- I started to remove some of the dependencies

[jira] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

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

[GitHub] flink pull request: [FLINK-1982] [record-api] Remove dependencies ...

2015-10-22 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1294 [FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests Rename Match*Test to Join*Test You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (FLINK-2904) Web interface truncated task counts

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2904: - Summary: Web interface truncated task counts Key: FLINK-2904 URL: https://issues.apache.org/jira/browse/FLINK-2904 Project: Flink Issue Type: Improvement

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

2015-10-22 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1293 [FLINK-2900] [hadoop-compat] Remove Record API code from Hadoop Compat module You can merge this pull request into a Git repository by running: $ git pull https://github.com/fhueske/flink had

[jira] [Created] (FLINK-2903) Web interface numeric localization

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2903: - Summary: Web interface numeric localization Key: FLINK-2903 URL: https://issues.apache.org/jira/browse/FLINK-2903 Project: Flink Issue Type: Improvement

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

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

[jira] [Created] (FLINK-2902) Web interface sort tasks newest first

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2902: - Summary: Web interface sort tasks newest first Key: FLINK-2902 URL: https://issues.apache.org/jira/browse/FLINK-2902 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2901) Several flink-test ITCases depend on Record API features

2015-10-22 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2901: Summary: Several flink-test ITCases depend on Record API features Key: FLINK-2901 URL: https://issues.apache.org/jira/browse/FLINK-2901 Project: Flink Issue

[jira] [Assigned] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

2015-10-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1982: Assignee: Fabian Hueske > Remove dependencies on Record for Flink runtime and core > --

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

2015-10-22 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2900: Summary: Remove Record-API dependencies from Hadoop Compat module Key: FLINK-2900 URL: https://issues.apache.org/jira/browse/FLINK-2900 Project: Flink Issue

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

2015-10-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2900: Assignee: Fabian Hueske > Remove Record-API dependencies from Hadoop Compat module > --

[jira] [Closed] (FLINK-1988) Port Record API based tests in the common.io

2015-10-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1988. Resolution: Invalid Yes, `common.io` is clean. > Port Record API based tests in the common.io > ---

[jira] [Commented] (FLINK-1988) Port Record API based tests in the common.io

2015-10-22 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969822#comment-14969822 ] Henry Saputra commented on FLINK-1988: -- I think we could close this one. > Port Reco

[jira] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

2015-10-22 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969821#comment-14969821 ] Henry Saputra commented on FLINK-1982: -- I am seeing TeraSortITCase extends RecordAPIT

[jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

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

[GitHub] flink pull request: [FLINK-2897] [runtime] Use distinct initial in...

2015-10-22 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1292 [FLINK-2897] [runtime] Use distinct initial indices for OutputEmitter round-robin You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/f

[jira] [Created] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure

2015-10-22 Thread Andra Lungu (JIRA)
Andra Lungu created FLINK-2899: -- Summary: The groupReduceOn* methods which take types as a parameter fail with TypeErasure Key: FLINK-2899 URL: https://issues.apache.org/jira/browse/FLINK-2899 Project: F

[jira] [Commented] (FLINK-2898) Invert Travis CI build order

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

[GitHub] flink pull request: [FLINK-2898] [build] Invert Travis CI build or...

2015-10-22 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1290#issuecomment-150336339 Thanks for catching that! The commit log is correct, so it is puzzling why the pull request would have a different title. --- If your project is set up for it, you ca

[jira] [Commented] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method

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

[GitHub] flink pull request: [FLINK-2634] [gelly] [WIP] Vertex Centric Tria...

2015-10-22 Thread andralungu
GitHub user andralungu opened a pull request: https://github.com/apache/flink/pull/1291 [FLINK-2634] [gelly] [WIP] Vertex Centric Triangle Count This PR builds on the code presented in #1105. Basically, the reduceOn* calls are replaced with groupReduceOn* calls. As dis

[jira] [Commented] (FLINK-2874) Certain Avro generated getters/setters not recognized

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

[jira] [Commented] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most

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

[GitHub] flink pull request: [FLINK-2668] Chained Projections are no longer...

2015-10-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1279#issuecomment-150318859 Will 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 featur

[jira] [Commented] (FLINK-2668) ProjectOperator method to close projection

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

[GitHub] flink pull request: [FLINK-2874] Fix Avro getter/setter recognitio...

2015-10-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1252#issuecomment-150318989 Will 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 this fe

[GitHub] flink pull request: [FLINK-2206] Fix incorrect counts of finished,...

2015-10-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1287#issuecomment-150318790 Thanks for the review. Will 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 proje

[jira] [Commented] (FLINK-2559) Fix Javadoc Code Examples

2015-10-22 Thread Hubert Czerpak (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969523#comment-14969523 ] Hubert Czerpak commented on FLINK-2559: --- I'd be happy to help with this one if nobod

[GitHub] flink pull request: [FLINK-2897] [runtime] Use distinct initial in...

2015-10-22 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1290#issuecomment-150300806 Wrong title. :') --- 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 thi

[jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

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

[GitHub] flink pull request: [FLINK-2897] [runtime] Use distinct initial in...

2015-10-22 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1290 [FLINK-2897] [runtime] Use distinct initial indices for OutputEmitter round-robin You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/f

[jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

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

[GitHub] flink pull request: [FLINK-2866] [FLINK-2888] [FLINK-2891] Fixes f...

2015-10-22 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1289#issuecomment-150299847 +1 Code looks good, I actually solved it the same way but got stuck on the tests... :smile: --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle

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

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

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

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

2015-10-22 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-150299549 @mxm , I have addressed some of your comments. Two things still remain: batch + stream jobs, and better tests. Need advice on those. --- If your project is

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

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969503#comment-14969503 ] 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-22 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42778575 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -139,6 +140,69 @@ public void shouldSubmitToJobClient() {

[GitHub] flink pull request: [FLINK-2866] [FLINK-2888] [FLINK-2891] Fixes f...

2015-10-22 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1289 [FLINK-2866] [FLINK-2888] [FLINK-2891] Fixes for various release blocking issues Default state value is returned as copies in key value state. To circumvent this (if ever becomes a performance

[jira] [Commented] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle

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

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

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

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

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969447#comment-14969447 ] 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-22 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42774775 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -304,4 +368,60 @@ public String getDescription() {

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

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969446#comment-14969446 ] 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-22 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42774659 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -139,6 +140,69 @@ public void shouldSubmitToJobClient() {

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

2015-10-22 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42774635 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -139,6 +140,69 @@ public void shouldSubmitToJobClient() {

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

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969435#comment-14969435 ] 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-22 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42774405 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java --- @@ -161,6 +171,8 @@ public ContextEnvironmentFactory

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

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969432#comment-14969432 ] 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-22 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42774255 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/Client.java --- @@ -277,12 +278,20 @@ else if (prog.isUsingInteractiveMode()) {

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

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

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

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

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

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

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

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969418#comment-14969418 ] 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-22 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-150283627 Thanks for the update @sachingoel0101. I've made some comments. I think the pull request needs a bit of cleanup to make things more explicit. The general approach looks good

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

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969417#comment-14969417 ] 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-22 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42772695 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -304,4 +368,60 @@ public String getDescription() {

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

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969413#comment-14969413 ] 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-22 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42772667 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -139,6 +140,69 @@ public void shouldSubmitToJobClient() { }

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

2015-10-22 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42772661 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -139,6 +140,69 @@ public void shouldSubmitToJobClient() { }

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

2015-10-22 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42772634 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java --- @@ -161,6 +171,8 @@ public ContextEnvironmentFactory(Client cli

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

2015-10-22 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42772606 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java --- @@ -172,5 +184,74 @@ public ExecutionEnvironment createExecuti

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

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969411#comment-14969411 ] 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-22 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r42772489 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/Client.java --- @@ -277,12 +278,20 @@ else if (prog.isUsingInteractiveMode()) {

[jira] [Assigned] (FLINK-2800) kryo serialization problem

2015-10-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2800: Assignee: Till Rohrmann > kryo serialization problem > -- > >

[jira] [Commented] (FLINK-2895) Duplicate immutable object creation

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

[GitHub] flink pull request: [FLINK-2895] Duplicate immutable object creati...

2015-10-22 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1288#issuecomment-150261354 Thanks for your work @greghogan. LGTM, +1 for merging. --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[jira] [Commented] (FLINK-2895) Duplicate immutable object creation

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

[GitHub] flink pull request: [FLINK-2895] Duplicate immutable object creati...

2015-10-22 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1288 [FLINK-2895] Duplicate immutable object creation Operators defer object creation when object reuse is disabled. You can merge this pull request into a Git repository by running: $ git pull ht

[jira] [Commented] (FLINK-2898) Invert Travis CI build order

2015-10-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969287#comment-14969287 ] Fabian Hueske commented on FLINK-2898: -- Good idea! +1 > Invert Travis CI build order

[jira] [Created] (FLINK-2898) Invert Travis CI build order

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2898: - Summary: Invert Travis CI build order Key: FLINK-2898 URL: https://issues.apache.org/jira/browse/FLINK-2898 Project: Flink Issue Type: Improvement Compon

[jira] [Created] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2897: - Summary: Use distinct initial indices for OutputEmitter round-robin Key: FLINK-2897 URL: https://issues.apache.org/jira/browse/FLINK-2897 Project: Flink Issue Type

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

2015-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969198#comment-14969198 ] Aljoscha Krettek commented on FLINK-2891: - I also pushed the fix for the General P

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

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

[GitHub] flink pull request: [FLINK-2891] Set KV-State key upon Window Eval...

2015-10-22 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/1285 --- 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 en

[jira] [Commented] (FLINK-2895) Duplicate immutable object creation

2015-10-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969154#comment-14969154 ] Greg Hogan commented on FLINK-2895: --- With immutable objects, when object reuse is enable

[jira] [Created] (FLINK-2896) Right-hand side menu items of website are missing in narrow browsers

2015-10-22 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2896: Summary: Right-hand side menu items of website are missing in narrow browsers Key: FLINK-2896 URL: https://issues.apache.org/jira/browse/FLINK-2896 Project: Flink

[jira] [Created] (FLINK-2895) Duplicate immutable object creation

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2895: - Summary: Duplicate immutable object creation Key: FLINK-2895 URL: https://issues.apache.org/jira/browse/FLINK-2895 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most

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

[jira] [Commented] (FLINK-2668) ProjectOperator method to close projection

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

[GitHub] flink pull request: [FLINK-2668] Chained Projections are no longer...

2015-10-22 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1279#issuecomment-150213016 Go ahead --- 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 enab

[jira] [Closed] (FLINK-2894) Flink does not allow to specify default serializer for Kryo

2015-10-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2894. Resolution: Not A Problem > Flink does not allow to specify default serializer for Kryo > --

[GitHub] flink pull request: [FLINK-2206] Fix incorrect counts of finished,...

2015-10-22 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1287#issuecomment-150212141 +1 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 feature

[GitHub] flink pull request: [FLINK-2668] Chained Projections are no longer...

2015-10-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1279#issuecomment-150211310 Thanks for the update, looks good. I will merge this into `master` and `release-0.10` unless somebody objects. --- If your project is set up for it, you can reply t

[jira] [Commented] (FLINK-2668) ProjectOperator method to close projection

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

[jira] [Created] (FLINK-2894) Flink does not allow to specify default serializer for Kryo

2015-10-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2894: Summary: Flink does not allow to specify default serializer for Kryo Key: FLINK-2894 URL: https://issues.apache.org/jira/browse/FLINK-2894 Project: Flink Is

  1   2   >