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

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

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

2015-10-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14968621#comment-14968621 ] Aljoscha Krettek commented on FLINK-2891: - I think right now it is state/key for t

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

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14968618#comment-14968618 ] Gyula Fora commented on FLINK-2891: --- Btw, what is the state semantics for window functio

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

2015-10-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2891: --- Summary: Key for Keyed State is not set upon Window Evaluation Key: FLINK-2891 URL: https://issues.apache.org/jira/browse/FLINK-2891 Project: Flink Iss

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

2015-10-21 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

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

2015-10-21 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu reassigned FLINK-2634: -- Assignee: Andra Lungu > Add a Vertex-centric Version of the Tringle Count Library Method >

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

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

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

2015-10-21 Thread gallenvara
Github user gallenvara commented on the pull request: https://github.com/apache/flink/pull/1283#issuecomment-150094719 JMH result: ![longserializationspeed](https://cloud.githubusercontent.com/assets/12931563/10656076/c4085f44-78ad-11e5-9534-c69196b4.PNG) --- If your project

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

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

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

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

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

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

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

2015-10-21 Thread tedyu
GitHub user tedyu opened a pull request: https://github.com/apache/flink/pull/1282 FLINK-2866 Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle Use try-with-resources to close FSDataInputStream You can merge this pull request into a Git reposi

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

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

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

2015-10-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967987#comment-14967987 ] Márton Balassi commented on FLINK-2491: --- Unfortunately it is. I did not find the tim

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

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-2888: -- Affects Version/s: 0.10 > Default state not copied for AbstractHeapKvState > ---

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

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-2888: -- Component/s: Streaming > Default state not copied for AbstractHeapKvState >

[jira] [Closed] (FLINK-2471) FileSinkFunction invoke performance optimize

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-2471. - Resolution: Not A Problem > FileSinkFunction invoke performance optimize > ---

[jira] [Resolved] (FLINK-2589) Threads created in TimeTriggerPolicy don't end properly

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2589. --- Resolution: Not A Problem > Threads created in TimeTriggerPolicy don't end properly >

[jira] [Closed] (FLINK-1503) GSoC project: Batch and Streaming integration through new operators and unified API

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1503. - Resolution: Invalid > GSoC project: Batch and Streaming integration through new operators and > unified A

[jira] [Resolved] (FLINK-2010) Add test that verifies that chained tasks are properly checkpointed

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2010. --- Resolution: Fixed > Add test that verifies that chained tasks are properly checkpointed >

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967967#comment-14967967 ] Gyula Fora commented on FLINK-2491: --- Is this still an issue? > Operators are not partic

[jira] [Resolved] (FLINK-2138) PartitionCustom for streaming

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2138. --- Resolution: Fixed > PartitionCustom for streaming > - > >

[jira] [Resolved] (FLINK-2630) Scala DataStream API does not have a project method

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2630. --- Resolution: Not A Problem > Scala DataStream API does not have a project method >

[jira] [Closed] (FLINK-2494) Fix StreamGraph getJobGraph bug

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-2494. - Resolution: Fixed > Fix StreamGraph getJobGraph bug > --- > >

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

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967957#comment-14967957 ] Gyula Fora commented on FLINK-2470: --- Is this still an issue, or can we close it? > Stre

[jira] [Resolved] (FLINK-2481) Test at least once processing guarantee for streaming

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2481. --- Resolution: Fixed > Test at least once processing guarantee for streaming > --

[jira] [Closed] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1617. - Resolution: Invalid > GSoC project: Query optimisation layer for Flink Streaming > ---

[jira] [Closed] (FLINK-2201) Inconsistent use of ClosureCleaner in streaming window helpers

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-2201. - Resolution: Not A Problem > Inconsistent use of ClosureCleaner in streaming window helpers > -

[jira] [Resolved] (FLINK-2403) Rework partitioned state checkpointing logic

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2403. --- Resolution: Done > Rework partitioned state checkpointing logic >

[jira] [Closed] (FLINK-2180) Streaming iterate test fails spuriously

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-2180. - Resolution: Duplicate > Streaming iterate test fails spuriously > ---

[jira] [Closed] (FLINK-2154) ActiveTriggerPolicy collects elements to a closed buffer after job finishes

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-2154. - Resolution: Invalid > ActiveTriggerPolicy collects elements to a closed buffer after job finishes > --

[jira] [Closed] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter

2015-10-21 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-2143. - Resolution: Won't Fix > Add an overload to reduceWindow which takes the inverse of the reduceFunction > a

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

2015-10-21 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2888: - Summary: Default state not copied for AbstractHeapKvState Key: FLINK-2888 URL: https://issues.apache.org/jira/browse/FLINK-2888 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2015-10-21 Thread Saumitra Shahapure (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967547#comment-14967547 ] Saumitra Shahapure commented on FLINK-2254: --- Hi [~vkalavri], I have posted the d

