[GitHub] flink pull request: Mesos integration of Apache Flink

2015-03-26 Thread adam-mesos
Github user adam-mesos commented on a diff in the pull request: https://github.com/apache/flink/pull/251#discussion_r27275396 --- Diff: flink-addons/flink-mesos/src/main/java/org/apache/flink/mesos/Executors/FlinkExecutor.java --- @@ -0,0 +1,97 @@ +/** + * Licensed to the

[jira] [Assigned] (FLINK-1758) Extend Gelly's neighborhood methods

2015-03-26 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu reassigned FLINK-1758: -- Assignee: Andra Lungu > Extend Gelly's neighborhood methods > -

[jira] [Resolved] (FLINK-1726) Add Community Detection Library and Example

2015-03-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-1726. -- Resolution: Implemented Fix Version/s: 0.9 > Add Community Detection Library and Example

[jira] [Commented] (FLINK-1726) Add Community Detection Library and Example

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

[GitHub] flink pull request: [FLINK-1726][gelly] Added Community Detection ...

2015-03-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/505 --- 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 enabl

[jira] [Commented] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library

2015-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382795#comment-14382795 ] ASF GitHub Bot commented on FLINK-1718: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-1718] Adds sparse matrix and sparse vec...

2015-03-26 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/539#discussion_r27261446 --- Diff: flink-staging/flink-ml/pom.xml --- @@ -46,9 +46,9 @@ - com.github.fommil.netlib

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-03-26 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/537#issuecomment-86727594 Hey @andralungu! Thanks for this PR. I know it took more effort than you might have thought initially :-) I have a few comments: - In my opinion, the degrees ava

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

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

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382697#comment-14382697 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-03-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/537#discussion_r27257390 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexUpdateFunction.java --- @@ -40,7 +41,22 @@ VertexValue extends Se

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382691#comment-14382691 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-03-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/537#discussion_r27256989 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java --- @@ -38,11 +41,41 @@ * @param The type of the

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-03-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/537#discussion_r27256784 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/LabelPropagation.java --- @@ -68,12 +70,12 @@ public LabelPropagation(int maxIt

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382687#comment-14382687 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382684#comment-14382684 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-03-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/537#discussion_r27256701 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/LabelPropagation.java --- @@ -68,12 +70,12 @@ public LabelPropagation(int maxIt

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382680#comment-14382680 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-03-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/537#discussion_r27256440 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -1141,8 +1185,33 @@ public boolean filter(Edge edge) { */

[jira] [Commented] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library

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

[GitHub] flink pull request: [FLINK-1718] Adds sparse matrix and sparse vec...

2015-03-26 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/539#discussion_r27256008 --- Diff: flink-staging/flink-ml/pom.xml --- @@ -46,9 +46,9 @@ - com.github.fommil.netlib ---

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-03-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/537#discussion_r27255825 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -1118,17 +1118,61 @@ public boolean filter(Edge edge) { }

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-03-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382664#comment-14382664 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-1790) Remove the redundant import code

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

[GitHub] flink pull request: [FLINK-1790]Remove the redundant import code

2015-03-26 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/538#issuecomment-86716110 +1 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

[GitHub] flink pull request: Flink dev cluster on Docker with Docker Compos...

2015-03-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/533#issuecomment-86709259 I flattened the history & added rat exclusions in https://github.com/rmetzger/flink/tree/flink_docker_2 Here is the travis build: https://travis-ci.org/rmetzger/flink

[jira] [Commented] (FLINK-1694) Change the split between create/run of a vertex-centric iteration

2015-03-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382620#comment-14382620 ] Vasia Kalavri commented on FLINK-1694: -- Thanks for the input guys! [~balidani] right

[GitHub] flink pull request: [Flink-1686] Streaming Iterations Slot Sharing...

2015-03-26 Thread senorcarbone
Github user senorcarbone closed the pull request at: https://github.com/apache/flink/pull/524 --- 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

[GitHub] flink pull request: [Flink-1686] Streaming Iterations Slot Sharing...

2015-03-26 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/524#issuecomment-86675840 Looks good to me, lets merge this :+1: --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Resolved] (FLINK-1785) Master tests in flink-tachyon fail with java.lang.NoSuchFieldError: IBM_JAVA

