[jira] [Commented] (FLINK-1484) JobManager restart does not notify the TaskManager

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

[GitHub] flink pull request: [FLINK-1484] Adds explicit disconnect message ...

2015-02-05 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/368#discussion_r24220454 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -125,6 +126,10 @@ Actor with ActorLogMessages with ActorLo

[jira] [Commented] (FLINK-1388) POJO support for writeAsCsv

2015-02-05 Thread Adnan Khan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14308464#comment-14308464 ] Adnan Khan commented on FLINK-1388: --- so I came across this page[1] and also I've been tr

[jira] [Updated] (FLINK-1485) Typo in Documentation - Join with Join-Function

2015-02-05 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-1485: Component/s: Documentation > Typo in Documentation - Join with Join-Function > -

[jira] [Created] (FLINK-1485) Typo in Documentation - Join with Join-Function

2015-02-05 Thread Johannes (JIRA)
Johannes created FLINK-1485: --- Summary: Typo in Documentation - Join with Join-Function Key: FLINK-1485 URL: https://issues.apache.org/jira/browse/FLINK-1485 Project: Flink Issue Type: Bug Affec

[GitHub] flink pull request: Typo in - Join with Join-Function

2015-02-05 Thread jkirsch
GitHub user jkirsch opened a pull request: https://github.com/apache/flink/pull/369 Typo in - Join with Join-Function Fix typo in the Java Code Example You can merge this pull request into a Git repository by running: $ git pull https://github.com/jkirsch/incubator-flink typo

[jira] [Commented] (FLINK-1484) JobManager restart does not notify the TaskManager

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

[GitHub] flink pull request: [FLINK-1484] Adds explicit disconnect message ...

