[GitHub] flink pull request: [FLINK-1553] [streaming] Reworked Kafka connec...

2015-02-24 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/433#issuecomment-75919869 Well, the code does not compile: https://travis-ci.org/apache/flink/jobs/51825098 --- If your project is set up for it, you can reply to this email and have your reply a

[GitHub] flink pull request: [FLINK-1609] FileSystem.getHomeDirectory()

2015-02-24 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/438#issuecomment-75919698 +1 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 does not have this fe

[jira] [Commented] (FLINK-1609) FileSystem doesn't expose current user's home directory

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

[jira] [Commented] (FLINK-1609) FileSystem doesn't expose current user's home directory

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

[GitHub] flink pull request: [FLINK-1609] FileSystem.getHomeDirectory()

2015-02-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/438 [FLINK-1609] FileSystem.getHomeDirectory() You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/incubator-flink filesystem_home Alternatively y

[jira] [Created] (FLINK-1609) FileSystem doesn't expose current user's home directory

2015-02-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-1609: --- Summary: FileSystem doesn't expose current user's home directory Key: FLINK-1609 URL: https://issues.apache.org/jira/browse/FLINK-1609 Project: Flink I

[jira] [Commented] (FLINK-1553) Kafka connectors rework

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

[GitHub] flink pull request: [FLINK-1553] [streaming] Reworked Kafka connec...

2015-02-24 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/433#issuecomment-75916547 LGTM at first view. Could you please update the documentation accordingly? --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-1586) Add support for iteration visualization for Streaming programs

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

[GitHub] flink pull request: [FLINK-1586] [streaming] Add support for itera...

2015-02-24 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/432#issuecomment-75916392 Looks great, Paris! Let me merge it later 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 p

[jira] [Commented] (FLINK-1568) Add failure-case tests for data exchange

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

