[jira] [Commented] (FLINK-1330) Restructure directory layout

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

[GitHub] flink pull request: [FLINK-1389] Allow changing the filenames of t...

2015-01-25 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/301#issuecomment-71366256 The only reason why I added the two variants is that I want to give users freedom to choose between these two variants. Its one more line of code that might (someday)

[jira] [Commented] (FLINK-1389) Allow setting custom file extensions for files created by the FileOutputFormat

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

[GitHub] flink pull request: [FLINK-1330] [build] Build creates a link in t...

2015-01-25 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/333#issuecomment-71366786 This looks good. --- 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

[GitHub] flink pull request: [FLINK-1389] Allow changing the filenames of t...

2015-01-25 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/301#issuecomment-71366397 To be honest, I find this additional option more confusing than helpful. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request: [FLINK-1434] [FLINK-1401] Streaming support ad...

2015-01-25 Thread gyfora
Github user gyfora commented on a diff in the pull request: https://github.com/apache/flink/pull/334#discussion_r23503616 --- Diff: flink-addons/flink-streaming/flink-streaming-core/pom.xml --- @@ -48,6 +48,12 @@ under the License.

[jira] [Commented] (FLINK-1434) Web interface cannot be used to run streaming programs

2015-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291047#comment-14291047 ] ASF GitHub Bot commented on FLINK-1434: --- Github user gyfora commented on a diff in

[GitHub] flink pull request: [FLINK-1434] [FLINK-1401] Streaming support ad...

2015-01-25 Thread gyfora
Github user gyfora commented on a diff in the pull request: https://github.com/apache/flink/pull/334#discussion_r23503611 --- Diff: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamGraph.java --- @@ -536,4 +549,79 @@ public long

[jira] [Commented] (FLINK-1389) Allow setting custom file extensions for files created by the FileOutputFormat

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

[GitHub] flink pull request: [FLINK-1434] [FLINK-1401] Streaming support ad...

2015-01-25 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/334#discussion_r23503538 --- Diff: flink-addons/flink-streaming/flink-streaming-core/pom.xml --- @@ -48,6 +48,12 @@ under the License.

[jira] [Commented] (FLINK-1434) Web interface cannot be used to run streaming programs

2015-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291048#comment-14291048 ] ASF GitHub Bot commented on FLINK-1434: --- Github user gyfora commented on a diff in

[GitHub] flink pull request: [FLINK-1434] [FLINK-1401] Streaming support ad...

2015-01-25 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/334#discussion_r23503540 --- Diff: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamGraph.java --- @@ -536,4 +549,79 @@ public

[jira] [Commented] (FLINK-1434) Web interface cannot be used to run streaming programs

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

[jira] [Commented] (FLINK-1441) Documentation SVN checkout link is wrong

2015-01-25 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291044#comment-14291044 ] Max Michels commented on FLINK-1441: Thank you, we will merge this as soon as

[jira] [Commented] (FLINK-629) Add support for null values to the java api

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291060#comment-14291060 ] Robert Metzger commented on FLINK-629: -- Cool. I'm glad its working. I'll push the fix

[GitHub] flink pull request: [FLINK-1381] Allow multiple output splitters f...

2015-01-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/332 --- 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-1381) Only one output splitter supported per operator

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

[jira] [Commented] (FLINK-1448) Documentation Clone your repository Link is wrong

2015-01-25 Thread Rahul Mahindrakar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291142#comment-14291142 ] Rahul Mahindrakar commented on FLINK-1448: -- Wow you fixed all of them! Great.

[jira] [Commented] (FLINK-1433) Add HADOOP_CLASSPATH to start scripts

2015-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291154#comment-14291154 ] ASF GitHub Bot commented on FLINK-1433: --- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-1433] Add HADOOP_CLASSPATH to start scr...

2015-01-25 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/337#issuecomment-71378388 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

[jira] [Commented] (FLINK-1447) Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser

2015-01-25 Thread Rahul Mahindrakar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291075#comment-14291075 ] Rahul Mahindrakar commented on FLINK-1447: -- See these errors. Need to

