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

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

[GitHub] flink pull request: [FLINK-2841] Correcting roadmap link to point ...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1254#issuecomment-148776433 Looks good, merging 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 ha

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

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

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-16 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/1239 --- 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-2808) Rework / Extend the StatehandleProvider

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

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-148775942 Manually merged --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this fe

[GitHub] flink pull request: Removed broken dependency to flink-spargel.

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1259#issuecomment-148775557 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-2844) Remove old web interface and default to the new one

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

[GitHub] flink pull request: [FLINK-2844][jobmanager] remove old web interf...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1246#issuecomment-148775028 Nice, 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 hav

[jira] [Updated] (FLINK-2855) Add a documentation section for Gelly library methods

2015-10-16 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2855: - Affects Version/s: 0.10 > Add a documentation section for Gelly library methods >

[jira] [Resolved] (FLINK-2855) Add a documentation section for Gelly library methods

2015-10-16 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2855. -- Resolution: Fixed > Add a documentation section for Gelly library methods >

[jira] [Updated] (FLINK-2855) Add a documentation section for Gelly library methods

2015-10-16 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2855: - Fix Version/s: 0.10 > Add a documentation section for Gelly library methods >

[GitHub] flink pull request: [FLINK-2855] [gelly] Add documentation for the...

2015-10-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1258 --- 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-2855) Add a documentation section for Gelly library methods

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

[jira] [Commented] (FLINK-2809) DataSet[Unit] doesn't work

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

[GitHub] flink pull request: [FLINK-2809] [scala-api] Added UnitTypeInfo an...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1217#issuecomment-148773959 Apparently you can sometimes get weird behavior if you confuse the two cases, because extra parenthesis are then accidentally interpreted as a call to "apply()". -

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1239#discussion_r42259842 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/state/AbstractHeapKvState.java --- @@ -0,0 +1,1

[jira] [Created] (FLINK-2864) Make State of General-Purpose Window Operators Fault-Tolerant

2015-10-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2864: --- Summary: Make State of General-Purpose Window Operators Fault-Tolerant Key: FLINK-2864 URL: https://issues.apache.org/jira/browse/FLINK-2864 Project: Flink

[jira] [Commented] (FLINK-2857) Gelly API improvements

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

[GitHub] flink pull request: [FLINK-2857] [gelly] API improvements

2015-10-16 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1263 [FLINK-2857] [gelly] API improvements This PR: - renames the mapper parameter in creation methods to `vertexInitializer`, so that its purpose is easier to understand. - add `fromTuple2DataSet`

[jira] [Closed] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2808. --- > Rework / Extend the StatehandleProvider > --- > > Ke

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

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

[jira] [Resolved] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2808. - Implemented in 479bec0b2b44315196c1f1cddeb114c79d1717db > Rework / Extend the StatehandleProvider > -

[jira] [Resolved] (FLINK-2846) Emit checkpoint barriers earlier, before drawing the state snapshot

2015-10-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2846. - Resolution: Fixed Fixed via da159ef563e934cda6f802aa5535986356760f35 > Emit checkpoint barriers e

[jira] [Closed] (FLINK-2846) Emit checkpoint barriers earlier, before drawing the state snapshot

2015-10-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2846. --- > Emit checkpoint barriers earlier, before drawing the state snapshot > --

[GitHub] flink pull request: [FLINK-2855] [gelly] Add documentation for the...

2015-10-16 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1258#issuecomment-148756149 Thanks a lot for the review @fhueske! I'll address your comments and merge :) --- If your project is set up for it, you can reply to this email and have your reply ap

[jira] [Commented] (FLINK-2855) Add a documentation section for Gelly library methods

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

[jira] [Resolved] (FLINK-2854) KafkaITCase.testOneSourceMultiplePartitions failed on Travis

2015-10-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2854. - Resolution: Duplicate Subsumed by FLINK-2863 > KafkaITCase.testOneSourceMultiplePartitions failed

[jira] [Commented] (FLINK-2854) KafkaITCase.testOneSourceMultiplePartitions failed on Travis

2015-10-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14960904#comment-14960904 ] Stephan Ewen commented on FLINK-2854: - Update: The error is in the producer, which enc

[jira] [Created] (FLINK-2863) Kafka producer does not fail in case of write failure

2015-10-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2863: --- Summary: Kafka producer does not fail in case of write failure Key: FLINK-2863 URL: https://issues.apache.org/jira/browse/FLINK-2863 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2854) KafkaITCase.testOneSourceMultiplePartitions failed on Travis

