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

2015-07-28 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2411: - Assignee: Martin Junghanns Add basic graph summarization algorithm

[jira] [Commented] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644070#comment-14644070 ] ASF GitHub Bot commented on FLINK-2405: --- Github user gyfora commented on the pull

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-28 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/936#issuecomment-125505767 Thanks, I will check :) --- 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] [Created] (FLINK-2417) Travis build failure on flink-tachyon

2015-07-28 Thread Sachin Goel (JIRA)
Sachin Goel created FLINK-2417: -- Summary: Travis build failure on flink-tachyon Key: FLINK-2417 URL: https://issues.apache.org/jira/browse/FLINK-2417 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644163#comment-14644163 ] ASF GitHub Bot commented on FLINK-2405: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644176#comment-14644176 ] ASF GitHub Bot commented on FLINK-2324: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-28 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/936#issuecomment-125503398 I've got one remark before merging. --- 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

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125532963 The `Checkpointed` variant used to be check in the settings source, chained and after repartition. That is no longer the case, so we lost the coverage there.

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644156#comment-14644156 ] ASF GitHub Bot commented on FLINK-2324: --- Github user gyfora commented on the pull

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644065#comment-14644065 ] ASF GitHub Bot commented on FLINK-2404: --- Github user mxm commented on the pull

[GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co...

2015-07-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/943#issuecomment-125507699 Why do we need to serialize the TypeInformation in the first place? --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644082#comment-14644082 ] ASF GitHub Bot commented on FLINK-2410: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644122#comment-14644122 ] ASF GitHub Bot commented on FLINK-2406: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2406] [FLINK-2402] Abstract the Barrier...

2015-07-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/938#issuecomment-125523242 I think the current code (pre this pull request) does not tolerate missing barriers. Missing barriers can happen at startup time, when one source took much longer to

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-28 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125525140 The test still tests the Checkpointed interface, and regarding the partitioned state, since the job is a wordcount, it is very natural to add partitioned state to test

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-28 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125529716 Yes but it has 3 stateful operators 2 of them use non-partitioned operator states and 1 uses the checkpointed interface. Assertions verify the behaviour. Now

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-28 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125537856 I can rewrite this of course and create new test classes but in any way the StreamCheckpointingIT case needs to be changed because it was not well designed in the first

[GitHub] flink pull request: [FLINK-2404]Primitive add methods for Accumula...

2015-07-28 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/942#issuecomment-125504599 Thanks for repeating your experiment isolated without the whole Flink stack. Here we can clearly see the performance impact of the `Long` auto unboxing. I will

[GitHub] flink pull request: [FLINK-2231] Create a Serializer for Scala Enu...

2015-07-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/935#discussion_r35631275 --- Diff: flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/ScalaSpecialTypesSerializerTest.scala --- @@ -93,8 +98,11 @@ class

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644151#comment-14644151 ] ASF GitHub Bot commented on FLINK-2324: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-2231) Create a Serializer for Scala Enumerations

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644152#comment-14644152 ] ASF GitHub Bot commented on FLINK-2231: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-2231] Create a Serializer for Scala Enu...

2015-07-28 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/935#issuecomment-125536383 Looks good, any objections to me merging this? I can fix the one comment I had about using serializer.getLength when I merge it. --- If your project is set up for it,

[jira] [Commented] (FLINK-2231) Create a Serializer for Scala Enumerations

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644162#comment-14644162 ] ASF GitHub Bot commented on FLINK-2231: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/936 --- 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-2411) Add basic graph summarization algorithm

2015-07-28 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14643995#comment-14643995 ] Vasia Kalavri commented on FLINK-2411: -- Hi [~mju]! Thank you for the detailed

[jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable

2015-07-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644057#comment-14644057 ] Fabian Hueske commented on FLINK-2410: -- I had exactly the same problem with shipping

[jira] [Commented] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644117#comment-14644117 ] ASF GitHub Bot commented on FLINK-2406: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-2406] [FLINK-2402] Abstract the Barrier...

2015-07-28 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/938#issuecomment-125520977 I tried this pull request on a cluster, because the current code is failing with the following exception when running it with a checkpoint interval of 1 second and a

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644159#comment-14644159 ] ASF GitHub Bot commented on FLINK-2324: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2391]Fix Storm-compatibility FlinkTopol...

2015-07-28 Thread ffbin
Github user ffbin closed the pull request at: https://github.com/apache/flink/pull/932 --- 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-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644007#comment-14644007 ] ASF GitHub Bot commented on FLINK-2391: --- Github user ffbin closed the pull request

[jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable

2015-07-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644059#comment-14644059 ] Stephan Ewen commented on FLINK-2410: - [~fhueske] is right. The initial design was

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-28 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/936#issuecomment-125505397 I think the way the partitioned field of a `StatefulFunction` is set can be simplified. Currently this happens with via the partitionByStateKey. This is not very

[jira] [Commented] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644068#comment-14644068 ] ASF GitHub Bot commented on FLINK-2405: --- Github user tillrohrmann commented on the

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-28 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125540030 Alright :) --- 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-2324) Rework partitioned state storage

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644177#comment-14644177 ] ASF GitHub Bot commented on FLINK-2324: --- Github user gyfora commented on the pull

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

2015-07-28 Thread Ankur Chauhan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14645190#comment-14645190 ] Ankur Chauhan commented on FLINK-1984: -- I just opened a pull request

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-28 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14645267#comment-14645267 ] Sachin Goel commented on FLINK-2404: Fixed via

[jira] [Created] (FLINK-2424) InstantiationUtil.serializeObject(Object) does not close output stream

2015-07-28 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2424: -- Summary: InstantiationUtil.serializeObject(Object) does not close output stream Key: FLINK-2424 URL: https://issues.apache.org/jira/browse/FLINK-2424 Project: Flink

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

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14645199#comment-14645199 ] ASF GitHub Bot commented on FLINK-1984: --- Github user uce commented on the pull

[GitHub] flink pull request: Framesize fix

2015-07-28 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35635357 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java --- @@ -309,6 +315,32 @@ public Task(TaskDeploymentDescriptor tdd,

[GitHub] flink pull request: Framesize fix

2015-07-28 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35635351 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java --- @@ -309,6 +315,32 @@ public Task(TaskDeploymentDescriptor tdd,

[GitHub] flink pull request: Framesize fix

2015-07-28 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35635338 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java --- @@ -259,6 +261,10 @@ public Task(TaskDeploymentDescriptor tdd,

[GitHub] flink pull request: Framesize fix

2015-07-28 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35635367 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/SerializedValue.java --- @@ -57,6 +60,25 @@ public T deserializeValue(ClassLoader loader)

[GitHub] flink pull request: Framesize fix

2015-07-28 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35635383 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala --- @@ -421,4 +421,16 @@ object AkkaUtils { val duration =

[GitHub] flink pull request: Framesize fix

2015-07-28 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35635395 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -338,16 +332,51 @@ class JobManager( // is

[GitHub] flink pull request: Framesize fix

2015-07-28 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35635361 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/SerializedValue.java --- @@ -47,6 +47,9 @@ public SerializedValue(T value) throws IOException

[GitHub] flink pull request: Framesize fix

2015-07-28 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35635387 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala --- @@ -421,4 +421,16 @@ object AkkaUtils { val duration =

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644353#comment-14644353 ] ASF GitHub Bot commented on FLINK-2404: --- Github user mxm commented on the pull

[GitHub] flink pull request: [FLINK-2404]Primitive add methods for Accumula...

2015-07-28 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/942#issuecomment-125603184 We can add a comment that the new ones are faster on primitives. It is not possible to deprecate the older ones because they are inherited from the Accumulator interface

[jira] [Created] (FLINK-2420) OutputFlush thread in stream writers does not propagate exceptions

2015-07-28 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2420: --- Summary: OutputFlush thread in stream writers does not propagate exceptions Key: FLINK-2420 URL: https://issues.apache.org/jira/browse/FLINK-2420 Project: Flink

[GitHub] flink pull request: [FLINK-2406] [FLINK-2402] Abstract the Barrier...

2015-07-28 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/938#issuecomment-125626437 Interesting... I had the same issue on my builds when I rebased on this PR. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Assigned] (FLINK-2412) Index Out of Bounds Exception

2015-07-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-2412: -- Assignee: Ufuk Celebi Index Out of Bounds Exception -

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-28 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125600663 Yes, I have written this above (that's why I replaced it with one using the partitioned states). But that's not the only problem. If you introduce a shuffle between two

[GitHub] flink pull request: [FLINK-2406] [FLINK-2402] Abstract the Barrier...

2015-07-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/938#issuecomment-125622275 Actually, the failure is not a deadlock. It just seems that the run is so slow that the test takes more than 5 minutes. The stack trace indicates that various tasks

[jira] [Commented] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644405#comment-14644405 ] ASF GitHub Bot commented on FLINK-2406: --- Github user StephanEwen commented on the

[jira] [Created] (FLINK-2416) Expose vertex using with the new URL scheme

2015-07-28 Thread Piotr Godek (JIRA)
Piotr Godek created FLINK-2416: -- Summary: Expose vertex using with the new URL scheme Key: FLINK-2416 URL: https://issues.apache.org/jira/browse/FLINK-2416 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644130#comment-14644130 ] ASF GitHub Bot commented on FLINK-2324: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125524456 I think we should not change the existing tests but add new ones. The current `StreamCheckpointingITCase` is there to test the non-partitioned state. Update:

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644170#comment-14644170 ] ASF GitHub Bot commented on FLINK-2324: --- Github user gyfora commented on the pull

[jira] [Commented] (FLINK-2412) Index Out of Bounds Exception

2015-07-28 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644351#comment-14644351 ] Andra Lungu commented on FLINK-2412: 19:17:33,944 WARN

[jira] [Commented] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644429#comment-14644429 ] ASF GitHub Bot commented on FLINK-2406: --- Github user gyfora commented on the pull

[jira] [Updated] (FLINK-2412) Index Out of Bounds Exception

2015-07-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2412: --- Fix Version/s: 0.9.1 0.10 Index Out of Bounds Exception

[jira] [Updated] (FLINK-2412) Index Out of Bounds Exception

2015-07-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2412: --- Component/s: (was: Local Runtime) Distributed Runtime Index Out of Bounds

[jira] [Updated] (FLINK-2412) Index Out of Bounds Exception

2015-07-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2412: --- Affects Version/s: 0.9 Index Out of Bounds Exception -

[jira] [Updated] (FLINK-2412) Index Out of Bounds Exception

2015-07-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2412: --- Priority: Critical (was: Major) Index Out of Bounds Exception -

[jira] [Commented] (FLINK-2412) Index Out of Bounds Exception

2015-07-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644458#comment-14644458 ] Ufuk Celebi commented on FLINK-2412: Thanks for reporting the issue. Looks like a bug

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644346#comment-14644346 ] ASF GitHub Bot commented on FLINK-2324: --- Github user gyfora commented on the pull

[jira] [Created] (FLINK-2418) Add an end-to-end streaming fault tolerance test for the Checkpointed interface

2015-07-28 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2418: --- Summary: Add an end-to-end streaming fault tolerance test for the Checkpointed interface Key: FLINK-2418 URL: https://issues.apache.org/jira/browse/FLINK-2418

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-28 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125604960 I am adding an IT case to this PR that tests partitioned states independently. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644368#comment-14644368 ] ASF GitHub Bot commented on FLINK-2324: --- Github user gyfora commented on the pull

[GitHub] flink pull request: [FLINK-2404]Primitive add methods for Accumula...

2015-07-28 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/942#issuecomment-125604252 No one will actually find out unless they specifically went through the documentation for these. Most people would only ever see the docs for Accumulator

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644358#comment-14644358 ] ASF GitHub Bot commented on FLINK-2404: --- Github user sachingoel0101 commented on the

[jira] [Created] (FLINK-2419) DataStream sinks lose key information

2015-07-28 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2419: - Summary: DataStream sinks lose key information Key: FLINK-2419 URL: https://issues.apache.org/jira/browse/FLINK-2419 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2421) StreamRecordSerializer incorrectly duplicates and misses tests

2015-07-28 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2421: --- Summary: StreamRecordSerializer incorrectly duplicates and misses tests Key: FLINK-2421 URL: https://issues.apache.org/jira/browse/FLINK-2421 Project: Flink

[jira] [Updated] (FLINK-2422) Web client is showing a blank page if Meta refresh is disabled in browser

2015-07-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2422: -- Labels: starter (was: ) Web client is showing a blank page if Meta refresh is disabled in

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644554#comment-14644554 ] ASF GitHub Bot commented on FLINK-2105: --- Github user jkovacs commented on the pull

[GitHub] flink pull request: [FLINK-2406] [FLINK-2402] Abstract the Barrier...

2015-07-28 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/938#issuecomment-125664433 It's the same problem I guess, if you look at this Thread: ``` Custom Source (6/6) daemon prio=10 tid=0x7f96a80c9800 nid=0x112cf runnable

[jira] [Commented] (FLINK-2422) Web client is showing a blank page if Meta refresh is disabled in browser

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644584#comment-14644584 ] ASF GitHub Bot commented on FLINK-2422: --- GitHub user buzdin opened a pull request:

[jira] [Commented] (FLINK-2419) DataStream sinks lose key information

2015-07-28 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644503#comment-14644503 ] Gyula Fora commented on FLINK-2419: --- I added a test in my other PR for the sinks.

[jira] [Reopened] (FLINK-2419) DataStream sinks lose key information

2015-07-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-2419: --- DataStream sinks lose key information -

[jira] [Created] (FLINK-2422) Web client is showing a blank page if Meta refresh is disabled

2015-07-28 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2422: - Summary: Web client is showing a blank page if Meta refresh is disabled Key: FLINK-2422 URL: https://issues.apache.org/jira/browse/FLINK-2422 Project: Flink

[GitHub] flink pull request: [FLINK-2406] [FLINK-2402] Abstract the Barrier...

2015-07-28 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/938#issuecomment-125660687 You can observe it on this build for instance: https://travis-ci.org/gyfora/flink/builds/73018512 --- If your project is set up for it, you can reply to this email and

[GitHub] flink pull request: [FLINK-2404]Primitive add methods for Accumula...

2015-07-28 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/942#issuecomment-125652591 For the cases, where we add a primitive type on a Long/Int/DoubleCounter, the optimization will automatically be used. --- If your project is set up for it, you can reply

[jira] [Updated] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2404: -- Assignee: Sachin Goel LongCounters should have an addValue() method for primitive

[jira] [Commented] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644565#comment-14644565 ] ASF GitHub Bot commented on FLINK-2406: --- Github user gyfora commented on the pull

[GitHub] flink pull request: [FLINK-2422] [web client] adding redirect link

2015-07-28 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/946#issuecomment-125665625 Thank you for the contribution. +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-2422) Web client is showing a blank page if Meta refresh is disabled in browser

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644585#comment-14644585 ] ASF GitHub Bot commented on FLINK-2422: --- Github user rmetzger commented on the pull

[jira] [Resolved] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2404. --- Resolution: Fixed LongCounters should have an addValue() method for primitive longs

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-28 Thread jkovacs
Github user jkovacs commented on the pull request: https://github.com/apache/flink/pull/907#issuecomment-125657216 Thanks @fhueske and @chiwanpark for the comprehensive review. I have pushed our updated branch, addressing your comments. @r-pogalz will also contribute a microbenchmark

[GitHub] flink pull request: [FLINK-2422] [web client] adding redirect link

2015-07-28 Thread buzdin
GitHub user buzdin opened a pull request: https://github.com/apache/flink/pull/946 [FLINK-2422] [web client] adding redirect link - added explicit link in case browser is not redirecting properly You can merge this pull request into a Git repository by running: $ git pull

[jira] [Resolved] (FLINK-2419) DataStream sinks lose key information

2015-07-28 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2419. --- Resolution: Fixed https://github.com/apache/flink/commit/78fd2146dd00da1130910d9f23f09e2504854ef7

[jira] [Comment Edited] (FLINK-2419) DataStream sinks lose key information

2015-07-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644487#comment-14644487 ] Robert Metzger edited comment on FLINK-2419 at 7/28/15 2:59 PM:

[GitHub] flink pull request: [FLINK-2404]Primitive add methods for Accumula...

2015-07-28 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/942#issuecomment-125653547 Thanks for the pull request! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644527#comment-14644527 ] ASF GitHub Bot commented on FLINK-2404: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-2419) DataStream sinks lose key information

2015-07-28 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644526#comment-14644526 ] Gyula Fora commented on FLINK-2419: --- Alright, it's going to be a tricky test due to the

[jira] [Commented] (FLINK-2419) DataStream sinks lose key information

2015-07-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644510#comment-14644510 ] Robert Metzger commented on FLINK-2419: --- Okay, I suspect its this one:

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644528#comment-14644528 ] ASF GitHub Bot commented on FLINK-2404: --- Github user mxm commented on the pull

[GitHub] flink pull request: [FLINK-2404]Primitive add methods for Accumula...

2015-07-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/942 --- 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-2404) LongCounters should have an addValue() method for primitive longs

2015-07-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14644531#comment-14644531 ] ASF GitHub Bot commented on FLINK-2404: --- Github user sachingoel0101 commented on the

  1   2   >