[GitHub] flink pull request: [FLINK-1568] [FLINK-1604] [FLINK-1606] [FLINK-...

2015-02-24 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/436#discussion_r25302080 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/deployment/PartitionInfo.java --- @@ -143,7 +147,14 @@ public static PartitionInfo fromEdg

[jira] [Commented] (FLINK-1568) Add failure-case tests for data exchange

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

[GitHub] flink pull request: [FLINK-1568] [FLINK-1604] [FLINK-1606] [FLINK-...

2015-02-24 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/436#issuecomment-75861629 W000t! +1 @uce =) --- 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 t

[GitHub] flink pull request: fixed package statement

2015-02-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/437 --- 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-1580) Cleanup TaskManager initialization logic

2015-02-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335468#comment-14335468 ] Stephan Ewen commented on FLINK-1580: - Partially solved in ed8b26bf2e8dd7c187c24ad0d8f

[jira] [Resolved] (FLINK-1590) Log environment information also in YARN mode

2015-02-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1590. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen (was: Robert Metzger)

[jira] [Updated] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager

2015-02-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1608: Description: The TaskManager uses a NetUtils routine to pick a network interface that lets it talk

[jira] [Commented] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager

2015-02-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14335442#comment-14335442 ] Stephan Ewen commented on FLINK-1608: - As a safety fallback, I suggest that we allow t

[jira] [Updated] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager

2015-02-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1608: Description: The taskmanagers use a NetUtils routine to find an interface that lets them talk to th

[jira] [Created] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager

2015-02-24 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1608: --- Summary: TaskManagers may pick wrong network interface when starting before JobManager Key: FLINK-1608 URL: https://issues.apache.org/jira/browse/FLINK-1608 Project: Fl

[GitHub] flink pull request: fixed package statement

2015-02-24 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/437#issuecomment-75835795 Once build finished if successful will commit this if no one else has comment. CC @rmetzger, @aljoscha --- If your project is set up for it, you can reply to t

[GitHub] flink pull request: fixed package statement

2015-02-24 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/437#issuecomment-75836121 Sounds good. Thank you Henry. --- 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-1596) FileIOChannel introduces space in temp file name

2015-02-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1596: -- Fix Version/s: 0.9 > FileIOChannel introduces space in temp file name >

[GitHub] flink pull request: fixed package statement

2015-02-24 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/437#issuecomment-75822423 +1 LGTM How can Java compiler miss this I am confused =( My IntelliJ IDEA has a red wiggly line indicating mismatch package name. --- If your project is set

[GitHub] flink pull request: fixed package statement

2015-02-24 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/437 fixed package statement package statement was not updated after class movement also added a missing import You can merge this pull request into a Git repository by running: $ git pull https://

[jira] [Commented] (FLINK-1568) Add failure-case tests for data exchange

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

[GitHub] flink pull request: [FLINK-1568] [FLINK-1604] [FLINK-1606] [FLINK-...

2015-02-24 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/436#issuecomment-75808232 I'll address @hsaputra's comment and merge this bad boy. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

[jira] [Commented] (FLINK-1568) Add failure-case tests for data exchange

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

[GitHub] flink pull request: [FLINK-1568] [FLINK-1604] [FLINK-1606] [FLINK-...

2015-02-24 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/436#discussion_r25268693 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/deployment/PartitionInfo.java --- @@ -143,7 +147,14 @@ public static PartitionInfo fromEdge(Ex

[jira] [Commented] (FLINK-1568) Add failure-case tests for data exchange

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

[GitHub] flink pull request: [FLINK-1568] [FLINK-1604] [FLINK-1606] [FLINK-...

2015-02-24 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/436#issuecomment-75789360 +1 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 does not have this f

[jira] [Commented] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis

2015-02-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14334989#comment-14334989 ] Till Rohrmann commented on FLINK-1540: -- Have you seen this issue re-occurring? > Job

[jira] [Commented] (FLINK-1568) Add failure-case tests for data exchange

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

[GitHub] flink pull request: [FLINK-1568] [FLINK-1604] [FLINK-1606] [FLINK-...

2015-02-24 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/436 [FLINK-1568] [FLINK-1604] [FLINK-1606] [FLINK-1607] Fixes failing JobManagerFailsITCase and SimpleRecoveryITCase This PR contains fixes for the failing ```JobManagerFailsITCase``` and ```Simple

[jira] [Created] (FLINK-1607) SimpleRecoveryITCase fails spuriously on Travis

2015-02-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1607: Summary: SimpleRecoveryITCase fails spuriously on Travis Key: FLINK-1607 URL: https://issues.apache.org/jira/browse/FLINK-1607 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1606) JobManagerFailsITCase fails spuriously for the Hadoop-2.0.0-alpha build profile on Travis

2015-02-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1606: Summary: JobManagerFailsITCase fails spuriously for the Hadoop-2.0.0-alpha build profile on Travis Key: FLINK-1606 URL: https://issues.apache.org/jira/browse/FLINK-1606

[GitHub] flink pull request: [FLINK-1462] Gelly documentation

2015-02-24 Thread ktzoumas
Github user ktzoumas commented on the pull request: https://github.com/apache/flink/pull/430#issuecomment-75775383 Reads very very well. Big +1 as well --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Closed] (FLINK-1516) JobManagerFailsITCase: akka.actor.InvalidActorNameException: actor name [jobmanager] is not unique!

2015-02-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1516. Resolution: Fixed Should be fixed as part of FLINK-1499 > JobManagerFailsITCase: akka.actor.Invalid

[jira] [Assigned] (FLINK-1604) Livelock in PartitionRequestClientFactory

2015-02-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-1604: Assignee: Till Rohrmann > Livelock in PartitionRequestClientFactory > -

[jira] [Commented] (FLINK-1462) Add documentation guide for the graph API

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

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/408#issuecomment-75770438 This looks great already! We just need a few more changes: - you can add the `Triplet` type inside the gsa package. This should just be a simple wrapper around `Tuple3`.

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread balidani
Github user balidani commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r25256087 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java --- @@ -0,0 +1,232 @@ +/* +

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread balidani
Github user balidani commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r25255250 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java --- @@ -0,0 +1,232 @@ +/* +

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r25255528 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java --- @@ -0,0 +1,232 @@ +/* + *

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread balidani
Github user balidani commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r25255193 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java --- @@ -0,0 +1,232 @@ +/* +

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread balidani
Github user balidani commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r25255094 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java --- @@ -0,0 +1,232 @@ +/* +

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r25255045 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java --- @@ -0,0 +1,232 @@ +/* + *

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r25254768 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java --- @@ -0,0 +1,232 @@ +/* + *

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r25254691 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java --- @@ -0,0 +1,232 @@ +/* + *

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r25254212 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java --- @@ -0,0 +1,232 @@ +/* + *

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[jira] [Commented] (FLINK-1519) Web frontend task state mismatch when cancelling

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

[GitHub] flink pull request: [FLINK-1519] Added canceling state to web inte...

2015-02-24 Thread qmlmoon
GitHub user qmlmoon opened a pull request: https://github.com/apache/flink/pull/435 [FLINK-1519] Added canceling state to web interface ![qq20150224-1](https://cloud.githubusercontent.com/assets/5807102/6350681/6455be72-bc36-11e4-8747-1d77604ee64b.jpg) You can merge this pull requ

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-24 Thread balidani
Github user balidani commented on the pull request: https://github.com/apache/flink/pull/408#issuecomment-75755326 Hi @vasia, all! So I implemented the changes that @vasia suggested. I also added a commit that adds the Hadoop profiles to the `flink-gelly` project in `pom.xml`,

[jira] [Created] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts

2015-02-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1605: - Summary: Create a shaded Hadoop fat jar to resolve library version conflicts Key: FLINK-1605 URL: https://issues.apache.org/jira/browse/FLINK-1605 Project: Flink

[jira] [Commented] (FLINK-1555) Add utility to log the serializers of composite types

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

[GitHub] flink pull request: [FLINK-1555] Add serializer hierarchy debug ut...

2015-02-24 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/415#issuecomment-75753097 I've updated the PR to also print out the fields of GenericTypes. I'm thinking to merge this in the next 24 hours. --- If your project is set up for it, you can

[jira] [Assigned] (FLINK-1519) Web frontend task state mismatch when cancelling

2015-02-24 Thread Mingliang Qi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Qi reassigned FLINK-1519: --- Assignee: Mingliang Qi > Web frontend task state mismatch when cancelling > -

[jira] [Resolved] (FLINK-1600) Failure when submitting a job leaves user code libraries in the BLOB manager

2015-02-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1600. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen Fixed via 9ddb565314a4

[jira] [Resolved] (FLINK-1598) Give better error messages when serializers run out of space.

2015-02-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1598. - Resolution: Fixed Fixed via 9528a521f56e0c6b0c70d43e62ad84b19c048c36 > Give better error messages

[jira] [Commented] (FLINK-1596) FileIOChannel introduces space in temp file name

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

[GitHub] flink pull request: [FLINK-1596] remove space in filename

2015-02-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/431 --- 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] [Resolved] (FLINK-1596) FileIOChannel introduces space in temp file name

2015-02-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1596. - Resolution: Fixed Fixed in 0.9 in 98bc7b951b30961871958a4483e0b186bfb785b8 > FileIOChannel introd

[jira] [Commented] (FLINK-1603) Update how to contribute doc to include information to send Github PR instead of attaching patch

2015-02-24 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14334756#comment-14334756 ] Max Michels commented on FLINK-1603: +1 We should also mention that pull requests can

[jira] [Commented] (FLINK-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory

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

[GitHub] flink pull request: [FLINK-1542] Test case at BlobUtilsTest should...

2015-02-24 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/396#issuecomment-75733680 You can do `:+1:` on GitHub. :neckbeard: http://www.emoji-cheat-sheet.com/ --- If your project is set up for it, you can reply to this email and have your reply appea

[jira] [Updated] (FLINK-1604) Livelock in PartitionRequestClientFactory

2015-02-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1604: - Description: In case of a job restart, we observed a livelock in {{PartitionRequestClientFactory.

[jira] [Created] (FLINK-1604) Livelock in PartitionRequestClientFactory

2015-02-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1604: Summary: Livelock in PartitionRequestClientFactory Key: FLINK-1604 URL: https://issues.apache.org/jira/browse/FLINK-1604 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn

2015-02-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1414: - Assignee: Robert Metzger > Remove quickstart-*.sh from git source and put them to the web

[jira] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-02-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14334722#comment-14334722 ] Robert Metzger commented on FLINK-1602: --- Yes, I think its a good idea to link the la

[jira] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-02-24 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14334719#comment-14334719 ] Henry Saputra commented on FLINK-1602: -- Yeah, that is definitely better idea. Maybe m

[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO...

2015-02-24 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/426#discussion_r25237861 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java --- @@ -235,8 +252,21 @@ public OUT readRecord(OUT reuse, byte[] bytes, in

[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO...

2015-02-24 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/426#discussion_r25237152 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java --- @@ -82,6 +92,13 @@ public CsvInputFormat(Path filePath, String lineDe

[jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs.

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

[GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO...

2015-02-24 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/426#discussion_r25237140 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java --- @@ -64,15 +65,24 @@ private transient int commentCount;

[jira] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

2015-02-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14334690#comment-14334690 ] Robert Metzger commented on FLINK-1602: --- How about removing the links to the 0.6-inc

[jira] [Commented] (FLINK-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory

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

[GitHub] flink pull request: [FLINK-1542] Test case at BlobUtilsTest should...

2015-02-24 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/396#issuecomment-75717171 @uce , just realized how did you render the thumbs up icon? Looks cool =) --- If your project is set up for it, you can reply to this email and have your reply appear on