[jira] [Commented] (FLINK-1147) TypeInference on POJOs

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288937#comment-14288937 ] ASF GitHub Bot commented on FLINK-1147: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-1165) No createCollectionsEnvironment in Java API

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288935#comment-14288935 ] ASF GitHub Bot commented on FLINK-1165: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1147][Java API] TypeInference on POJOs

2015-01-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/315#issuecomment-71158420 +1 to merge from me as well. Go ahead, Timo... --- 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

[GitHub] flink pull request: [FLINK-1165] No createCollectionsEnvironment i...

2015-01-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/320#issuecomment-71158365 I vote to call it `createCollectionsEnvironment` in Java as well, so that the APIs are in sync, and we do not have a breaking change in the Scala API. Otherwis

[GitHub] flink pull request: [FLINK-1392] Add Kryo serializer for Protobuf

2015-01-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/322#issuecomment-71158115 Per the discussion on the dev mailing list (http://mail-archives.apache.org/mod_mbox/flink-dev/201501.mbox/browser), should this be registered by the code that analyze

[jira] [Commented] (FLINK-1392) Serializing Protobuf - issue 1

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288929#comment-14288929 ] ASF GitHub Bot commented on FLINK-1392: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-1391) Kryo fails to properly serialize avro collection types

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288923#comment-14288923 ] ASF GitHub Bot commented on FLINK-1391: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1391] Add support for using Avro-POJOs ...

2015-01-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/323#issuecomment-71157859 Looks like a good fix to me. One comment/question inline, otherwise good to merge. --- If your project is set up for it, you can reply to this email and have your rep

[jira] [Commented] (FLINK-1391) Kryo fails to properly serialize avro collection types

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288922#comment-14288922 ] ASF GitHub Bot commented on FLINK-1391: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1391] Add support for using Avro-POJOs ...

2015-01-22 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/323#discussion_r23435527 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java --- @@ -237,6 +244,25 @@ private void checkKryoInitiali

[jira] [Commented] (FLINK-1353) Execution always uses DefaultAkkaAskTimeout, rather than the configured value

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288912#comment-14288912 ] ASF GitHub Bot commented on FLINK-1353: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1353] Fixes the Execution to use the co...

2015-01-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/325#issuecomment-71157412 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 your project does not have this

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

2015-01-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-71157010 I took the pull request and filtered the branch to move the files into the `flink-addons/flink-gelly` directory (that worked better for me than the subtree merge). Al

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

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288905#comment-14288905 ] ASF GitHub Bot commented on FLINK-1201: --- Github user StephanEwen commented on the pu

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

2015-01-22 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/328#issuecomment-71148024 Thanks for the explation @tillrohrmann +1 for exponential backoff approach. We can have max retries and max delay for each try as configurable configuration prop

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

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

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

2015-01-22 Thread mustafa elbehery (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288646#comment-14288646 ] mustafa elbehery commented on FLINK-629: Its working now, Thanks a lot robert for y

[GitHub] flink pull request: Rename coGroupDataSet.scala to CoGroupDataSet....

2015-01-22 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/324#issuecomment-71134892 As per recommendation from @StephanEwen, will not merge this to 0.8 until we need to cherry-pick fixes related to these files. --- If your project is set up for it, you

[GitHub] flink pull request: Rename coGroupDataSet.scala to CoGroupDataSet....

2015-01-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/324 --- 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-1352) Buggy registration from TaskManager to JobManager

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288569#comment-14288569 ] ASF GitHub Bot commented on FLINK-1352: --- Github user StephanEwen commented on the pu

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

2015-01-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/328#issuecomment-71133987 I am not sure that the infinite number of tries is actually bad. This sort of depends on the situation, I guess: - On YARN, it may make sense, because the node wi

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

2015-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288543#comment-14288543 ] Stephan Ewen commented on FLINK-1424: - [~aalexandrov] was also suggesting to use a dif

[jira] [Updated] (FLINK-1435) TaskManager does not log missing memory error on start up

2015-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1435: Labels: memorymanager starter (was: memorymanager) > TaskManager does not log missing memory error

[jira] [Updated] (FLINK-1436) Command-line interface verbose option (-v)

2015-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1436: Labels: starter usability (was: usability) > Command-line interface verbose option (-v) > -

[jira] [Commented] (FLINK-1436) Command-line interface verbose option (-v)

2015-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14288533#comment-14288533 ] Stephan Ewen commented on FLINK-1436: - +1 for all three suggestions from robert > Com

[GitHub] flink pull request: Rename coGroupDataSet.scala to CoGroupDataSet....

2015-01-22 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/324#issuecomment-71119613 Cool, thanks @StephanEwen, if no one beats me merging I will do this EOD today --- If your project is set up for it, you can reply to this email and have your reply appe

[GitHub] flink pull request: Rename coGroupDataSet.scala to CoGroupDataSet....

2015-01-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/324#issuecomment-71103567 You have my +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 featu

[GitHub] flink pull request: Rename coGroupDataSet.scala to CoGroupDataSet....

2015-01-22 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/324#issuecomment-71079720 Can I get +1 for this 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 t

[jira] [Commented] (FLINK-1437) Bug in PojoSerializer's copy() method

2015-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287801#comment-14287801 ] Stephan Ewen commented on FLINK-1437: - Good catch. The POJO serializer can probably ha

[jira] [Commented] (FLINK-1435) TaskManager does not log missing memory error on start up

2015-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287787#comment-14287787 ] Stephan Ewen commented on FLINK-1435: - We should make sure that all errors in the JobM

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

2015-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287776#comment-14287776 ] Stephan Ewen commented on FLINK-1433: - +1 that seems very important > Add HADOOP_CLAS

