[GitHub] flink pull request: [FLINK-1352] [runtime] Fix buggy registration ...

2015-01-21 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/328#issuecomment-70888379 Hi @tillrohrmann, I don't think this PR change the retries strategy, does it? --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-1410) Integrate Flink version variables into website layout

2015-01-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285903#comment-14285903 ] Robert Metzger commented on FLINK-1410: --- Also, we need to fix the ul, li elements

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

2015-01-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286016#comment-14286016 ] Stephan Ewen commented on FLINK-629: Concerning the fix: Some classes are not

[jira] [Created] (FLINK-1429) Add documentation for streaming scala api

2015-01-21 Thread JIRA
Márton Balassi created FLINK-1429: - Summary: Add documentation for streaming scala api Key: FLINK-1429 URL: https://issues.apache.org/jira/browse/FLINK-1429 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-1403) Streaming api doesn't support output file named with file:// prefix

2015-01-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285987#comment-14285987 ] Márton Balassi commented on FLINK-1403: --- Implemented via dc0d81b. Streaming api

[jira] [Resolved] (FLINK-1345) Add operator chaining to the streaming runtime

2015-01-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1345. --- Resolution: Implemented Implemented via 26535c4...7dbb55e. Add operator chaining to the

[jira] [Created] (FLINK-1430) Add test for streaming scala api completeness

2015-01-21 Thread JIRA
Márton Balassi created FLINK-1430: - Summary: Add test for streaming scala api completeness Key: FLINK-1430 URL: https://issues.apache.org/jira/browse/FLINK-1430 Project: Flink Issue Type:

[GitHub] flink commit comment: 7df6a3d7266b0f934b76722732176dbf5469bdb4

2015-01-21 Thread StephanEwen
Github user StephanEwen commented on commit 7df6a3d7266b0f934b76722732176dbf5469bdb4: https://github.com/apache/flink/commit/7df6a3d7266b0f934b76722732176dbf5469bdb4#commitcomment-9381927 In

[jira] [Updated] (FLINK-1410) Integrate Flink version variables into website layout

2015-01-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1410: -- Attachment: ulli-howItShouldLook.png ulli-howItactuallyLooks.png Integrate

[jira] [Resolved] (FLINK-1403) Streaming api doesn't support output file named with file:// prefix

2015-01-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1403. --- Resolution: Implemented Streaming api doesn't support output file named with file:// prefix

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

2015-01-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286098#comment-14286098 ] Stephan Ewen commented on FLINK-1424: - Sounds good. [~cebe] can you make a patch for

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

2015-01-21 Thread Felix Neutatz (JIRA)
Felix Neutatz created FLINK-1428: Summary: Typos in Java code example for RichGroupReduceFunction Key: FLINK-1428 URL: https://issues.apache.org/jira/browse/FLINK-1428 Project: Flink Issue

[jira] [Commented] (FLINK-1372) TaskManager and JobManager do not log startup settings any more

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

[GitHub] flink pull request: [FLINK-1372] [runtime] Fixes Akka logging

2015-01-21 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/329#issuecomment-70911543 +1 agree --- 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: Rename coGroupDataSet.scala to CoGroupDataSet....

2015-01-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/324#issuecomment-70953743 Looks good to me. It does not break the API, since it only moves source code, so I do not have any objections. I would merge it into the master, though, not into 0.8.

[GitHub] flink pull request: [FLINK-1295][FLINK-883] Allow to deploy 'job o...

2015-01-21 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/292#discussion_r23292258 --- Diff: flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMaster.scala --- @@ -41,9 +41,9 @@ object ApplicationMaster{ val

[GitHub] flink pull request: [FLINK-1295][FLINK-883] Allow to deploy 'job o...

2015-01-21 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/292#discussion_r23290018 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClient.java --- @@ -0,0 +1,653 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request: [FLINK-1352] [runtime] Fix buggy registration ...

2015-01-21 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/328 [FLINK-1352] [runtime] Fix buggy registration of TaskManager to JobManager The JobManager sends now RefusedRegistration messages to the TaskManager if the registration failed or the TaskManager

[GitHub] flink pull request: [FLINK-1234] Update documentation configuratio...

2015-01-21 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/295#issuecomment-70812027 I'll merge #292 first and then fix the variable names as part of this pr. --- 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-1295][FLINK-883] Allow to deploy 'job o...

2015-01-21 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/292#discussion_r23290531 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClient.java --- @@ -0,0 +1,653 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request: [FLINK-1295][FLINK-883] Allow to deploy 'job o...

2015-01-21 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/292#discussion_r23290607 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClient.java --- @@ -0,0 +1,653 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request: [FLINK-1295][FLINK-883] Allow to deploy 'job o...

2015-01-21 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/292#discussion_r23289567 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClient.java --- @@ -0,0 +1,653 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request: Update programming_guide.md