2015-02-05 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/368 [FLINK-1484] Adds explicit disconnect message for TaskManagers In case of a JobManager restart, which can be caused by an uncaught exception, all connected TaskManager are notified by a ```Disco

[jira] [Created] (FLINK-1484) JobManager restart does not notify the TaskManager

2015-02-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1484: Summary: JobManager restart does not notify the TaskManager Key: FLINK-1484 URL: https://issues.apache.org/jira/browse/FLINK-1484 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak

2015-02-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1455. - Resolution: Invalid Not a memory leak. The error message comes only because the JVM I/O problem c

[jira] [Updated] (FLINK-1483) Temporary channel files are not properly deleted when Flink is terminated

2015-02-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1483: - Description: The temporary channel files are not properly deleted if the IOManager does not shut

[jira] [Created] (FLINK-1483) Temporary channel files are not properly deleted when Flink is terminated

2015-02-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1483: Summary: Temporary channel files are not properly deleted when Flink is terminated Key: FLINK-1483 URL: https://issues.apache.org/jira/browse/FLINK-1483 Project: Flin

[jira] [Closed] (FLINK-1482) BlobStore does not delete directories when process is killed

2015-02-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1482. Resolution: Fixed Fixed with e766dba3653bb942ff66bd9edc999237a77c2ea2 > BlobStore does not delete d

[jira] [Commented] (FLINK-1482) BlobStore does not delete directories when process is killed

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

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

2015-02-05 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/366#issuecomment-73089829 Thank you for trying it out. Ideally, with the bot in place the number of warnings will go down over time. I'll address the comments in the source. I

[jira] [Commented] (FLINK-1482) BlobStore does not delete directories when process is killed

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

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

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

[GitHub] flink pull request: [FLINK-1482] [runtime] Adds shutdown hook to d...

2015-02-05 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/367#issuecomment-73089771 Ufuk already implemented the shutdown hooks. --- 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

[GitHub] flink pull request: [FLINK-1482] [runtime] Adds shutdown hook to d...

2015-02-05 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/367 --- 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-1482] [runtime] Adds shutdown hook to d...

2015-02-05 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/367 [FLINK-1482] [runtime] Adds shutdown hook to delete blob store directories Adds shutdown hook to delete blob store directories. This also deletes the blob store files in case that the JVM was te

[jira] [Commented] (FLINK-1482) BlobStore does not delete directories when process is killed

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

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

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

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

2015-02-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/366#issuecomment-73087911 I just ran the script on your pull request ;) > Flink QA-Check results: > :+1: The number of javadoc errors was 402 and is now 402 > :-1: The change i

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

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

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

2015-02-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/366#discussion_r24179312 --- Diff: tools/qa-check.sh --- @@ -0,0 +1,175 @@ +#!/usr/bin/env bash + +# +# Licensed to the Apache Software Foundation (ASF) under one or more

[jira] [Created] (FLINK-1482) BlobStore does not delete directories when process is killed

2015-02-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1482: Summary: BlobStore does not delete directories when process is killed Key: FLINK-1482 URL: https://issues.apache.org/jira/browse/FLINK-1482 Project: Flink I

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

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

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

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

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

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

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

2015-02-05 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/366#issuecomment-73084319 Its not completely building flink, its only generating javadocs or compiling for getting the compiler warnings. The main purpose of the script is to be executed a

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

2015-02-05 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/366#discussion_r24178788 --- Diff: tools/qa-check.sh --- @@ -0,0 +1,175 @@ +#!/usr/bin/env bash + +# +# Licensed to the Apache Software Foundation (ASF) under one or more

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

2015-02-05 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/366#issuecomment-73084249 The idea is to run this automatically or on request, which should be fine. --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

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

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

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

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

2015-02-05 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/366#issuecomment-73083750 Very nice. Will try it out now :) --- 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

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

2015-02-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/366#issuecomment-73083755 The script builds Flink twice and therefore takes a while. I don't know if we can force users to execute it before making pull requests. However, it would be good to get an au

[jira] [Commented] (FLINK-1481) Flakey JobManagerITCase

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

[jira] [Closed] (FLINK-1481) Flakey JobManagerITCase

2015-02-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1481. Resolution: Fixed Fixed with 0ccd1fd5b90dbdacb579e329016a0819cd301d43 > Flakey JobManagerITCase > -

[GitHub] flink pull request: [FLINK-1481] Fixes flakey JobManagerITCase

2015-02-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/365 --- 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-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

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

[GitHub] flink pull request: [FLINK-1463] Fix stateful/stateless Serializer...

2015-02-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/353#issuecomment-73079537 Thanks. Sorry for being picky ;-) --- 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] [Commented] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

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

[GitHub] flink pull request: [FLINK-1463] Fix stateful/stateless Serializer...

2015-02-05 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/353#issuecomment-73079161 Ok, then I'll add this. --- 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 thi

[jira] [Commented] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

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

[jira] [Commented] (FLINK-1481) Flakey JobManagerITCase

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

[GitHub] flink pull request: [FLINK-1463] Fix stateful/stateless Serializer...

2015-02-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/353#issuecomment-73078373 Yes. Some serializers are heavyweight and often, the factories produce only one serializer through their lifetime. It is a nice improvement, bot a crucial one, though.

[GitHub] flink pull request: [FLINK-1481] Fixes flakey JobManagerITCase

2015-02-05 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/365#issuecomment-73078351 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 feat

[jira] [Commented] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

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

[GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool

2015-02-05 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/366 [FLINK-1166] Add qa-check.sh tool The ./tools/qa-check.sh tool allows developers to check for common errors before opening a pull request. The qa-checks are designed to be easily extensible by f

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

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

[GitHub] flink pull request: [FLINK-1463] Fix stateful/stateless Serializer...

2015-02-05 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/353#issuecomment-73077279 Do you think that with the additional checking logic this would really make up for one superfluous duplication? --- If your project is set up for it, you can reply to t

[GitHub] flink pull request: [FLINK-1442] Reduce memory consumption of arch...

2015-02-05 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/344#issuecomment-73074657 Awesome! Thanks for the update. --- 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 h

[jira] [Commented] (FLINK-1442) Archived Execution Graph consumes too much memory

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

[jira] [Commented] (FLINK-1442) Archived Execution Graph consumes too much memory

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

[GitHub] flink pull request: [FLINK-1442] Reduce memory consumption of arch...

2015-02-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/344#issuecomment-73073294 I addressed the issues already in a cleanup commit built on top of #317 . See 56b7f85b4f6d522765df19a9710a098092ccde56 --- If your project is set up for it, you can r

[jira] [Resolved] (FLINK-1480) Test Flink against Hadoop 2.6.0

2015-02-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1480. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/140faa94 >

[GitHub] flink pull request: [FLINK-1481] Fixes flakey JobManagerITCase

2015-02-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/365#issuecomment-73060980 Good one, thank you! +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 proje

[jira] [Commented] (FLINK-1481) Flakey JobManagerITCase

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

[jira] [Commented] (FLINK-1422) Missing usage example for "withParameters"

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

[GitHub] flink pull request: [FLINK-1422] Add withParameters() to documenta...

2015-02-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/350#discussion_r24168441 --- Diff: docs/programming_guide.md --- @@ -2398,6 +2399,61 @@ of a function, or use the `withParameters(...)` method to pass in a configuratio [Back to t

[jira] [Commented] (FLINK-1422) Missing usage example for "withParameters"

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

[GitHub] flink pull request: [FLINK-1422] Add withParameters() to documenta...

2015-02-05 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/350#discussion_r24168173 --- Diff: docs/programming_guide.md --- @@ -2398,6 +2399,61 @@ of a function, or use the `withParameters(...)` method to pass in a configuratio [Back to to

[GitHub] flink pull request: [FLINK-1422] Add withParameters() to documenta...

2015-02-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/350#discussion_r24167714 --- Diff: docs/programming_guide.md --- @@ -2398,6 +2399,61 @@ of a function, or use the `withParameters(...)` method to pass in a configuratio [Back to t

[jira] [Commented] (FLINK-1422) Missing usage example for "withParameters"

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

[jira] [Commented] (FLINK-1481) Flakey JobManagerITCase

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

[GitHub] flink pull request: [FLINK-1481] Fixes flakey JobManagerITCase

2015-02-05 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/365 [FLINK-1481] Fixes flakey JobManagerITCase The sometimes failing sender tasks are now guaranteed to have at least one task which fails. You can merge this pull request into a Git repository by

[GitHub] flink pull request: [FLINK-1422] Add withParameters() to documenta...

2015-02-05 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/350#issuecomment-73056344 updated. --- 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-1422) Missing usage example for "withParameters"

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

[jira] [Created] (FLINK-1481) Flakey JobManagerITCase

2015-02-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1481: Summary: Flakey JobManagerITCase Key: FLINK-1481 URL: https://issues.apache.org/jira/browse/FLINK-1481 Project: Flink Issue Type: Bug Reporter: T

[jira] [Resolved] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable

2015-02-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-1471. - Resolution: Fixed > Allow KeySelectors to implement ResultTypeQueryable >

[jira] [Commented] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable

2015-02-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14307239#comment-14307239 ] Timo Walther commented on FLINK-1471: - Fixed in d033fa8fa834d288ec977ef7bda043dfdc397e

[jira] [Commented] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable

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

[GitHub] flink pull request: [FLINK-1471][java-api] Fixes wrong input valid...

2015-02-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/359 --- 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] [Closed] (FLINK-1415) Akka cleanups

2015-02-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1415. Resolution: Fixed Fixed with 4046819b380b8dfa57d52c6d314f389546a159a3 > Akka cleanups > ---

[jira] [Commented] (FLINK-1415) Akka cleanups

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

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

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

[GitHub] flink pull request: [FLINK-1415] Akka cleanups

2015-02-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/319 --- 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

[GitHub] flink pull request: Port FLINK-1391 and FLINK-1392 to "release-0.8...

2015-02-05 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/364 Port FLINK-1391 and FLINK-1392 to "release-0.8" branch. These commits port the fixes for the two issues (Avro and Protobuf support) to the release-0.8 branch. They also contain a hotfix regardin

[jira] [Created] (FLINK-1480) Test Flink against Hadoop 2.6.0

2015-02-05 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1480: - Summary: Test Flink against Hadoop 2.6.0 Key: FLINK-1480 URL: https://issues.apache.org/jira/browse/FLINK-1480 Project: Flink Issue Type: Task Co

[jira] [Resolved] (FLINK-1479) The spawned threads in the sorter have no context class loader

2015-02-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1479. - Resolution: Fixed Assignee: Stephan Ewen Fixed via 63720634e2333a86eed0e9957bcc35122067dae6

[GitHub] flink pull request: yarn client tests

2015-02-05 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/134#issuecomment-73047820 Yes, the changes here have been subsumed by FLINK-883. @skunert can you close this pull request? --- If your project is set up for it, you can reply to this emai

[jira] [Commented] (FLINK-883) Use MiniYARNCluster to test the Flink YARN client

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

[jira] [Updated] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

2015-02-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1463: Fix Version/s: 0.8.1 > RuntimeStatefulSerializerFactory declares ClassLoader as transient bu

[jira] [Commented] (FLINK-883) Use MiniYARNCluster to test the Flink YARN client

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

[GitHub] flink pull request: yarn client tests

2015-02-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/134#issuecomment-73046443 I guess this one is subsumed by @rmetzger 's work on https://issues.apache.org/jira/browse/FLINK-883 Can we close this PR? --- If your project is set up for

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

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

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

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

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

2015-02-05 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/317 --- 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-1376] [runtime] Add proper shared slot ...

2015-02-05 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/317#issuecomment-73046225 Of course. Thanks for merging. On Thu, Feb 5, 2015 at 2:30 PM, Stephan Ewen wrote: > This one has been manually merged (but I made a typo in the

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

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

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

2015-02-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14307203#comment-14307203 ] Timo Walther commented on FLINK-1319: - Actually, I don't like the "drop-in" approach.

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

2015-02-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/317#issuecomment-73045884 This one has been manually merged (but I made a typo in the "This closes #xxx" message ;-) ) @tillrohrmann Can you close the PR manually? --- If your project

[jira] [Commented] (FLINK-1479) The spawned threads in the sorter have no context class loader

2015-02-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14307189#comment-14307189 ] Stephan Ewen commented on FLINK-1479: - Patch coming up... > The spawned threads in th

[jira] [Created] (FLINK-1479) The spawned threads in the sorter have no context class loader

2015-02-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1479: --- Summary: The spawned threads in the sorter have no context class loader Key: FLINK-1479 URL: https://issues.apache.org/jira/browse/FLINK-1479 Project: Flink I

[jira] [Commented] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

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

[GitHub] flink pull request: [FLINK-1463] Fix stateful/stateless Serializer...

2015-02-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/353#issuecomment-73042896 Looks good. For efficiency, we could change the factory such that it returns the original in the first request, and a duplicate after that. Good change otherwi

[jira] [Commented] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable

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

[GitHub] flink pull request: [FLINK-1471][java-api] Fixes wrong input valid...

2015-02-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/359#issuecomment-73042551 Skipping the validation on raw types makes total sense. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink pull request: [docs] add documentation for FLink GCE setup u...

2015-02-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/361 --- 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

[GitHub] flink pull request: [docs] add documentation for FLink GCE setup u...

2015-02-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/361#issuecomment-73041953 Will merge this... --- 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

  1   2   >