[jira] [Resolved] (FLINK-4555) Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down

2016-09-24 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4555. --- Resolution: Not A Problem > Explicitly kill TaskManager on YARN when ApplicationMaster

[jira] [Resolved] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-09-24 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4485. --- Resolution: Fixed Fix Version/s: 1.1.3 1.2.0 master: cd43dd5

[jira] [Resolved] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-09-20 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3929. --- Resolution: Fixed Fix Version/s: 1.2.0 > Support for Kerberos Authentication wi

[jira] [Created] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants

2016-09-20 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4644: - Summary: Deprecate "flink.base.dir.path" from ConfigConstants Key: FLINK-4644 URL: https://issues.apache.org/jira/browse/FLINK-4644 Project: Flink

[jira] [Commented] (FLINK-4555) Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down

2016-09-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15503965#comment-15503965 ] Maximilian Michels commented on FLINK-4555: --- There has been some refactoring pre

[jira] [Assigned] (FLINK-4555) Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down

2016-09-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4555: - Assignee: Maximilian Michels > Explicitly kill TaskManager on YARN when Applicati

[jira] [Deleted] (FLINK-4633) Implement new Client

2016-09-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels deleted FLINK-4633: -- > Implement new Client > > > Key: FLINK-4633 >

[jira] [Created] (FLINK-4628) User class loader unavailable during input split assignment

2016-09-16 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4628: - Summary: User class loader unavailable during input split assignment Key: FLINK-4628 URL: https://issues.apache.org/jira/browse/FLINK-4628 Project: Flink

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-09-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15492595#comment-15492595 ] Maximilian Michels commented on FLINK-4485: --- Yes, I was able to reproduce the pr

[jira] [Assigned] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-09-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4485: - Assignee: Maximilian Michels > Finished jobs in yarn session fill /tmp filesystem

[jira] [Assigned] (FLINK-4442) Implement Standalone ResourceManager

2016-09-08 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4442: - Assignee: Maximilian Michels > Implement Standalone ResourceManager > --

[jira] [Resolved] (FLINK-4073) YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis

2016-09-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4073. --- Resolution: Fixed Assignee: Maximilian Michels Fix Version/s: 1.2.0 Fi

[jira] [Reopened] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-4570: --- > Scalastyle Maven plugin fails undeterministically >

[jira] [Closed] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4570. - Resolution: Fixed After some debugging, finally fixed by removing a Unicode character. Cra

[jira] [Resolved] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4570. --- Resolution: Fixed Reverted back to Scalastyle version 0.8.0 and disabled Scalastyle fo

[jira] [Reopened] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-4570: --- Switching from Scalastyle 0.5.0 to 0.8.0 did not cause the issue because the issue also o

[jira] [Resolved] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4570. --- Resolution: Fixed Fix Version/s: 1.2.0 Reverted to 0.5.0 in bc9d52391957c1a1150

[jira] [Updated] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4570: -- Affects Version/s: 1.2.0 > Scalastyle Maven plugin fails undeterministically > -

[jira] [Commented] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458430#comment-15458430 ] Maximilian Michels commented on FLINK-4570: --- Also reported here: https://github

[jira] [Created] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4570: - Summary: Scalastyle Maven plugin fails undeterministically Key: FLINK-4570 URL: https://issues.apache.org/jira/browse/FLINK-4570 Project: Flink Iss

[jira] [Assigned] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4348: - Assignee: Maximilian Michels (was: zhangjing) > Implement slot allocation protoc

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15457967#comment-15457967 ] Maximilian Michels commented on FLINK-4485: --- Thanks a lot for the minimal exampl

[jira] [Commented] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

2016-09-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15455239#comment-15455239 ] Maximilian Michels commented on FLINK-4348: --- [~jinyu.zj] Could I take this over

[jira] [Assigned] (FLINK-4538) Implement slot allocation protocol with JobMaster

2016-09-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4538: - Assignee: Maximilian Michels > Implement slot allocation protocol with JobMaster

[jira] [Resolved] (FLINK-4516) ResourceManager leadership election

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4516. --- Resolution: Fixed > ResourceManager leadership election >

[jira] [Resolved] (FLINK-4347) Implement SlotManager core

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4347. --- Resolution: Fixed > Implement SlotManager core > -- > >

[jira] [Closed] (FLINK-4363) Implement TaskManager basic startup of all components in java

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4363. - Resolution: Fixed > Implement TaskManager basic startup of all components in java > --

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452391#comment-15452391 ] Maximilian Michels commented on FLINK-4535: --- Hi [~jinyu.zj]! Just a few remarks:

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452166#comment-15452166 ] Maximilian Michels commented on FLINK-4485: --- Interesting. But it occurs consiste