[jira] [Resolved] (FLINK-2867) Access to pendingFilesPerCheckpoint should be synchronized

2015-10-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-2867. --- Resolution: Not A Problem > Access to pendingFilesPerCheckpoint should be synchronized > -

[jira] [Commented] (FLINK-2867) Access to pendingFilesPerCheckpoint should be synchronized

2015-10-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967541#comment-14967541 ] Stephan Ewen commented on FLINK-2867: - The Checkpoint/Restore and the {{invoke()}} met

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

2015-10-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967514#comment-14967514 ] Stephan Ewen commented on FLINK-2866: - The ObjectInputStream is resource-less and need

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

2015-10-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967517#comment-14967517 ] Stephan Ewen commented on FLINK-2866: - Thanks for spotting this, this should be fixed.

[jira] [Commented] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking

2015-10-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967502#comment-14967502 ] Stephan Ewen commented on FLINK-2826: - True, this can lead to NullPointers in corner c

[jira] [Closed] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output

2015-10-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2789. --- > Vulnerability to XSS attack due to printing HTML output > --

[jira] [Resolved] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output

2015-10-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2789. - Resolution: Not A Problem Fix Version/s: 0.10 The old web frontend that was affected by tha

[jira] [Commented] (FLINK-2868) Missing null check for operatorChain in StreamTask#invoke()

2015-10-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967475#comment-14967475 ] Stephan Ewen commented on FLINK-2868: - I don't think that this can ever be null, becau

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

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

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

2015-10-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967461#comment-14967461 ] 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-21 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1279#issuecomment-149962442 I would break the API since the old behavior can be confusing. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

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

2015-10-21 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1097#issuecomment-149961803 Looks like good progress! As pointed out in one of my comments, I think we should make the use a bit more intuitive. Having two methods which are named so similar but wh

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

2015-10-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967451#comment-14967451 ] 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-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1097#discussion_r42650529 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameter.java --- @@ -0,0 +1,149 @@ +/* + * Licensed to the Apache Softwa

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

2015-10-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1097#discussion_r42648906 --- 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-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967411#comment-14967411 ] ASF GitHub Bot commented on FLINK-2017: --- Github user fhueske commented on a diff in

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

2015-10-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1097#discussion_r42648726 --- 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-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967409#comment-14967409 ] ASF GitHub Bot commented on FLINK-2017: --- Github user fhueske commented on a diff in

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

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

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

2015-10-21 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1279#issuecomment-149952138 Do we agree to break the API for this change? And if so, should we add this change before or after the 0.10 release? --- If your project is set up for it, you can r

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

2015-10-21 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1252#issuecomment-149927087 I think it's a good fix. It applies to all POJOs, not just Avro-generated classes, but that should be ok. --- If your project is set up for it, you can reply to this e

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

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

[jira] [Resolved] (FLINK-2878) JobManager warns: Unexpected leader address pattern

2015-10-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2878. -- Resolution: Fixed Fixed via 3cad56d28d55025281873f53a28ec27ce1027992 > JobManager warns: Unexpe

[GitHub] flink pull request: [FLINK-2878] [webmonitor] Fix unexpected leade...

2015-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1280 --- 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-2878) JobManager warns: Unexpected leader address pattern

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

[GitHub] flink pull request: [FLINK-2878] [webmonitor] Fix unexpected leade...

2015-10-21 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1280#issuecomment-149921776 Will merge it then. --- 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 th

[jira] [Commented] (FLINK-2878) JobManager warns: Unexpected leader address pattern

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

[GitHub] flink pull request: [FLINK-2878] [webmonitor] Fix unexpected leade...

2015-10-21 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1280#issuecomment-149921478 LGTM --- 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 a

[jira] [Commented] (FLINK-2878) JobManager warns: Unexpected leader address pattern

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

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

2015-10-21 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1281 [FLINK-2887] [gelly] sendMessageToAllNeighbors respects the EdgeDirection The method now checks whether the edge direction has been set and collects the correct msg. You can merge this pull request i

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

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

[jira] [Closed] (FLINK-2886) NettyClient parses wrong configuration key for number of client threads

2015-10-21 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2886. -- Resolution: Fixed Fixed in 30c46ed > NettyClient parses wrong configuration key for number of client th

[jira] [Commented] (FLINK-2878) JobManager warns: Unexpected leader address pattern

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

[GitHub] flink pull request: [FLINK-2878] [webmonitor] Fix unexpected leade...

2015-10-21 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1280 [FLINK-2878] [webmonitor] Fix unexpected leader address pattern The HandlerRedirectUtils.getRedirectAddress decides whether the retrieved leader address is equal to the local job manager addres

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