2015-03-26 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra resolved FLINK-1785. -- Resolution: Fixed Fix Version/s: master merged to master > Master tests in flink-tachyon

[jira] [Commented] (FLINK-1785) Master tests in flink-tachyon fail with java.lang.NoSuchFieldError: IBM_JAVA

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

[GitHub] flink pull request: [FLINK-1785] [test] Master tests in flink-tach...

2015-03-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/536 --- 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 enabl

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

2015-03-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382291#comment-14382291 ] Stephan Ewen commented on FLINK-1789: - I think that is a great idea. We can even use t

[jira] [Commented] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom

2015-03-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382294#comment-14382294 ] Stephan Ewen commented on FLINK-1783: - It does not affect one, it only causes maven to

[jira] [Commented] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom

2015-03-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382295#comment-14382295 ] Stephan Ewen commented on FLINK-1783: - Even though they were identical in the end...

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

2015-03-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382288#comment-14382288 ] Timo Walther commented on FLINK-1319: - Sorry, I was a little bit confused yesterday be

[jira] [Commented] (FLINK-1782) Change Quickstart Java version to 1.7

2015-03-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382276#comment-14382276 ] Stephan Ewen commented on FLINK-1782: - I'll take a quick stab at fixing the quickstart

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

2015-03-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382269#comment-14382269 ] Stephan Ewen commented on FLINK-1319: - I think there is no reason they are not availab

[jira] [Commented] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library

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

[GitHub] flink pull request: [FLINK-1718] Adds sparse matrix and sparse vec...

2015-03-26 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/539 [FLINK-1718] Adds sparse matrix and sparse vector Adds a sparse matrix abstraction using CSC data representation. Adds a sparse vector abstraction using CSC data representation. Adds co

[jira] [Closed] (FLINK-1791) Change nightly Javadoc build to use correct profile

2015-03-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-1791. - Resolution: Fixed Changed the Buildbot configuration for the nightly doc builds. https://

[jira] [Assigned] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library

2015-03-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-1718: Assignee: Till Rohrmann > Add sparse vector and sparse matrix types to machine learning lib

[jira] [Updated] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library

2015-03-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1718: - Description: Currently, the machine learning library only supports dense matrix and dense vectors

[jira] [Created] (FLINK-1791) Change nightly Javadoc build to use correct profile

2015-03-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1791: --- Summary: Change nightly Javadoc build to use correct profile Key: FLINK-1791 URL: https://issues.apache.org/jira/browse/FLINK-1791 Project: Flink Issue

[jira] [Updated] (FLINK-1791) Change nightly Javadoc build to use correct profile

2015-03-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1791: Assignee: Maximilian Michels > Change nightly Javadoc build to use correct profile > ---

[jira] [Resolved] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

2015-03-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1769. - Resolution: Fixed Fixed in https://github.com/apache/flink/commit/2d373d88a733a71dcba21e6

[jira] [Commented] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

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

[GitHub] flink pull request: [FLINK-1769] Fix deploy bug caused by ScalaDoc...

2015-03-26 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/535 --- 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 ena

[jira] [Updated] (FLINK-1790) Remove the redundant import code

2015-03-26 Thread Sibao Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1790: -- Summary: Remove the redundant import code (was: d) > Remove the redundant import code > ---

[jira] [Updated] (FLINK-1790) d

2015-03-26 Thread Sibao Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1790: -- Summary: d (was: Remove the redunant import code) > d > - > > Key: FLINK-1790 >

[jira] [Updated] (FLINK-1790) d

2015-03-26 Thread Sibao Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sibao Hong updated FLINK-1790: -- Description: Remove the redundant import code (was: Remove the redunant import code) > d > - > >

[jira] [Created] (FLINK-1790) Remove the redunant import code

2015-03-26 Thread Sibao Hong (JIRA)
Sibao Hong created FLINK-1790: - Summary: Remove the redunant import code Key: FLINK-1790 URL: https://issues.apache.org/jira/browse/FLINK-1790 Project: Flink Issue Type: Improvement Com

[GitHub] flink pull request: [FLINK]Remove the redunant import code