2015-10-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14960883#comment-14960883 ] Stephan Ewen commented on FLINK-2854: - Looked through the logs. One partition is missi

[jira] [Commented] (FLINK-2809) DataSet[Unit] doesn't work

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

[GitHub] flink pull request: [FLINK-2809] [scala-api] Added UnitTypeInfo an...

2015-10-16 Thread ggevay
Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/1217#issuecomment-148743631 Thanks, for reviewing it! I actually can't think of any dangers of overriding a Java method with a no-paren method, but I don't mind, I have changed them to empty-pare

[jira] [Commented] (FLINK-2809) DataSet[Unit] doesn't work

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

[GitHub] flink pull request: [FLINK-2809] [scala-api] Added UnitTypeInfo an...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1217#issuecomment-148741076 Looks mostly good, but there are a few cases where I am unsure about the Scala/Java interop. Not all methods without paremeters should translate to methods without p

[jira] [Commented] (FLINK-2809) DataSet[Unit] doesn't work

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

[GitHub] flink pull request: [FLINK-2809] [scala-api] Added UnitTypeInfo an...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1217#discussion_r42252385 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/UnitSerializer.scala --- @@ -0,0 +1,58 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-2809) DataSet[Unit] doesn't work

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

[GitHub] flink pull request: [FLINK-2809] [scala-api] Added UnitTypeInfo an...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1217#discussion_r42252297 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/UnitSerializer.scala --- @@ -0,0 +1,58 @@ +/* + * Licensed to the Apach

[GitHub] flink pull request: [FLINK-2809] [scala-api] Added UnitTypeInfo an...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1217#discussion_r42252205 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/UnitTypeInfo.scala --- @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-2809) DataSet[Unit] doesn't work

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

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1243#issuecomment-148737070 I disagree with the locking in the base class. If you look at the documenation for sources, it states how to make sure you hold the checkpoint lock when emitting the

[GitHub] flink pull request: [FLINK-2743] Add XORShfitRandom and use it in ...

2015-10-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1170#issuecomment-148736980 Looks good except for the dependencies added to `flink-core/pom.xml`. --- If your project is set up for it, you can reply to this email and have your reply appear on Git

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

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

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1243#discussion_r42250317 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledingSourceBase.java

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1243#discussion_r42249355 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSo

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1243#discussion_r42250017 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledingSourceBase.java

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1243#discussion_r42249791 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledingSourceBase.java

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1243#discussion_r42249695 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledingSourceBase.java

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1243#discussion_r42249568 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledingSourceBase.java

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[jira] [Commented] (FLINK-2725) Max/Min/Sum Aggregation of mutable types

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

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1243#discussion_r42248976 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSo

[GitHub] flink pull request: [FLINK-2743] Add XORShfitRandom and use it in ...

2015-10-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1170#discussion_r42248517 --- Diff: flink-core/pom.xml --- @@ -70,6 +74,18 @@ under the License. test + --- End diff --

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

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

[GitHub] flink pull request: [FLINK-2725] Max/Min/Sum Aggregation of mutabl...

2015-10-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1191#issuecomment-148730932 Thanks for the PR! I will merge it with the next batch. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1243#discussion_r42247633 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledingSourceBase.java

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread HilmiYildirim
Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/1243#issuecomment-148726397 Done. I hope this is ok. --- 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 h

[jira] [Commented] (FLINK-2809) DataSet[Unit] doesn't work

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

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

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

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

2015-10-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1255#issuecomment-148716888 Hi @ChengXiangLi, I had a look at your PR and I think we need to change the implementation a bit. Right now, it executes an additional job for each range partition op

[GitHub] flink pull request: [FLINK-2809] [scala-api] Added UnitTypeInfo an...

2015-10-16 Thread ggevay
Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/1217#issuecomment-148716867 Can you please merge this before the 0.10 code freeze? --- 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] [Created] (FLINK-2862) FlinkTopologyBuilder should use proper generic types

2015-10-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2862: --- Summary: FlinkTopologyBuilder should use proper generic types Key: FLINK-2862 URL: https://issues.apache.org/jira/browse/FLINK-2862 Project: Flink Issue Type:

[jira] [Created] (FLINK-2861) Fields grouping on split streams fails

2015-10-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2861: --- Summary: Fields grouping on split streams fails Key: FLINK-2861 URL: https://issues.apache.org/jira/browse/FLINK-2861 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-10-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14960455#comment-14960455 ] Flavio Pompermaier edited comment on FLINK-2763 at 10/16/15 12:34 PM: --

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2015-10-16 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14960549#comment-14960549 ] Sachin Goel commented on FLINK-2732: I realize there is no communication required betw