[jira] [Created] (FLINK-4540) Detached job execution may prevent cluster shutdown

2016-08-31 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4540: - Summary: Detached job execution may prevent cluster shutdown Key: FLINK-4540 URL: https://issues.apache.org/jira/browse/FLINK-4540 Project: Flink I

[jira] [Created] (FLINK-4538) Implement slot allocation protocol with JobMaster

2016-08-31 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4538: - Summary: Implement slot allocation protocol with JobMaster Key: FLINK-4538 URL: https://issues.apache.org/jira/browse/FLINK-4538 Project: Flink Iss

[jira] [Updated] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4348: -- Summary: Implement slot allocation protocol with TaskExecutor (was: Implement slot allo

[jira] [Updated] (FLINK-4348) Implement slot allocation protocol

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4348: -- Summary: Implement slot allocation protocol (was: Implement communication from Resource

[jira] [Updated] (FLINK-4449) Heartbeat Manager integration with JobMaster / TaskExecutor

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4449: -- Summary: Heartbeat Manager integration with JobMaster / TaskExecutor (was: Heartbeat Ma

[jira] [Updated] (FLINK-4535) ResourceManager registration with TaskExecutor

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4535: -- Summary: ResourceManager registration with TaskExecutor (was: ResourceManager process r

[jira] [Created] (FLINK-4537) ResourceManager registration with JobManager

2016-08-31 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4537: - Summary: ResourceManager registration with JobManager Key: FLINK-4537 URL: https://issues.apache.org/jira/browse/FLINK-4537 Project: Flink Issue Ty

[jira] [Resolved] (FLINK-4495) Running multiple jobs on yarn (without yarn-session)

2016-08-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4495. --- Resolution: Duplicate Fix Version/s: 1.1.2 1.2.0 Should be r

[jira] [Closed] (FLINK-4526) ApplicationClient: remove redundant proxy messages

2016-08-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4526. - Resolution: Fixed master: 31c88a564a8eda263aedada0da671357d1a6f524 release-1.1: f7ec1efb32

[jira] [Closed] (FLINK-4488) Prevent cluster shutdown after job execution for non-detached jobs

2016-08-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4488. - Resolution: Fixed master: 87114cd2aaf78de2114d1ea4ab7bd2b57494d716 release-1.1: 28da995494

[jira] [Resolved] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

2016-08-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4486. --- Resolution: Fixed master: ab1df63c3fd419c23631f3b55b506e6fdf3cb72f release-1.1: 4cdeb1

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15446231#comment-15446231 ] Maximilian Michels commented on FLINK-4485: --- Thanks for the update. That's very

[jira] [Created] (FLINK-4526) ApplicationClient: remove redundant proxy messages

2016-08-29 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4526: - Summary: ApplicationClient: remove redundant proxy messages Key: FLINK-4526 URL: https://issues.apache.org/jira/browse/FLINK-4526 Project: Flink Is

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445385#comment-15445385 ] Maximilian Michels commented on FLINK-4485: --- Thanks for reportig [~nielsbasjes].

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

2016-08-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445237#comment-15445237 ] Maximilian Michels commented on FLINK-2608: --- Thanks for letting us know! > Arra

[jira] [Commented] (FLINK-4487) Need tools for managing the yarn-session better

2016-08-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439112#comment-15439112 ] Maximilian Michels commented on FLINK-4487: --- I totally forgot that there is also

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438936#comment-15438936 ] Maximilian Michels commented on FLINK-3677: --- No worries. Your changes are not wr

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438935#comment-15438935 ] Maximilian Michels commented on FLINK-3677: --- I reviewed the pull requests and I

[jira] [Commented] (FLINK-4487) Need tools for managing the yarn-session better

2016-08-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438883#comment-15438883 ] Maximilian Michels commented on FLINK-4487: --- {quote} 1. If there is already a ya

[jira] [Updated] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

2016-08-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4486: -- Fix Version/s: 1.1.2 1.2.0 > JobManager not fully running when yarn-s

[jira] [Assigned] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

2016-08-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4486: - Assignee: Maximilian Michels > JobManager not fully running when yarn-session.sh

[jira] [Commented] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

2016-08-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438685#comment-15438685 ] Maximilian Michels commented on FLINK-4486: --- The {{YarnClusterClient}} delays ch

[jira] [Commented] (FLINK-4495) Running multiple jobs on yarn (without yarn-session)

2016-08-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437088#comment-15437088 ] Maximilian Michels commented on FLINK-4495: --- Thanks [~nielsbasjes] for opening t

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436964#comment-15436964 ] Maximilian Michels commented on FLINK-3677: --- Sure, thank you for your code! > F

[jira] [Closed] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3677. - Resolution: Implemented Fix Version/s: 1.2.0 Implemented with 4810910431e01bf143ae7

[jira] [Closed] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

2016-08-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4273. - Resolution: Implemented Implemented with 259a3a5569952458140afc8e9ad96eac0c330162 > Refac

[jira] [Created] (FLINK-4488) Prevent cluster shutdown after job execution for non-detached jobs

2016-08-25 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4488: - Summary: Prevent cluster shutdown after job execution for non-detached jobs Key: FLINK-4488 URL: https://issues.apache.org/jira/browse/FLINK-4488 Project: F

[jira] [Updated] (FLINK-4329) Fix Streaming File Source Timestamps/Watermarks Handling

2016-08-24 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4329: -- Fix Version/s: 1.1.2 1.2.0 > Fix Streaming File Source Timestamps/Wat

[jira] [Closed] (FLINK-4454) Lookups for JobManager address in config

2016-08-24 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4454. - Resolution: Fixed master: 720645587bc58a22db6a8d948f91384da2ecb7b7 release-1.1: 70b818b1ba

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-08-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433156#comment-15433156 ] Maximilian Michels commented on FLINK-3710: --- You want to use {{mvn scala:doc}} o

[jira] [Created] (FLINK-4454) Lookups for JobManager address in config

2016-08-23 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4454: - Summary: Lookups for JobManager address in config Key: FLINK-4454 URL: https://issues.apache.org/jira/browse/FLINK-4454 Project: Flink Issue Type:

[jira] [Closed] (FLINK-4426) Unable to create proxy to the ResourceManager

2016-08-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4426. - Resolution: Resolved Glad you were able to solve the problem. Thank you for letting us kno

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-08-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432349#comment-15432349 ] Maximilian Michels commented on FLINK-3710: --- The JavaDoc linked on the homepage

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-08-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428681#comment-15428681 ] Maximilian Michels commented on FLINK-3710: --- Seems like this is not really possi

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-08-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428588#comment-15428588 ] Maximilian Michels commented on FLINK-3710: --- Thank you for the reminder, I'll lo

[jira] [Commented] (FLINK-4426) Unable to create proxy to the ResourceManager

2016-08-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428380#comment-15428380 ] Maximilian Michels commented on FLINK-4426: --- The {{ZooKeeperSaslClient}} is not

[jira] [Created] (FLINK-4416) Provide a programmatic way to load a Yarn config

2016-08-17 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4416: - Summary: Provide a programmatic way to load a Yarn config Key: FLINK-4416 URL: https://issues.apache.org/jira/browse/FLINK-4416 Project: Flink Issu

[jira] [Closed] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up

2016-08-13 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4236. - Resolution: Fixed Fix Version/s: 1.2.0 master: 726d7c7ff25a4af681bf43abedfac452bcea

[jira] [Commented] (FLINK-4318) Make master docs build target version-specific

2016-08-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415154#comment-15415154 ] Maximilian Michels commented on FLINK-4318: --- The docs are built from a list of G

[jira] [Comment Edited] (FLINK-4318) Make master docs build target version-specific

2016-08-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415154#comment-15415154 ] Maximilian Michels edited comment on FLINK-4318 at 8/10/16 11:51 AM: ---

[jira] [Comment Edited] (FLINK-4318) Make master docs build target version-specific

2016-08-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415154#comment-15415154 ] Maximilian Michels edited comment on FLINK-4318 at 8/10/16 11:51 AM: ---

[jira] [Resolved] (FLINK-3690) Create documentation on the new ResourceManager component

2016-08-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3690. --- Resolution: Fixed The ResourceManager is still undergoing changes. Should be resolved

[jira] [Updated] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up

2016-08-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4236: -- Fix Version/s: 1.1.2 > Flink Dashboard stops showing list of uploaded jars if main metho

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404120#comment-15404120 ] Maximilian Michels commented on FLINK-4094: --- Yes, it was undocumented. Initially

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403961#comment-15403961 ] Maximilian Michels commented on FLINK-4094: --- Thanks [~StephanEwen] for clyariyin

[jira] [Closed] (FLINK-4305) Build pull requests with Jenkins

2016-08-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4305. - Resolution: Fixed Pull requests are now built with Jenkins: https://builds.apache.org/job

[jira] [Created] (FLINK-4305) Build pull requests with Jenkins

2016-08-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4305: - Summary: Build pull requests with Jenkins Key: FLINK-4305 URL: https://issues.apache.org/jira/browse/FLINK-4305 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402305#comment-15402305 ] Maximilian Michels commented on FLINK-4299: --- Good idea! We should add some messa

[jira] [Assigned] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4299: - Assignee: Maximilian Michels > Show loss of job manager in Client > -

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402231#comment-15402231 ] Maximilian Michels commented on FLINK-4094: --- Thanks for elaborating on your thou

[jira] [Updated] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4296: -- Description: Flink's scheduler doesn't support queued scheduling but expects to find all

[jira] [Updated] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4296: -- Assignee: Till Rohrmann > Scheduler accepts more tasks than it has task slots available

[jira] [Created] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-01 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4297: - Summary: Yarn client can't determine fat jar location if path contains spaces Key: FLINK-4297 URL: https://issues.apache.org/jira/browse/FLINK-4297 Project:

[jira] [Created] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4296: - Summary: Scheduler accepts more tasks than it has task slots available Key: FLINK-4296 URL: https://issues.apache.org/jira/browse/FLINK-4296 Project: Flink

[jira] [Comment Edited] (FLINK-4094) Off heap memory deallocation might not properly work

2016-07-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399038#comment-15399038 ] Maximilian Michels edited comment on FLINK-4094 at 7/29/16 9:35 AM:

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-07-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399038#comment-15399038 ] Maximilian Michels commented on FLINK-4094: --- I don't think just disallowing prea

[jira] [Closed] (FLINK-3714) Add Support for "Allowed Lateness"

2016-07-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3714. - Resolution: Fixed Fix Version/s: (was: 1.2.0) 1.1.0 > Add Su

[jira] [Reopened] (FLINK-3714) Add Support for "Allowed Lateness"

2016-07-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-3714: --- > Add Support for "Allowed Lateness" > -- > >

[jira] [Comment Edited] (FLINK-3714) Add Support for "Allowed Lateness"

2016-07-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15398965#comment-15398965 ] Maximilian Michels edited comment on FLINK-3714 at 7/29/16 8:37 AM:

[jira] [Reopened] (FLINK-3714) Add Support for "Allowed Lateness"

2016-07-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-3714: --- > Add Support for "Allowed Lateness" > -- > >

[jira] [Closed] (FLINK-3714) Add Support for "Allowed Lateness"

2016-07-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3714. - Resolution: Fixed Fix Version/s: 1.2.0 Added fix version 1.2.0 > Add Support for "

[jira] [Created] (FLINK-4274) Expose new JobClient in the DataSet/DataStream API

2016-07-28 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4274: - Summary: Expose new JobClient in the DataSet/DataStream API Key: FLINK-4274 URL: https://issues.apache.org/jira/browse/FLINK-4274 Project: Flink Is

[jira] [Created] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

2016-07-28 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4273: - Summary: Refactor JobClientActor to watch already submitted jobs Key: FLINK-4273 URL: https://issues.apache.org/jira/browse/FLINK-4273 Project: Flink

[jira] [Created] (FLINK-4272) Create a JobClient for job control and monitoring

2016-07-28 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4272: - Summary: Create a JobClient for job control and monitoring Key: FLINK-4272 URL: https://issues.apache.org/jira/browse/FLINK-4272 Project: Flink Is

[jira] [Updated] (FLINK-4272) Create a JobClient for job control and monitoring

2016-07-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4272: -- Priority: Minor (was: Major) > Create a JobClient for job control and monitoring > ---

[jira] [Closed] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded

2016-07-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3904. - Resolution: Fixed Fix Version/s: (was: 1.1.0) 1.2.0 Fixed vi

[jira] [Closed] (FLINK-4258) Potential null pointer dereference in SavepointCoordinator#onFullyAcknowledgedCheckpoint

2016-07-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4258. - Resolution: Fixed Assignee: Maximilian Michels Fix Version/s: 1.1.0 Thanks

[jira] [Commented] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies

2016-07-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15394031#comment-15394031 ] Maximilian Michels commented on FLINK-4161: --- Could you reopen the pull request?

[jira] [Resolved] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session

2016-07-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4156. --- Resolution: Fixed Fix Version/s: 1.1.0 Should be resolved with FLINK-4166. > J

[jira] [Resolved] (FLINK-4125) Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count

2016-07-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4125. --- Resolution: Duplicate Fix Version/s: 1.1.0 Resolving this but feel free to open

[jira] [Commented] (FLINK-4125) Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count

2016-07-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15394020#comment-15394020 ] Maximilian Michels commented on FLINK-4125: --- Hi! This has already been fixed for

<    2   3   4   5   6   7   8   9   10   11   >