[jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

2015-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14340151#comment-14340151 ] ASF GitHub Bot commented on FLINK-1587: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1219] Add support for Apache Tez as exe...

2015-02-27 Thread ktzoumas
Github user ktzoumas commented on the pull request: https://github.com/apache/flink/pull/189#issuecomment-76407035 I tested this on a 25-node cluster with WordCount and the modified TPC-H query on generated TPC-H data of scale 1000. I also added docs. --- If your project is set up

[GitHub] flink pull request: [FLINK-1615] [java api] SimpleTweetInputFormat

2015-02-27 Thread Elbehery
GitHub user Elbehery opened a pull request: https://github.com/apache/flink/pull/442 [FLINK-1615] [java api] SimpleTweetInputFormat This is a contribution with a TweetInputFormat, Jira [FLINK-1615](https://issues.apache.org/jira/browse/FLINK-1615). This commit contains,

[GitHub] flink pull request: [FLINK-1528][Gelly] Added Local Clustering Coe...

2015-02-27 Thread balidani
Github user balidani commented on the pull request: https://github.com/apache/flink/pull/420#issuecomment-76391973 I made the changes @vasia suggested --- 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

[GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for...

2015-02-27 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/440#issuecomment-76399944 Thanks for the revision @andralungu! Looks 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

[jira] [Commented] (FLINK-1610) Java docs do not build

2015-02-27 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14340093#comment-14340093 ] Max Michels commented on FLINK-1610: Seems to be a Java 8 related issue. It builds

[jira] [Created] (FLINK-1616) Action list -r gives IOException when there are running jobs

2015-02-27 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1616: Summary: Action list -r gives IOException when there are running jobs Key: FLINK-1616 URL: https://issues.apache.org/jira/browse/FLINK-1616 Project: Flink

[jira] [Commented] (FLINK-1219) Add support for Apache Tez as execution engine

2015-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14340225#comment-14340225 ] ASF GitHub Bot commented on FLINK-1219: --- Github user ktzoumas commented on the pull

[GitHub] flink pull request: [FLINK-1219] Add support for Apache Tez as exe...

2015-02-27 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/189#discussion_r25512682 --- Diff: flink-staging/flink-tez/src/main/java/org/apache/flink/tez/client/RemoteTezEnvironment.java --- @@ -0,0 +1,79 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-1219] Add support for Apache Tez as exe...

2015-02-27 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/189#discussion_r25512719 --- Diff: flink-staging/flink-tez/src/main/java/org/apache/flink/tez/client/RemoteTezEnvironment.java --- @@ -0,0 +1,79 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1219) Add support for Apache Tez as execution engine

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

[jira] [Commented] (FLINK-1219) Add support for Apache Tez as execution engine

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

[GitHub] flink pull request: Implement the convenience methods count and co...

2015-02-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/210 --- 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-1613) Cannost submit to remote ExecutionEnvironment from IDE

2015-02-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14339918#comment-14339918 ] Robert Metzger commented on FLINK-1613: --- How about removing the

[jira] [Created] (FLINK-1615) Introduces a new InputFormat for Tweets

2015-02-27 Thread mustafa elbehery (JIRA)
mustafa elbehery created FLINK-1615: --- Summary: Introduces a new InputFormat for Tweets Key: FLINK-1615 URL: https://issues.apache.org/jira/browse/FLINK-1615 Project: Flink Issue Type: New

[GitHub] flink pull request: [FLINK-1522][FLINK-1576] Updated LabelPropagat...

2015-02-27 Thread balidani
GitHub user balidani opened a pull request: https://github.com/apache/flink/pull/441 [FLINK-1522][FLINK-1576] Updated LabelPropagationExample and test Hi! I converted the Label Propagation example to the conventional format, where the main program takes (optional)

[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples

2015-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14340005#comment-14340005 ] ASF GitHub Bot commented on FLINK-1522: --- GitHub user balidani opened a pull request:

[GitHub] flink pull request: Fix typos in iterations.md file

2015-02-27 Thread hsaputra
GitHub user hsaputra opened a pull request: https://github.com/apache/flink/pull/443 Fix typos in iterations.md file -) Remove extra solution word. -) Change propagete to propagate. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (FLINK-1614) JM Webfrontend doesn't always show the correct state of Tasks

2015-02-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1614: - Summary: JM Webfrontend doesn't always show the correct state of Tasks Key: FLINK-1614 URL: https://issues.apache.org/jira/browse/FLINK-1614 Project: Flink

[GitHub] flink pull request: Implement the convenience methods count and co...

2015-02-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/210#issuecomment-76385275 I moved the `writeInto(ByteBuf buf)` method to the subclasses of `AbstractID` used by `NettyMessage`. This is the only context where the method is being used and the