[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] [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] [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] [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-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-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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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-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] [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] [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] [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] [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-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-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-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-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] [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=15446231#comment-15446231 ] Maximilian Michels commented on FLINK-4485: --- Thanks for the update. That's very

[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] [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] [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] [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] [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] [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] [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-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-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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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 Reverted back to Scalastyle version 0.8.0 and disabled Scalastyle fo

[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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [Commented] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

2016-11-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674631#comment-15674631 ] Maximilian Michels commented on FLINK-5081: --- Thanks for reporting! I couldn't re

[jira] [Updated] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

2016-11-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3133: -- Summary: Introduce collect()/count()/print() methods in DataStream API (was: Introduce

[jira] [Updated] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

2016-11-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3133: -- Description: The DataSet API's methods {{collect()}}, {{count()}}, and {{print()}} shoul

[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

2016-11-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674899#comment-15674899 ] Maximilian Michels commented on FLINK-3133: --- I've made some improvements in the

[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

2016-11-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674912#comment-15674912 ] Maximilian Michels commented on FLINK-3133: --- Hi [~AlexanderShoshin]! I've adjust

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-11-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675182#comment-15675182 ] Maximilian Michels commented on FLINK-2821: --- {quote} On the other hand I can't h

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-11-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675194#comment-15675194 ] Maximilian Michels commented on FLINK-2821: --- Thanks for your feedback [~melentye

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-11-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675221#comment-15675221 ] Maximilian Michels commented on FLINK-2821: --- Thanks you for your answers, [~phil

[jira] [Commented] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683082#comment-15683082 ] Maximilian Michels commented on FLINK-5081: --- I've had a second look. The issue i

[jira] [Assigned] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-5081: - Assignee: Maximilian Michels > unable to set yarn.maximum-failed-containers with

[jira] [Updated] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5081: -- Affects Version/s: 1.2.0 > unable to set yarn.maximum-failed-containers with flink one-t

[jira] [Updated] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5081: -- Fix Version/s: 1.1.4 1.2.0 > unable to set yarn.maximum-failed-contai

[jira] [Commented] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683099#comment-15683099 ] Maximilian Michels commented on FLINK-5071: --- Is this 1.1.3 or 1.2-SNAPSHOT? Coul

[jira] [Created] (FLINK-5108) Remove ClientShutdownHook during job execution

2016-11-21 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-5108: - Summary: Remove ClientShutdownHook during job execution Key: FLINK-5108 URL: https://issues.apache.org/jira/browse/FLINK-5108 Project: Flink Issue

[jira] [Comment Edited] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

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

[jira] [Comment Edited] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683082#comment-15683082 ] Maximilian Michels edited comment on FLINK-5081 at 11/21/16 11:23 AM: --

[jira] [Updated] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5081: -- Fix Version/s: (was: 1.1.4) (was: 1.2.0) > unable to set yarn

[jira] [Resolved] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-5081. --- Resolution: Not A Problem Resolving this issue but feel free to re-open in case I miss

[jira] [Commented] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683269#comment-15683269 ] Maximilian Michels commented on FLINK-5071: --- Thanks! This has changed recently a

[jira] [Updated] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5071: -- Affects Version/s: 1.1.4 1.2.0 > YARN: yarn.containers.vcores con

[jira] [Assigned] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-5071: - Assignee: Maximilian Michels > YARN: yarn.containers.vcores config not respected

[jira] [Updated] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5071: -- Fix Version/s: (was: 1.1.3) 1.1.4 1.2.0 > YARN

[jira] [Updated] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5071: -- Fix Version/s: (was: 1.1.4) > YARN: yarn.containers.vcores config not respected when

[jira] [Updated] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5071: -- Affects Version/s: (was: 1.1.4) > YARN: yarn.containers.vcores config not respected

[jira] [Resolved] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

2016-11-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-5071. --- Resolution: Fixed Fixed via 5836f7eddb4849b95d4860cf20045bc61d061918 on the master bra

[jira] [Commented] (FLINK-5121) Integrate YARN application ID with web interface

2016-11-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686901#comment-15686901 ] Maximilian Michels commented on FLINK-5121: --- The application id is already part

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

2016-11-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2608. - Resolution: Fixed Assignee: Alexander Chermenin Fix Version/s: 1.2.0 Fixed

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

2016-11-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-2608: --- > Arrays.asList(..) does not work with CollectionInputFormat > ---

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

2016-11-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2608: -- Fix Version/s: (was: 1.0.0) > Arrays.asList(..) does not work with CollectionInputFo

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

2016-11-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2608. - Resolution: Fixed Had to unarchive the 1.0.0 version temporarily because this had been tag

[jira] [Created] (FLINK-5149) ContinuousEventTimeTrigger doesn't fire at the end of the window

2016-11-23 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-5149: - Summary: ContinuousEventTimeTrigger doesn't fire at the end of the window Key: FLINK-5149 URL: https://issues.apache.org/jira/browse/FLINK-5149 Project: Fli

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-11-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15690454#comment-15690454 ] Maximilian Michels commented on FLINK-2821: --- My changes don't resolve the given

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-11-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15690461#comment-15690461 ] Maximilian Michels commented on FLINK-2821: --- Thanks for your feedback! I will op

[jira] [Resolved] (FLINK-4900) Implement Docker image support

2016-11-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4900. --- Resolution: Fixed Fix Version/s: 1.2.0 Merged with e8318d6f449b0b4720ca2377eae4

[jira] [Updated] (FLINK-5149) ContinuousEventTimeTrigger doesn't fire at the end of the window

2016-11-24 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5149: -- Affects Version/s: 1.2.0 > ContinuousEventTimeTrigger doesn't fire at the end of the win

  1   2   3   4   5   6   7   8   9   10   >