[jira] [Closed] (FLINK-1409) Connected datastream functionality broken since the introduction of intermediate results

2015-01-25 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1409. - Resolution: Fixed Connected datastream functionality broken since the introduction of intermediate

[jira] [Closed] (FLINK-1449) Extend Streaming guide to include the Scala API

2015-01-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1449. - Resolution: Duplicate This is a duplicate of FlINK-1429. Extend Streaming guide to include the

[jira] [Assigned] (FLINK-1431) Add news mailing list to website

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1431: - Assignee: Robert Metzger Add news mailing list to website

[jira] [Assigned] (FLINK-1446) Make KryoSerializer.createInstance() return new instances instead of null

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1446: - Assignee: Robert Metzger Make KryoSerializer.createInstance() return new instances

[jira] [Commented] (FLINK-1447) Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291217#comment-14291217 ] Robert Metzger commented on FLINK-1447: --- Cool, thank you for taking a closer look

[jira] [Commented] (FLINK-1446) Make KryoSerializer.createInstance() return new instances instead of null

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

[GitHub] flink pull request: [FLINK-1446] Fix Kryo createInstance() method

2015-01-25 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/336#issuecomment-71416590 +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 does not have this feature

[GitHub] flink pull request: [FLINK-1433] Add HADOOP_CLASSPATH to start scr...

2015-01-25 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/337#issuecomment-71412124 Does this mean that we now have multiple hadoop dependencies in the class path? The ones that are part of the Flink lib directory, plus the ones in the

[jira] [Commented] (FLINK-1433) Add HADOOP_CLASSPATH to start scripts

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

[GitHub] flink pull request: [FLINK-1376] [runtime] Add proper shared slot ...

2015-01-25 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/317#issuecomment-71423347 I am looking into this right now and testing it locally. Seems to work so far. Will try to give a vote by tomorrow... --- If your project is set up for it, you can

[jira] [Commented] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

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

[jira] [Commented] (FLINK-1447) Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291065#comment-14291065 ] Robert Metzger commented on FLINK-1447: --- On the Ubuntu Firefox browser, can you

[jira] [Commented] (FLINK-1434) Web interface cannot be used to run streaming programs

2015-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291102#comment-14291102 ] ASF GitHub Bot commented on FLINK-1434: --- Github user mbalassi commented on the pull

[jira] [Updated] (FLINK-1441) Documentation SVN checkout link is wrong

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1441: -- Assignee: Rahul Mahindrakar Documentation SVN checkout link is wrong

[jira] [Commented] (FLINK-1441) Documentation SVN checkout link is wrong

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291117#comment-14291117 ] Robert Metzger commented on FLINK-1441: --- Hi Rahul, thank you for the patch. I'll