[jira] [Created] (FLINK-1437) Bug in PojoSerializer's copy() method

2015-01-22 Thread Timo Walther (JIRA)
Timo Walther created FLINK-1437: --- Summary: Bug in PojoSerializer's copy() method Key: FLINK-1437 URL: https://issues.apache.org/jira/browse/FLINK-1437 Project: Flink Issue Type: Bug C

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

2015-01-22 Thread Carsten Brandt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287517#comment-14287517 ] Carsten Brandt commented on FLINK-1424: --- In general I could but currently I'm very b

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

2015-01-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287514#comment-14287514 ] Gyula Fora commented on FLINK-1434: --- It seems like I was unaware of the OptimizerPlanEnv

[jira] [Commented] (FLINK-1436) Command-line interface verbose option (-v)

2015-01-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287509#comment-14287509 ] Robert Metzger commented on FLINK-1436: --- I totally agree with you. Also, it would b

[jira] [Commented] (FLINK-1436) Command-line interface verbose option (-v)

2015-01-22 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287477#comment-14287477 ] Max Michels commented on FLINK-1436: This is also related to the confusion in https:/

[jira] [Created] (FLINK-1436) Command-line interface verbose option (-v)

2015-01-22 Thread Max Michels (JIRA)
Max Michels created FLINK-1436: -- Summary: Command-line interface verbose option (-v) Key: FLINK-1436 URL: https://issues.apache.org/jira/browse/FLINK-1436 Project: Flink Issue Type: Improvement

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

2015-01-22 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287423#comment-14287423 ] Max Michels commented on FLINK-1410: +1 We should make releasing as simple as possibl

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

2015-01-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287404#comment-14287404 ] Robert Metzger commented on FLINK-629: -- Maybe you can even cherry-pick the commit into

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

2015-01-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287403#comment-14287403 ] Robert Metzger commented on FLINK-629: -- I think you can very easily backport the fix t

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

2015-01-22 Thread mustafa elbehery (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287392#comment-14287392 ] mustafa elbehery commented on FLINK-629: Its on Flink 9, I have to stick right now

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

2015-01-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287352#comment-14287352 ] Gyula Fora commented on FLINK-1434: --- This actually seems to be a ClassLoader issue, but

[jira] [Commented] (FLINK-1435) TaskManager does not log missing memory error on start up

2015-01-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287340#comment-14287340 ] Ufuk Celebi commented on FLINK-1435: Thanks for reporting the issue. I agree that the

[jira] [Updated] (FLINK-1435) TaskManager does not log missing memory error on start up

2015-01-22 Thread Malte Schwarzer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Malte Schwarzer updated FLINK-1435: --- Priority: Minor (was: Major) > TaskManager does not log missing memory error on start up > --

[jira] [Updated] (FLINK-1435) TaskManager does not log missing memory error on start up

2015-01-22 Thread Malte Schwarzer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Malte Schwarzer updated FLINK-1435: --- Priority: Major (was: Minor) > TaskManager does not log missing memory error on start up > --

[jira] [Updated] (FLINK-1435) TaskManager does not log missing memory error on start up

2015-01-22 Thread Malte Schwarzer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Malte Schwarzer updated FLINK-1435: --- Description: When using bin/start-cluster.sh to start TaskManagers and a worker node is faili

[jira] [Created] (FLINK-1435) TaskManager does not log missing memory error on start up

2015-01-22 Thread Malte Schwarzer (JIRA)
Malte Schwarzer created FLINK-1435: -- Summary: TaskManager does not log missing memory error on start up Key: FLINK-1435 URL: https://issues.apache.org/jira/browse/FLINK-1435 Project: Flink I

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

2015-01-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1372. Resolution: Fixed Fixed in 631b6eb804dc4a0236198574a8f8011ab2b6c8c2 > TaskManager and JobManager do

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

2015-01-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287289#comment-14287289 ] Gyula Fora commented on FLINK-1434: --- This issue is also linked with https://issues.apac

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

2015-01-22 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1434: - Summary: Web interface cannot be used to run streaming programs Key: FLINK-1434 URL: https://issues.apache.org/jira/browse/FLINK-1434 Project: Flink Issue Type: Bu

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

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

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

2015-01-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/329 --- 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-1352) Buggy registration from TaskManager to JobManager

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

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

2015-01-22 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/328#issuecomment-71003641 Thanks for the summary, Till :) On 22 Jan 2015, at 11:48, Till Rohrmann wrote: > Indefinitely many registration tries: > Pros: If the JobManager becomes a

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

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287269#comment-14287269 ] ASF GitHub Bot commented on FLINK-1372: --- Github user tillrohrmann commented on the p

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

2015-01-22 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/329#issuecomment-71003585 Ok, I'll merge it. --- 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

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

2015-01-22 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/328#issuecomment-71002640 You are right @hsaputra, because I'm not sure which approach is the best. In the corresponding JIRA issue I have tried to give a summary of what I think are the pros

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

2015-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14287259#comment-14287259 ] ASF GitHub Bot commented on FLINK-1352: --- Github user tillrohrmann commented on the p

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

2015-01-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1433: - Summary: Add HADOOP_CLASSPATH to start scripts Key: FLINK-1433 URL: https://issues.apache.org/jira/browse/FLINK-1433 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1432) CombineTaskTest.testCancelCombineTaskSorting sometimes fails

2015-01-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1432: - Summary: CombineTaskTest.testCancelCombineTaskSorting sometimes fails Key: FLINK-1432 URL: https://issues.apache.org/jira/browse/FLINK-1432 Project: Flink