[jira] [Updated] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument

2015-10-16 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-2860: --- Description: The [getting started guide code example|https://ci.apache.org/projects/f

[jira] [Created] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument

2015-10-16 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2860: -- Summary: The mlr object from the FlinkML Getting Started code example uses an undefined argument Key: FLINK-2860 URL: https://issues.apache.org/jira/browse/FLINK-2860

[jira] [Comment Edited] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-10-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14955693#comment-14955693 ] Flavio Pompermaier edited comment on FLINK-2763 at 10/16/15 10:20 AM: --

[jira] [Comment Edited] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-10-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14960455#comment-14960455 ] Flavio Pompermaier edited comment on FLINK-2763 at 10/16/15 10:20 AM: --

[GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa...

2015-10-16 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1243#issuecomment-148675785 I would like to shepherd this PR. @HilmiYildirim, I do agree with your suggestion regarding the checkpoint log. Could you change that in the PR, please? Cou

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

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

[GitHub] flink pull request: [FLINK-2855] [gelly] Add documentation for the...

2015-10-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1258#issuecomment-148675045 Good to merge. Found just three minor typos that can be fixed before merging. --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (FLINK-2855) Add a documentation section for Gelly library methods

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

[jira] [Commented] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-10-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14960455#comment-14960455 ] Flavio Pompermaier commented on FLINK-2763: --- I don't know whether Stephano's pat

[jira] [Commented] (FLINK-2855) Add a documentation section for Gelly library methods

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

[GitHub] flink pull request: [FLINK-2855] [gelly] Add documentation for the...

2015-10-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1258#discussion_r42227177 --- Diff: docs/libs/gelly_guide.md --- @@ -1450,4 +1450,140 @@ env.execute +### Community Detection + + Overview +In grap

[GitHub] flink pull request: [FLINK-2855] [gelly] Add documentation for the...

2015-10-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1258#discussion_r42227091 --- Diff: docs/libs/gelly_guide.md --- @@ -1450,4 +1450,140 @@ env.execute +### Community Detection + + Overview +In grap

[jira] [Commented] (FLINK-2855) Add a documentation section for Gelly library methods

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

[GitHub] flink pull request: [FLINK-2855] [gelly] Add documentation for the...

2015-10-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1258#discussion_r42226903 --- Diff: docs/libs/gelly_guide.md --- @@ -1450,4 +1450,140 @@ env.execute +### Community Detection + + Overview +In grap

[jira] [Commented] (FLINK-2855) Add a documentation section for Gelly library methods

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

[GitHub] flink pull request: Removed broken dependency to flink-spargel.

2015-10-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1259#issuecomment-148669464 Thanks for the fix! Good to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project doe

[jira] [Commented] (FLINK-2107) Implement Hash Outer Join algorithm

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

[GitHub] flink pull request: [FLINK-2107] Add hash-based strategies for lef...

2015-10-16 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1262 [FLINK-2107] Add hash-based strategies for left and right outer joins. This PR adds hash-based execution strategies for left and right outer joins, that have the outer side as the probe side of a ha

[jira] [Created] (FLINK-2859) Add links to docs and JIRA issues in FlinkML roadmap

2015-10-16 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2859: -- Summary: Add links to docs and JIRA issues in FlinkML roadmap Key: FLINK-2859 URL: https://issues.apache.org/jira/browse/FLINK-2859 Project: Flink

[jira] [Assigned] (FLINK-2857) Gelly API improvements

2015-10-16 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-2857: Assignee: Vasia Kalavri > Gelly API improvements > -- > >

[jira] [Commented] (FLINK-2714) Port the Flink DataSet Triangle Enumeration example to the Gelly library

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

[GitHub] flink pull request: [FLINK-2714] [Gelly] Copy triangle counting lo...

2015-10-16 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1250#issuecomment-148663100 Thanks a lot for the quick update @ssaumitra! It looks good now :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (FLINK-2857) Gelly API improvements

2015-10-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14960384#comment-14960384 ] Aljoscha Krettek commented on FLINK-2857: - +1 Seems to be good :D > Gelly API imp

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

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

[GitHub] flink pull request: [FLINK-2848] [test] Apply JMH on MutableHashTa...

2015-10-16 Thread gallenvara
Github user gallenvara closed the pull request at: https://github.com/apache/flink/pull/1261 --- 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

  1   2   >