[jira] [Commented] (FLINK-1201) Graph API for Flink

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

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons (...

2015-01-25 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/335#issuecomment-71376640 Thank you. Looks good. History is preserved and you addressed my comments. +1 for merging it. --- If your project is set up for it, you can reply to this

[jira] [Resolved] (FLINK-1431) Add news mailing list to website

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1431. --- Resolution: Fixed Resolved in http://svn.apache.org/r1654662 Add news mailing list to

[jira] [Commented] (FLINK-1428) Typos in Java code example for RichGroupReduceFunction

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291132#comment-14291132 ] Robert Metzger commented on FLINK-1428: --- Would be cool if you could provide a patch

[jira] [Updated] (FLINK-1447) Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser

2015-01-25 Thread Rahul Mahindrakar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rahul Mahindrakar updated FLINK-1447: - Attachment: Capture.PNG I cannot see this with my Ubuntu 14.04 firefox browser. This is

[jira] [Created] (FLINK-1450) Add Fold operator to the Streaming api

2015-01-25 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1450: - Summary: Add Fold operator to the Streaming api Key: FLINK-1450 URL: https://issues.apache.org/jira/browse/FLINK-1450 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-532) (Chained Map) Tasks simply keep in state Running

2015-01-25 Thread Mathias Peters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291114#comment-14291114 ] Mathias Peters commented on FLINK-532: -- I did not encounter this issue anymore in

[jira] [Closed] (FLINK-532) (Chained Map) Tasks simply keep in state Running

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-532. Resolution: Won't Fix Thank you. I'm closing the issue. (Chained Map) Tasks simply keep in state

[jira] [Created] (FLINK-1446) Make KryoSerializer.createInstance() return new instances instead of null

2015-01-25 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1446: - Summary: Make KryoSerializer.createInstance() return new instances instead of null Key: FLINK-1446 URL: https://issues.apache.org/jira/browse/FLINK-1446 Project:

[jira] [Created] (FLINK-1448) Documentation Clone your repository Link is wrong

2015-01-25 Thread Rahul Mahindrakar (JIRA)
Rahul Mahindrakar created FLINK-1448: Summary: Documentation Clone your repository Link is wrong Key: FLINK-1448 URL: https://issues.apache.org/jira/browse/FLINK-1448 Project: Flink

[jira] [Created] (FLINK-1449) Extend Streaming guide to include the Scala API

2015-01-25 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1449: - Summary: Extend Streaming guide to include the Scala API Key: FLINK-1449 URL: https://issues.apache.org/jira/browse/FLINK-1449 Project: Flink Issue Type: Task

[GitHub] flink pull request: Add flink-gelly to flink-addons (with commit h...

2015-01-25 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/335 Add flink-gelly to flink-addons (with commit history) Hi everyone, here's the new PR for the graph api. I have addressed the comments of #326 and looking forward to additional feedback!

[GitHub] flink pull request: [FLINK-1446] Fix Kryo createInstance() method

2015-01-25 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/336 [FLINK-1446] Fix Kryo createInstance() method You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink FLINK-1446 Alternatively you can

[jira] [Commented] (FLINK-1441) Documentation SVN checkout link is wrong

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291118#comment-14291118 ] Robert Metzger commented on FLINK-1441: --- Merged in http://svn.apache.org/r1654660

[jira] [Commented] (FLINK-1433) Add HADOOP_CLASSPATH to start scripts

2015-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291127#comment-14291127 ] ASF GitHub Bot commented on FLINK-1433: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-1433] Add HADOOP_CLASSPATH to start scr...

2015-01-25 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/337 [FLINK-1433] Add HADOOP_CLASSPATH to start scripts You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink FLINK-1433 Alternatively you

[jira] [Commented] (FLINK-1424) bin/flink run does not recognize -c parameter anymore

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

[GitHub] flink pull request: [Flink-1436] refactor CLiFrontend to provide m...

2015-01-25 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/331#issuecomment-71376859 @mxm: Since you have some experience with the CliFrontend now, would you mind looking into https://issues.apache.org/jira/browse/FLINK-1424 as well? --- If your project

[jira] [Resolved] (FLINK-1448) Documentation Clone your repository Link is wrong

2015-01-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1448. --- Resolution: Fixed Assignee: Robert Metzger Resovled in http://svn.apache.org/r1654661

[jira] [Created] (FLINK-1451) Enable parallel execution of streaming file sources

2015-01-25 Thread JIRA
Márton Balassi created FLINK-1451: - Summary: Enable parallel execution of streaming file sources Key: FLINK-1451 URL: https://issues.apache.org/jira/browse/FLINK-1451 Project: Flink Issue

[jira] [Updated] (FLINK-1451) Enable parallel execution of streaming file sources

2015-01-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1451: -- Description: Currently the streaming FileSourceFunction does not support parallelism greater

[jira] [Resolved] (FLINK-1381) Only one output splitter supported per operator

2015-01-25 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1381. --- Resolution: Fixed Only one output splitter supported per operator

[jira] [Commented] (FLINK-1424) bin/flink run does not recognize -c parameter anymore

2015-01-25 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291265#comment-14291265 ] Max Michels commented on FLINK-1424: [~cebe] The commit you mention makes it possible

[jira] [Resolved] (FLINK-1081) Add HDFS file-stream source for streaming

2015-01-25 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1081. --- Resolution: Fixed Add HDFS file-stream source for streaming