[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/375#issuecomment-73477321 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 ena

[jira] [Commented] (FLINK-1478) Add strictly local input split assignment

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

[GitHub] flink pull request: [FLINK-1179] Add button to JobManager web inte...

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/374#issuecomment-73477910 Very nice work. I have one comment inline, otherwise +1 to go! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[GitHub] flink pull request: [FLINK-1179] Add button to JobManager web inte...

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/374#discussion_r24315701 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/web/SetupInfoServlet.java --- @@ -127,25 +134,42 @@ private void writeTaskmanage

[jira] [Commented] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager

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

[jira] [Commented] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager

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

[GitHub] flink pull request: Remove unused enum values from Aggregations en...

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/373#issuecomment-73477963 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 featu

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

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/353#issuecomment-73478102 +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

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

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

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

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/368#issuecomment-73478074 Looks good. Since this is a behavior change, can you file a ticket for this, Till? --- If your project is set up for it, you can reply to this email and have your rep

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

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

[GitHub] flink pull request: [FLINK-1396][FLINK-1303] Hadoop Input/Output d...

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/363#issuecomment-73478491 Looks good. We are getting into very long package names here ;-) `org.apache.flink.api.java.hadoop.mapred.wrapper.*` --- If your project is set up for it, you can

[GitHub] flink pull request: [FLINK-1179] Add button to JobManager web inte...

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/374#issuecomment-73478511 I've tried it out locally. Looks very nice. Thank you. +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-1396) Add hadoop input formats directly to the user API.

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

[jira] [Commented] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager

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

[jira] [Commented] (FLINK-1493) Support for streaming jobs preserving global ordering of records

2015-02-09 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311962#comment-14311962 ] Márton Balassi commented on FLINK-1493: --- Hey Matthias, Thanks for looking into this

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

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

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

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/368#issuecomment-73478622 My bad, there is a ticket already. Can you squash the commits then and add the ticket tag? Otherwise, good to merge! --- If your project is set up for it, yo

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

2015-02-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/368#issuecomment-73479833 Yes, I'll do it. On Mon, Feb 9, 2015 at 10:23 AM, Stephan Ewen wrote: > My bad, there is a ticket already. Can you squash the commits then and ad

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

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

[jira] [Created] (FLINK-1494) Build fails on BlobCacheTest

2015-02-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1494: Summary: Build fails on BlobCacheTest Key: FLINK-1494 URL: https://issues.apache.org/jira/browse/FLINK-1494 Project: Flink Issue Type: Bug Componen

[jira] [Resolved] (FLINK-1475) Minimize log output of yarn test cases

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1475. --- Resolution: Fixed Fix Version/s: 0.9 > Minimize log output of yarn test cases > ---

[jira] [Commented] (FLINK-1475) Minimize log output of yarn test cases

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312093#comment-14312093 ] Robert Metzger commented on FLINK-1475: --- Resolved in http://git-wip-us.apache.org/re

[GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut...

2015-02-09 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/376 [FLINK-1492] Fix exceptions on blob store shutdown You can merge this pull request into a Git repository by running: $ git pull https://github.com/uce/incubator-flink flink-1492-proper_shutdown_ho

[jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup

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

[jira] [Commented] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312156#comment-14312156 ] Robert Metzger commented on FLINK-1487: --- I had another instance of this issue, in th

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

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/335#issuecomment-73499086 @vasia: You don't need to open a new pull request, force pushing to the branch this PR is based on will update it. I don't know if you need to do the history filtering

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

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

[jira] [Updated] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1342: -- Priority: Critical (was: Major) > Quickstart's assembly can possibly filter out user's code > -

[GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut...

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/376#issuecomment-73500870 This change is also in 0.8 so do we need to apply the fix there as well for the upcoming 0.8.1 release? --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup

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

[GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut...

2015-02-09 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/376#issuecomment-73500986 Yes, if it is finally OK. --- 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 fe

[jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup

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

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

2015-02-09 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/353 --- 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 ena

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

2015-02-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/353#issuecomment-73501310 Manually merged. --- 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 featur

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

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

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

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

[jira] [Commented] (FLINK-1494) Build fails on BlobCacheTest

2015-02-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312177#comment-14312177 ] Ufuk Celebi commented on FLINK-1494: Repeatedly as in "sometimes" or "always"? ;) The

[jira] [Commented] (FLINK-1493) Support for streaming jobs preserving global ordering of records

2015-02-09 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312182#comment-14312182 ] Gyula Fora commented on FLINK-1493: --- Hey, This is actually quite tricky to make it robu

[jira] [Closed] (FLINK-1494) Build fails on BlobCacheTest

2015-02-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1494. Resolution: Not a Problem The build failure was caused by not cleaned up artefacts, i.e., not callin

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

2015-02-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1463. - Resolution: Fixed Resolved in https://github.com/apache/flink/commit/7bc78cbf97d341ebfed3

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

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1479: -- Fix Version/s: 0.8.1 > The spawned threads in the sorter have no context class loader >

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

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312188#comment-14312188 ] Robert Metzger commented on FLINK-1479: --- Fixed in "release-0.8" by [~StephanEwen] in

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

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1376: -- Fix Version/s: 0.8.1 > SubSlots are not properly released in case that a TaskManager fatally fai

[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-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312192#comment-14312192 ] ASF GitHub Bot commented on FLINK-1376: --- Github user rmetzger commented on the pull

[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-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312191#comment-14312191 ] Robert Metzger commented on FLINK-1376: --- Resolved for "release-0.8" with target 0.8.

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

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/318#issuecomment-73504622 I've merged it to the 0.8 branch. I forgot to close the PR, could you do it manually? Thank you. --- If your project is set up for it, you can reply to this email an

[GitHub] flink pull request: [FLINK-1486] add print method for prefixing a ...

2015-02-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/372#issuecomment-73504724 To make it a bit more explicit what is sink identifier and what is the task identifier (especially when just one of the two are printed), I prefixed the sink identifier with "

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

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1376: -- Affects Version/s: 0.9 0.8 > SubSlots are not properly released in case t

[jira] [Commented] (FLINK-1486) Add a string to the print method to identify output

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

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/375#issuecomment-73505358 Only minor remarks. Looks good otherwise. --- 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 proj

[jira] [Commented] (FLINK-1478) Add strictly local input split assignment

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

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-02-09 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-73505531 @qmlmoon has provided TPCH Query 3 / 10 and WebLogAnalysis examples --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

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

2015-02-09 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/318 --- 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-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

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

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/375#discussion_r24327047 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java --- @@ -260,15 +260,49 @@ public void connectToPredeces

[jira] [Commented] (FLINK-1478) Add strictly local input split assignment

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

[GitHub] flink pull request: [FLINK-1179] Add button to JobManager web inte...

2015-02-09 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/374#issuecomment-73509674 @StephanEwen Thanks for your advice! I fixed 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

[GitHub] flink pull request: [FLINK-1396][FLINK-1303] Hadoop Input/Output d...

2015-02-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/363 --- 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-1179) Add button to JobManager web interface to request stack trace of a TaskManager

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

[jira] [Commented] (FLINK-1396) Add hadoop input formats directly to the user API.

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

[jira] [Resolved] (FLINK-1303) HadoopInputFormat does not work with Scala API

2015-02-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1303. - Resolution: Fixed Fix Version/s: 0.8.1 Resolved in https://github.com/apache/flink

[jira] [Resolved] (FLINK-1396) Add hadoop input formats directly to the user API.

2015-02-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1396. - Resolution: Fixed Fix Version/s: 0.8.1 0.9 Resolved in https://

[jira] [Created] (FLINK-1495) Make Akka timeout configurable in YARN client.

2015-02-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1495: - Summary: Make Akka timeout configurable in YARN client. Key: FLINK-1495 URL: https://issues.apache.org/jira/browse/FLINK-1495 Project: Flink Issue Type: Im

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

2015-02-09 Thread rmetzger
Github user rmetzger closed the pull request at: https://github.com/apache/flink/pull/364 --- 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 ena

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

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/364#issuecomment-73510972 Merged. --- 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-1391) Kryo fails to properly serialize avro collection types

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312239#comment-14312239 ] Robert Metzger commented on FLINK-1391: --- Pushed fix into "release-0.8": 84c4998125b1

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

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

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

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312242#comment-14312242 ] Robert Metzger commented on FLINK-1392: --- Pushed fix for "release-0.8" in http://git

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

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1392: -- Affects Version/s: 0.9 0.8 > Serializing Protobuf - issue 1 > ---

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

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

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

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1392: -- Fix Version/s: 0.8.1 > Serializing Protobuf - issue 1 > -- > >

[GitHub] flink pull request: [FLINK-1495][yarn] Make Akka timeout configura...

2015-02-09 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/377 [FLINK-1495][yarn] Make Akka timeout configurable in YARN client. You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink yarn_timeouts

[jira] [Commented] (FLINK-1495) Make Akka timeout configurable in YARN client.

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

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

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1391: -- Fix Version/s: 0.8.1 > Kryo fails to properly serialize avro collection types >

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/375#discussion_r24329907 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java --- @@ -260,15 +260,49 @@ public void connectToPred

[jira] [Commented] (FLINK-1478) Add strictly local input split assignment

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

[jira] [Created] (FLINK-1496) Events at unitialized input channels are lost

2015-02-09 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1496: -- Summary: Events at unitialized input channels are lost Key: FLINK-1496 URL: https://issues.apache.org/jira/browse/FLINK-1496 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1497) No documentation on MiniCluster

2015-02-09 Thread Sergey Dudoladov (JIRA)
Sergey Dudoladov created FLINK-1497: --- Summary: No documentation on MiniCluster Key: FLINK-1497 URL: https://issues.apache.org/jira/browse/FLINK-1497 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/375#discussion_r24330528 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java --- @@ -260,15 +260,49 @@ public void connectToPredeces

[jira] [Commented] (FLINK-1478) Add strictly local input split assignment

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

[jira] [Commented] (FLINK-1497) No documentation on MiniCluster

2015-02-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312308#comment-14312308 ] Stephan Ewen commented on FLINK-1497: - The mini cluster is so far an internal testing

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/375 --- 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-1478) Add strictly local input split assignment

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

[jira] [Resolved] (FLINK-1478) Add strictly local input split assignment

2015-02-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1478. - Resolution: Fixed Fixed in 4386620c06e94c9f4e3030ea7ae0f480845e2969 > Add strictly local input sp

[jira] [Created] (FLINK-1498) Spurious failures on Travis for I/O heavy tasks

2015-02-09 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1498: --- Summary: Spurious failures on Travis for I/O heavy tasks Key: FLINK-1498 URL: https://issues.apache.org/jira/browse/FLINK-1498 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1495) Make Akka timeout configurable in YARN client.

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

[GitHub] flink pull request: [FLINK-1495][yarn] Make Akka timeout configura...

2015-02-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/377#issuecomment-73529074 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 enabl

[GitHub] flink pull request: [FLINK-1495][yarn] Make Akka timeout configura...

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/377#issuecomment-73530921 Thank you. I'll merge it once the master is building again ;) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as we

[jira] [Commented] (FLINK-1495) Make Akka timeout configurable in YARN client.

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

[GitHub] flink pull request: [FLINK-1489] Fixes blocking scheduleOrUpdateCo...

2015-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/378 [FLINK-1489] Fixes blocking scheduleOrUpdateConsumers message calls Replaces the blocking calls with futures which in case of an exception let the respective task fail. Furthermore, the Partitio

[jira] [Commented] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers

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

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

2015-02-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1376. Resolution: Fixed Fixed with db1b8b993c12f2e74b6cc9a48414265666dc0e69 in 0.9 Fixed with 91382bb8c1

[jira] [Created] (FLINK-1499) Make TaskManager to disconnect from TaskManager in case of a restart

2015-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1499: Summary: Make TaskManager to disconnect from TaskManager in case of a restart Key: FLINK-1499 URL: https://issues.apache.org/jira/browse/FLINK-1499 Project: Flink

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

2015-02-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/335#issuecomment-73547684 Simple renaming didn't seem to keep the history, so I did the filtering again :) Didn't you have the same problem when moving flink-addons to flink-staging? Let

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

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

[jira] [Created] (FLINK-1500) exampleScalaPrograms.EnumTriangleOptITCase does not finish on Travis

2015-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1500: Summary: exampleScalaPrograms.EnumTriangleOptITCase does not finish on Travis Key: FLINK-1500 URL: https://issues.apache.org/jira/browse/FLINK-1500 Project: Flink

[jira] [Resolved] (FLINK-1498) Spurious failures on Travis for I/O heavy tasks

2015-02-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1498. - Resolution: Fixed Fixed in 52d9806baaff1689f21962febb7dc73d68572289 > Spurious failures on Travis

[GitHub] flink pull request: [FLINK-1495][yarn] Make Akka timeout configura...

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

  1   2   >