2015-10-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14966820#comment-14966820 ] Chesnay Schepler commented on FLINK-1982: - Which tests specifically still need por

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

2015-10-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14966819#comment-14966819 ] Chesnay Schepler commented on FLINK-1988: - is this issue still valid [~hsaputra]?

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

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

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

2015-10-21 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/1279 [FLINK-2668] Chained Projections are no longer appended Chained project() calls (like project(0).project(1)) are no longer merged into a single projection, but instead applied separately. This means

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

2015-10-21 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2887: Summary: sendMessageToAllNeighbors ignores the EdgeDirection Key: FLINK-2887 URL: https://issues.apache.org/jira/browse/FLINK-2887 Project: Flink Issue Type:

[jira] [Closed] (FLINK-2834) Global round-robin for temporary directories

2015-10-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2834. Resolution: Fixed Fix Version/s: 0.10 0.9.2 Fixed for 0.10 with dd3264e636

[jira] [Closed] (FLINK-2743) Add new RNG based on XORShift algorithm

2015-10-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2743. Resolution: Fixed Fix Version/s: 0.10 Implemented with 5fb1c479f5e3f00917ebc2c623126b8966e463

[jira] [Closed] (FLINK-2876) Minutiae

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

[jira] [Closed] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method

2015-10-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2880. Resolution: Fixed Fixed with 7a959bcb405e0e4e6655dc87824c4ab27da317c2 > Allow DeserializationSchema

[jira] [Closed] (FLINK-2820) Configuration not passed to JobGraphGenerator

2015-10-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2820. Resolution: Fixed Fixed with 4c1cffd9d02d9ddaaf433a1882098c8423d97c28 > Configuration not passed to

[jira] [Commented] (FLINK-2743) Add new RNG based on XORShift algorithm

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

[jira] [Commented] (FLINK-2834) Global round-robin for temporary directories

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

[jira] [Commented] (FLINK-2876) Minutiae

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

[GitHub] flink pull request: [FLINK-2834] Global round-robin for temporary ...

2015-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1272 --- 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-2820) Configuration not passed to JobGraphGenerator

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

[jira] [Commented] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method

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

[GitHub] flink pull request: [FLINK-2876] Minutiae

2015-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1277 --- 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-2820] Configuration not passed to JobGr...

2015-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1278 --- 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: [docs] Fix documentation for building Flink wi...

2015-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1260 --- 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-2743] Add XORShfitRandom and use it in ...

2015-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1170 --- 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-2880] [streaming] [API-Breaking] Allow ...

2015-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1275 --- 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-2254) Add Bipartite Graph Support for Gelly

2015-10-21 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14966699#comment-14966699 ] Vasia Kalavri commented on FLINK-2254: -- Hi [~ssaumitra], you are right. Specialized a

[jira] [Commented] (FLINK-2865) OutOfMemory error (Direct buffer memory)

2015-10-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14966697#comment-14966697 ] Maximilian Michels commented on FLINK-2865: --- Yes, could have expressed myself mo

[jira] [Commented] (FLINK-2865) OutOfMemory error (Direct buffer memory)

2015-10-21 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14966691#comment-14966691 ] Ufuk Celebi commented on FLINK-2865: OK, sorry. "There is no limit anymore" was confus

[jira] [Created] (FLINK-2886) NettyClient parses wrong configuration key for number of client threads

2015-10-21 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2886: -- Summary: NettyClient parses wrong configuration key for number of client threads Key: FLINK-2886 URL: https://issues.apache.org/jira/browse/FLINK-2886 Project: Flink

[jira] [Commented] (FLINK-2820) Configuration not passed to JobGraphGenerator

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

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

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

[GitHub] flink pull request: [FLINK-2827] Closing FileInputStream in finall...

2015-10-21 Thread ssaumitra
Github user ssaumitra commented on the pull request: https://github.com/apache/flink/pull/1276#issuecomment-149862453 I just observed that Flink has already dropped Java 6 support. try with resources is the best possible approach then. I will amend my commit. --- If your project is s

[GitHub] flink pull request: [FLINK-2820] Configuration not passed to JobGr...

2015-10-21 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1278#issuecomment-149862634 Merging this one as well --- 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 th

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

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

[GitHub] flink pull request: [FLINK-2827] Closing FileInputStream in finall...

2015-10-21 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1276#issuecomment-149861772 +1 We're on Java 7, which allows to implicitly close resources in a try statement: --- If your project is set up for it, you can reply to this email and have your reply app

[GitHub] flink pull request: [docs] Fix documentation for building Flink wi...

2015-10-21 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1260#issuecomment-149861741 I agree, it makes sense to add the documentation as a separate PR. I think here in the office, all of us are using IntelliJ by now. But I could try to get my old Ec

  1   2   >