2015-01-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/327 --- 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-1296] Add sorter support for very large...

2015-01-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/249 --- 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-1424) bin/flink run does not recognize -c parameter anymore

2015-01-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285374#comment-14285374 ] Stephan Ewen commented on FLINK-1424: - Does it work if you switch the order of the

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

2015-01-21 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70809957 Awesome work Vasia. +1 for Gelly and the personalized names. If we document that Gelly is our graph API, then it shouldn't be a problem understand what it is. ---

[jira] [Assigned] (FLINK-1423) No Tags for new release on the github repo

2015-01-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1423: - Assignee: Robert Metzger No Tags for new release on the github repo

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

2015-01-21 Thread Carsten Brandt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285573#comment-14285573 ] Carsten Brandt commented on FLINK-1424: --- Yes, this way it is working. If it is not

[jira] [Commented] (FLINK-1372) TaskManager and JobManager do not log startup settings any more

2015-01-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285693#comment-14285693 ] Robert Metzger commented on FLINK-1372: --- The issue has not been resolved. I just

[jira] [Assigned] (FLINK-1403) Streaming api doesn't support output file named with file:// prefix

2015-01-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1403: - Assignee: Márton Balassi Streaming api doesn't support output file named with file://

[GitHub] flink pull request: [FLINK-1352] [runtime] Fix buggy registration ...

2015-01-21 Thread Humbedooh
Github user Humbedooh commented on the pull request: https://github.com/apache/flink/pull/328#issuecomment-70851722 Please ignore this, I am trying to get our JIRA integration working again, so I am posting a couple of bogus replies here. --- If your project is set up for it, you

[jira] [Commented] (FLINK-1352) Buggy registration from TaskManager to JobManager

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

[jira] [Commented] (FLINK-1427) Configuration through environment variables

2015-01-21 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285744#comment-14285744 ] Alexander Alexandrov commented on FLINK-1427: - I am not too fond of this idea.

[jira] [Commented] (FLINK-1372) TaskManager and JobManager do not log startup settings any more

2015-01-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285738#comment-14285738 ] Till Rohrmann commented on FLINK-1372: -- You're right Robert. I forgot to insert the

[jira] [Commented] (FLINK-1426) JobManager AJAX requests sometimes fail

2015-01-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285663#comment-14285663 ] Robert Metzger commented on FLINK-1426: --- Ah cool. I didn't know that there is still

[GitHub] flink pull request: https://issues.apache.org/jira/browse/FLINK-13...

2015-01-21 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/312#issuecomment-70846478 This can be closed. msdevanms wants to merge 78 commits into master from release-0.8, which are both branches from our repo. I also couldn't find a public fork at his

[jira] [Commented] (FLINK-1426) JobManager AJAX requests sometimes fail

2015-01-21 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285683#comment-14285683 ] Alexander Alexandrov commented on FLINK-1426: - He is, he has just not opened a

[GitHub] flink pull request: [FLINK-1352] [runtime] Fix buggy registration ...

2015-01-21 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/328#issuecomment-70848126 Well, I wanted to get some feedback/discussion on the retry strategy before merging this PR. At the moment the strategy is a limited number of retries with a

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

2015-01-21 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70839009 Thank you all for the suggestions regarding preserving the commit history! I'll try them out later today and see whether I can make it :) --- If your project is set up for

[jira] [Commented] (FLINK-1426) JobManager AJAX requests sometimes fail

2015-01-21 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285657#comment-14285657 ] Alexander Alexandrov commented on FLINK-1426: - Just to restate - I have a

[jira] [Commented] (FLINK-1427) Configuration through environment variables

2015-01-21 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285760#comment-14285760 ] Ufuk Celebi commented on FLINK-1427: [~aalexandrov]: couldn't we just keep the current

[GitHub] flink pull request: [FLINK-1372] [runtime] Fixes Akka logging

2015-01-21 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/329 [FLINK-1372] [runtime] Fixes Akka logging Adds EnvironmentInformation.logEnvironmentInfo method calls to JobManager's and TaskManager's main methods. You can merge this pull request into a Git

[jira] [Commented] (FLINK-1372) TaskManager and JobManager do not log startup settings any more

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

[GitHub] flink pull request: [FLINK-1372] [runtime] Fixes Akka logging

2015-01-21 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/329#issuecomment-70856651 +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 not have this feature enabled and

[jira] [Commented] (FLINK-1372) TaskManager and JobManager do not log startup settings any more

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

[GitHub] flink pull request: [FLINK-1372] [runtime] Fixes Akka logging

2015-01-21 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/329#issuecomment-70857827 I think small changes like this can be committed directly. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: [FLINK-1372] [runtime] Fixes Akka logging

2015-01-21 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/329#issuecomment-70856935 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 feature

[jira] [Commented] (FLINK-1372) TaskManager and JobManager do not log startup settings any more

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