[jira] [Commented] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module

2015-10-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14968713#comment-14968713 ] Chesnay Schepler commented on FLINK-2848: - could you make a single PR for all files? > Refactor

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

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

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

2015-10-22 Thread gallenvara
Github user gallenvara commented on the pull request: https://github.com/apache/flink/pull/1284#issuecomment-150131741 JMH result: ![stringserializationspeed](https://cloud.githubusercontent.com/assets/12931563/10659384/f944e136-78d1-11e5-87db-f7929818774d.PNG) --- If your

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

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

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

2015-10-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14968625#comment-14968625 ] Gyula Fora commented on FLINK-2891: --- Then it's probably hard to keep state only in the window. In a

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1281#discussion_r42724980 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java --- @@ -129,24 +133,43 @@ public void

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

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

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

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

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1281#discussion_r42725042 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java --- @@ -129,24 +133,43 @@ public void

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

2015-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14968828#comment-14968828 ] ASF GitHub Bot commented on FLINK-2887: --- Github user fhueske commented on a diff in 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=14969503#comment-14969503 ] ASF GitHub Bot commented on FLINK-2797: --- Github user sachingoel0101 commented on a diff in the pull

[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=14969518#comment-14969518 ] ASF GitHub Bot commented on FLINK-2897: --- GitHub user greghogan opened a pull request:

[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=14969520#comment-14969520 ] ASF GitHub Bot commented on FLINK-2897: --- Github user sachingoel0101 commented on the 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

[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-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=14969765#comment-14969765 ] ASF GitHub Bot commented on FLINK-2898: --- Github user greghogan commented on the pull request:

[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-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

[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=14969628#comment-14969628 ] ASF GitHub Bot commented on FLINK-2874: --- Github user fhueske commented on the pull request:

[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:

[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-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=14969512#comment-14969512 ] ASF GitHub Bot commented on FLINK-2797: --- Github user sachingoel0101 commented on the pull request:

[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=14969515#comment-14969515 ] ASF GitHub Bot commented on FLINK-2866: --- Github user aljoscha commented on the pull request:

[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=14969754#comment-14969754 ] ASF GitHub Bot commented on FLINK-2634: --- GitHub user andralungu opened a pull request:

[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

[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

[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

[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

[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=14969627#comment-14969627 ] ASF GitHub Bot commented on FLINK-2668: --- Github user fhueske commented on the pull request:

[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

[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=14968621#comment-14968621 ] Aljoscha Krettek commented on FLINK-2891: - I think right now it is state/key for the window

[jira] [Created] (FLINK-2892) Apply JMH on MemorySegmentSpeedBenchmark class.

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

[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=14968853#comment-14968853 ] ASF GitHub Bot commented on FLINK-2866: --- Github user StephanEwen commented on the pull request:

[jira] [Closed] (FLINK-2841) Broken roadmap link in FlinkML contribution guide

2015-10-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2841. -- Resolution: Fixed Reopened to fix the "fix version" from "010" to "0.10" > Broken roadmap link in

[jira] [Updated] (FLINK-2841) Broken roadmap link in FlinkML contribution guide

2015-10-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2841: --- Fix Version/s: (was: 010) 0.10 > Broken roadmap link in FlinkML contribution

[jira] [Created] (FLINK-2893) Rename recovery configuration keys

2015-10-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2893: -- Summary: Rename recovery configuration keys Key: FLINK-2893 URL: https://issues.apache.org/jira/browse/FLINK-2893 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[jira] [Resolved] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

2015-10-22 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2887. -- Resolution: Fixed Fix Version/s: 0.10 > sendMessageToAllNeighbors ignores the

[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=14968940#comment-14968940 ] ASF GitHub Bot commented on FLINK-2668: --- Github user zentol commented on the pull request:

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

2015-10-22 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1279#issuecomment-150177113 @fhueske I've made the changes you suggested --- 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] [Reopened] (FLINK-2841) Broken roadmap link in FlinkML contribution guide

2015-10-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reopened FLINK-2841: > Broken roadmap link in FlinkML contribution guide > -

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1281 --- 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-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=14969807#comment-14969807 ] ASF GitHub Bot commented on FLINK-2897: --- GitHub user greghogan opened a pull request:

[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=14969906#comment-14969906 ] ASF GitHub Bot commented on FLINK-2900: --- GitHub user fhueske opened a pull request:

[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

[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-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=14969948#comment-14969948 ] ASF GitHub Bot commented on FLINK-1982: --- Github user fhueske commented on a diff in the pull

[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] [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

[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

[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] [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=14969821#comment-14969821 ] Henry Saputra commented on FLINK-1982: -- I am seeing TeraSortITCase extends RecordAPITestBase but

[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

[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=14969924#comment-14969924 ] Fabian Hueske commented on FLINK-2901: -- I started to remove some of the dependencies and tests. The

[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;

[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

[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=14970036#comment-14970036 ] ASF GitHub Bot commented on FLINK-1982: --- Github user fhueske commented on the 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

[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=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 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;

[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=14969934#comment-14969934 ] ASF GitHub Bot commented on FLINK-1982: --- Github user zentol commented on a diff in the pull request:

[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=14969822#comment-14969822 ] Henry Saputra commented on FLINK-1988: -- I think we could close this one. > Port Record API based

[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] [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

[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

[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=14970089#comment-14970089 ] ASF GitHub Bot commented on FLINK-1982: --- Github user hsaputra commented on a diff in the pull

[GitHub] flink pull request: FLINK-2866 Potential resource leak due to uncl...

2015-10-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1282#issuecomment-150159711 Good fix, 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

[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=14968859#comment-14968859 ] ASF GitHub Bot commented on FLINK-2891: --- GitHub user aljoscha opened a pull request:

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

2015-10-22 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1285 [FLINK-2891] Set KV-State key upon Window Evaluation in General Windows Before, this was not set, leading to incorrect results if KV-State was used in the WindowFunction. This also

[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-150163567 Regarding the PR itself: The `ProjectOperator` class can be cleaned up a bit more. By removing the two methods, the member variable `proj` becomes unused and the

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1281#issuecomment-150168427 Sure. Shall I do this after merging to master or shall we wait until we have more fixes for the RC? --- If your project is set up for it, you can reply to this email and

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1281#discussion_r42726773 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java --- @@ -129,24 +133,43 @@ public void

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[jira] [Commented] (FLINK-2470) Stream Iteration can Hang after some Data

2015-10-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14968856#comment-14968856 ] Stephan Ewen commented on FLINK-2470: - I think the iterations can deadlock, because of cyclic

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1281#discussion_r42728398 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java --- @@ -129,24 +133,43 @@ public void

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1281#issuecomment-150163859 As a bugfix, this can also go into the next 0.10 RC (i.e., cherry-pick to release branch). --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

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

2015-10-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-2206: --- Appears again in 0.10 with the new web frontend... > JobManager webinterface shows 5

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

2015-10-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2206: -- Fix Version/s: 0.10 > JobManager webinterface shows 5 finished jobs at most >

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

2015-10-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2206: -- Affects Version/s: 0.10 > JobManager webinterface shows 5 finished jobs at most >

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1281#issuecomment-150170995 Just merge to master and cherry pick the commit over to the release branch. No need to wait for more fixes. At some point, we build a new RC from the current release

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[jira] [Commented] (FLINK-2888) Default state not copied for AbstractHeapKvState

2015-10-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14968858#comment-14968858 ] Stephan Ewen commented on FLINK-2888: - Upcoming patch tested on Travis, will merge in a bit... >

[jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection

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

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1281#issuecomment-150163452 Thanks for reviewing @fhueske! I will add a comment to clarify what happens with the edge directions and merge this :) --- If your project is set up for it, you can

[GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors...

2015-10-22 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1281#issuecomment-150172859 Alright, will do. Thanks Fabian! --- 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] [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=14968883#comment-14968883 ] ASF GitHub Bot commented on FLINK-2874: --- Github user fhueske commented on the pull request:

[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-150165291 Looks good to me as well. Should we add this fix to 0.10 RC1 as well? --- If your project is set up for it, you can reply to this email and have your reply appear on

[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

[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=14969198#comment-14969198 ] Aljoscha Krettek commented on FLINK-2891: - I also pushed the fix for the General Purpose (GP)

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

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

[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=14969111#comment-14969111 ] ASF GitHub Bot commented on FLINK-2668: --- Github user fhueske commented on the pull request:

[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=14969122#comment-14969122 ] ASF GitHub Bot commented on FLINK-2668: --- Github user aljoscha commented on the pull request:

  1   2   >