2015-03-26 Thread matadorhong
GitHub user matadorhong opened a pull request: https://github.com/apache/flink/pull/538 [FLINK]Remove the redunant import code You can merge this pull request into a Git repository by running: $ git pull https://github.com/matadorhong/flink RemoveRedundantImport Alternatively

[jira] [Closed] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

2015-03-26 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1775. - Resolution: Fixed > BarrierBuffers don't correctly handle end of stream events > -

[jira] [Closed] (FLINK-1772) Chain of split/select does not work

2015-03-26 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1772. - Resolution: Not a Problem > Chain of split/select does not work > --- > >

[jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

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

[GitHub] flink pull request: [FLINK-1775] BarrierBuffer fix to avoid end of...

2015-03-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/534 --- 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 enabl

[jira] [Commented] (FLINK-1560) Add ITCases for streaming examples

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

[GitHub] flink pull request: FLINK-1560 - Add ITCases for streaming example...

2015-03-26 Thread szape
Github user szape commented on the pull request: https://github.com/apache/flink/pull/519#issuecomment-86582509 It runs just fine on my computer. Did you pull the latest state of the branch? The TwitterStreamData class was updated not so long ago. Also, the IterateExample isn't run

[GitHub] flink pull request: [FLINK-1785] [test] Master tests in flink-tach...

2015-03-26 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/536#issuecomment-86574250 Cool, thanks @rmetzger. Will merge it today. --- 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 proj

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

2015-03-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382048#comment-14382048 ] Timo Walther commented on FLINK-1789: - Unfortunately that's not an option for our rese

[GitHub] flink pull request: FLINK-1560 - Add ITCases for streaming example...

2015-03-26 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/519#issuecomment-86569586 @szape: I've started merging this: The TwitterStreamITCase seems to fail spuriously. Could you look into it? --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-1785) Master tests in flink-tachyon fail with java.lang.NoSuchFieldError: IBM_JAVA

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

[jira] [Commented] (FLINK-1560) Add ITCases for streaming examples

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

[jira] [Commented] (FLINK-1560) Add ITCases for streaming examples

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

[GitHub] flink pull request: FLINK-1560 - Add ITCases for streaming example...

2015-03-26 Thread szape
Github user szape commented on the pull request: https://github.com/apache/flink/pull/519#issuecomment-86565008 I tried to fix issue FLINK-1662, that is related to IterateExample. Gyula, what do you think? To see the actual bug, run IterateExample with parallelism 1 without the la

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

2015-03-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14382015#comment-14382015 ] Robert Metzger commented on FLINK-1789: --- You can just add the path to the regular J

[jira] [Resolved] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

2015-03-26 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1773. --- Resolution: Implemented https://github.com/apache/flink/pull/523 > Add interface for grouped policies

[jira] [Created] (FLINK-1789) Allow adding of URLs to the usercode class loader

2015-03-26 Thread Timo Walther (JIRA)
Timo Walther created FLINK-1789: --- Summary: Allow adding of URLs to the usercode class loader Key: FLINK-1789 URL: https://issues.apache.org/jira/browse/FLINK-1789 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

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

[GitHub] flink pull request: [FLINK-1775] BarrierBuffer fix to avoid end of...

2015-03-26 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/534#issuecomment-86555612 Ok I will add that one --- 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

[jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

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

[GitHub] flink pull request: [FLINK-1775] BarrierBuffer fix to avoid end of...

2015-03-26 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/534#issuecomment-86554956 I think we need to refactor some parts, but this is a crucial fix. Tests are passing. +1 to merge after throwing the Exception Robert mentioned. --- If your project

[jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

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

[GitHub] flink pull request: [FLINK-1775] BarrierBuffer fix to avoid end of...

2015-03-26 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/534#issuecomment-86554780 Now it seems that all these issues are fixed. --- 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 projec

[GitHub] flink pull request: Introduced CentralActiveTrigger with GroupedAc...

2015-03-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/523 --- 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 enabl

[jira] [Commented] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface

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

[GitHub] flink pull request: [FLINK-1501] Add metrics library for monitorin...

2015-03-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/421#issuecomment-86517135 I rebased the code to the current master in the branch "flink1501-rebased" in my github (https://github.com/rmetzger/flink/tree/flink1501-rebased). As soon as the test

[jira] [Commented] (FLINK-1694) Change the split between create/run of a vertex-centric iteration

2015-03-26 Thread Daniel Bali (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14381818#comment-14381818 ] Daniel Bali commented on FLINK-1694: I agree with a configuration object. There aren't

[jira] [Assigned] (FLINK-1788) Extend Table API to allow logical plan optimisations

2015-03-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1788: --- Assignee: Aljoscha Krettek > Extend Table API to allow logical plan optimisations > -

[jira] [Created] (FLINK-1788) Extend Table API to allow logical plan optimisations

2015-03-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1788: --- Summary: Extend Table API to allow logical plan optimisations Key: FLINK-1788 URL: https://issues.apache.org/jira/browse/FLINK-1788 Project: Flink Issu

[jira] [Resolved] (FLINK-1755) NullPointerException in LocalInputChannel.getNextLookAhead()

2015-03-26 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1755. Resolution: Fixed Fix Version/s: 0.9 Fixed in 0b86903. > NullPointerException in LocalInputC

[jira] [Commented] (FLINK-1726) Add Community Detection Library and Example

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

[jira] [Commented] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

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

[GitHub] flink pull request: [FLINK-1769] Fix deploy bug caused by ScalaDoc...

2015-03-26 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/535#issuecomment-86449530 +1 for merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] flink pull request: [FLINK-1726][gelly] Added Community Detection ...

2015-03-26 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/505#issuecomment-86449745 Thank you @andralungu! Will merge later. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface

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

[GitHub] flink pull request: [FLINK-1501] Add metrics library for monitorin...

2015-03-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/421#issuecomment-86440012 No, there are no objections. I'll rebase this pull request to the current master and merge it later today. I think the next steps are: - Get the CPU utili

[jira] [Closed] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

2015-03-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1787. - Resolution: Duplicate > Remove commons Validate calls with Guava checkArgument() calls. >

[jira] [Commented] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

2015-03-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14381645#comment-14381645 ] Robert Metzger commented on FLINK-1787: --- oh, you are right. I'll close this one agai

[jira] [Commented] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

2015-03-26 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14381642#comment-14381642 ] Chiwan Park commented on FLINK-1787: I think that this issue is duplicated with FLINK-

[jira] [Updated] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

2015-03-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1787: -- Issue Type: Task (was: Bug) > Remove commons Validate calls with Guava checkArgument() calls. >

[jira] [Created] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

2015-03-26 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1787: - Summary: Remove commons Validate calls with Guava checkArgument() calls. Key: FLINK-1787 URL: https://issues.apache.org/jira/browse/FLINK-1787 Project: Flink

[jira] [Commented] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface

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

[GitHub] flink pull request: [FLINK-1501] Add metrics library for monitorin...

2015-03-26 Thread bhatsachin
Github user bhatsachin commented on the pull request: https://github.com/apache/flink/pull/421#issuecomment-86423248 Hey Robert, could you please enlist the further monitoring enhancements required for this pull request and are there any objections to the merge? --- If your project i

[jira] [Commented] (FLINK-1785) Master tests in flink-tachyon fail with java.lang.NoSuchFieldError: IBM_JAVA

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

[GitHub] flink pull request: [FLINK-1785] [test] Master tests in flink-tach...

2015-03-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/536#issuecomment-86420816 The travis build passed, so +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 your project d

[jira] [Created] (FLINK-1786) Add support for pipelined programs with slot count exceeding parallelism

2015-03-26 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1786: -- Summary: Add support for pipelined programs with slot count exceeding parallelism Key: FLINK-1786 URL: https://issues.apache.org/jira/browse/FLINK-1786 Project: Flink

[jira] [Commented] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

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

[GitHub] flink pull request: [FLINK-1769] Fix deploy bug caused by ScalaDoc...

2015-03-26 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/535#issuecomment-86416475 I just wanted to leave it sitting here for a while. But if no-one has any reservations I'll merge it today. --- If your project is set up for it, you can reply to this e

  1   2   >