[GitHub] flink issue #4935: [Flink-7945][Metrics]Fix per partition-lag metr...

2017-11-03 Thread Aitozi
Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/4935 update the code according to the comment. ping @tzulitai ---

[jira] [Commented] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238759#comment-16238759 ] ASF GitHub Bot commented on FLINK-7977: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #4945: [FLINK-7977][build] bump version of compatibility ...

2017-11-03 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4945 [FLINK-7977][build] bump version of compatibility check for Flink 1.4 ## What is the purpose of the change Since Flink maintains backward compatibility check for 2 versions, Flink 1.4

[jira] [Updated] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7977: Component/s: Build System > bump version of compatibility check for Flink 1.4 >

[jira] [Created] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-03 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7977: --- Summary: bump version of compatibility check for Flink 1.4 Key: FLINK-7977 URL: https://issues.apache.org/jira/browse/FLINK-7977 Project: Flink Issue Type:

[jira] [Updated] (FLINK-7976) bump japicmp-maven-plugin version in Flink

2017-11-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7976: Fix Version/s: 1.5.0 > bump japicmp-maven-plugin version in Flink >

[jira] [Updated] (FLINK-7976) bump japicmp-maven-plugin version in Flink

2017-11-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7976: Affects Version/s: 1.4.0 > bump japicmp-maven-plugin version in Flink >

[jira] [Created] (FLINK-7976) bump japicmp-maven-plugin version in Flink

2017-11-03 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7976: --- Summary: bump japicmp-maven-plugin version in Flink Key: FLINK-7976 URL: https://issues.apache.org/jira/browse/FLINK-7976 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #4944: [hotfix] add space bewteen error message lines

2017-11-03 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4944 [hotfix] add space bewteen error message lines ## What is the purpose of the change add space bewteen error message lines ## Brief change log add space bewteen error

[jira] [Assigned] (FLINK-7717) Port TaskManagerMetricsHandler to new REST endpoint

2017-11-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7717: --- Assignee: (was: Bowen Li) > Port TaskManagerMetricsHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint

2017-11-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7716: --- Assignee: (was: Bowen Li) > Port JobManagerMetricsHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint

2017-11-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7718: --- Assignee: (was: Bowen Li) > Port JobVertixMetricsHandler to new REST endpoint >

[jira] [Commented] (FLINK-7949) AsyncWaitOperator is not restarting when queue is full

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238298#comment-16238298 ] ASF GitHub Bot commented on FLINK-7949: --- Github user bartektartanus commented on the issue:

[GitHub] flink issue #4924: [FLINK-7949] AsyncWaitOperator is not restarting when que...

2017-11-03 Thread bartektartanus
Github user bartektartanus commented on the issue: https://github.com/apache/flink/pull/4924 Yes, it fixes our issue - now our test in [nussknacker](https://github.com/TouK/nussknacker) is passing. Process restarts seamlessly and works fine even after another restarts, but I haven't

[jira] [Closed] (FLINK-7973) Fix service shading relocation for S3 file systems

2017-11-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7973. --- > Fix service shading relocation for S3 file systems > --

[jira] [Resolved] (FLINK-7973) Fix service shading relocation for S3 file systems

2017-11-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7973. - Fixed via 84d0677f98f81d50411957103be82993e40f587a > Fix service shading relocation for S3 file

[GitHub] flink pull request #4943: [FLINK-6022] [avro] Use Avro to serialize Avro in ...

2017-11-03 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/4943 [FLINK-6022] [avro] Use Avro to serialize Avro in flight and in State ## What is the purpose of the change This changes Avro types to be serialized with a proper Avro serializer. The

[jira] [Commented] (FLINK-6022) Improve support for Avro GenericRecord

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238287#comment-16238287 ] ASF GitHub Bot commented on FLINK-6022: --- GitHub user StephanEwen opened a pull request:

[jira] [Commented] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238114#comment-16238114 ] ASF GitHub Bot commented on FLINK-7856: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4893: [FLINK-7856][flip6] Port JobVertexBackPressureHand...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4893#discussion_r148857309 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexBackPressureHandler.java --- @@ -0,0 +1,134 @@ +/* +

[GitHub] flink pull request #4893: [FLINK-7856][flip6] Port JobVertexBackPressureHand...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4893#discussion_r148857541 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureHeaders.java --- @@ -0,0 +1,68 @@ +/* + *

[jira] [Commented] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238115#comment-16238115 ] ASF GitHub Bot commented on FLINK-7856: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7949) AsyncWaitOperator is not restarting when queue is full

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238103#comment-16238103 ] ASF GitHub Bot commented on FLINK-7949: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4924: [FLINK-7949] AsyncWaitOperator is not restarting when que...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4924 Thanks for the fix @bartektartanus. LGTM. Did you verify that this actually fixes the problem? Would be great if we could also add a unit test to guard against future regressions.

[jira] [Resolved] (FLINK-7847) Fix typo in flink-avro shading pattern

2017-11-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7847. - Resolution: Fixed Fixed via b4dead96a16c8772ccf86b533f5de6feb0f3d1f6 > Fix typo in flink-avro

[jira] [Closed] (FLINK-7847) Fix typo in flink-avro shading pattern

2017-11-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7847. --- > Fix typo in flink-avro shading pattern > -- > >

[jira] [Closed] (FLINK-7420) Move all Avro code to flink-avro

2017-11-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7420. --- > Move all Avro code to flink-avro > > > Key: FLINK-7420

[jira] [Resolved] (FLINK-7420) Move all Avro code to flink-avro

2017-11-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7420. - Resolution: Fixed Fixed in - 537a10ea2ff6a2d8507483c66f413f77884e77c4 -

[jira] [Closed] (FLINK-7972) Move SerializationSchema to flink-core

2017-11-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7972. --- > Move SerializationSchema to flink-core > -- > >

[jira] [Resolved] (FLINK-7972) Move SerializationSchema to flink-core

2017-11-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7972. - Resolution: Fixed Fixed in fe931d075f031e9494fd26dbeed4bb1024bd52cf > Move SerializationSchema

[GitHub] flink issue #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to new RES...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4734 I think @zentol is right and we can register the `CurrentJobsOverviewHandler` under `jobs/overview`. Thus, we should add this handler as well. Could you rebase this handler onto the latest

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238027#comment-16238027 ] ASF GitHub Bot commented on FLINK-7652: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238018#comment-16238018 ] ASF GitHub Bot commented on FLINK-7420: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4942: [FLINK-7420] [avro] Move all Avro code to flink-av...

2017-11-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4942 ---

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238017#comment-16238017 ] ASF GitHub Bot commented on FLINK-7420: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4931: [FLINK-7420] Move all Avro code to flink-avro

2017-11-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4931 ---

[jira] [Assigned] (FLINK-7975) Queryable state client does not wait for shutdown completion

2017-11-03 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-7975: - Assignee: Kostas Kloudas > Queryable state client does not wait for shutdown completion

[jira] [Assigned] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

2017-11-03 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-7974: - Assignee: Kostas Kloudas > AbstractServerBase#shutdown does not wait for shutdown

[jira] [Created] (FLINK-7975) Queryable state client does not wait for shutdown completion

2017-11-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7975: Summary: Queryable state client does not wait for shutdown completion Key: FLINK-7975 URL: https://issues.apache.org/jira/browse/FLINK-7975 Project: Flink

[jira] [Created] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

2017-11-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7974: Summary: AbstractServerBase#shutdown does not wait for shutdown completion Key: FLINK-7974 URL: https://issues.apache.org/jira/browse/FLINK-7974 Project: Flink

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237763#comment-16237763 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237749#comment-16237749 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237761#comment-16237761 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237750#comment-16237750 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237748#comment-16237748 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237747#comment-16237747 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237755#comment-16237755 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237760#comment-16237760 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237746#comment-16237746 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237757#comment-16237757 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237762#comment-16237762 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237759#comment-16237759 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237751#comment-16237751 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237764#comment-16237764 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237758#comment-16237758 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237745#comment-16237745 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237754#comment-16237754 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237756#comment-16237756 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237752#comment-16237752 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237753#comment-16237753 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148814381 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148811288 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148811085 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148814354 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148810594 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnWorkerNode.java --- @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148814557 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148812650 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148807573 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -63,11 +64,14 @@ * The yarn implementation of the

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148810490 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnWorkerNode.java --- @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237744#comment-16237744 ] ASF GitHub Bot commented on FLINK-7076: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148812132 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148810078 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnWorkerNode.java --- @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148810409 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnWorkerNode.java --- @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148811663 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148811956 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148814129 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148808279 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -227,14 +241,27 @@ public void startNewWorker(ResourceProfile

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148813642 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148808362 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -227,14 +241,27 @@ public void startNewWorker(ResourceProfile

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148809690 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -260,6 +287,7 @@ public void onContainersAllocated(List

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148808721 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -63,11 +64,14 @@ * The yarn implementation of the

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r148808482 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -227,14 +241,27 @@ public void startNewWorker(ResourceProfile

[jira] [Commented] (FLINK-7706) Port JobAccumulatorsHandler to new REST endpoint

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237686#comment-16237686 ] ASF GitHub Bot commented on FLINK-7706: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4898: [FLINK-7706] [flip6] Add JobAccumulatorsHandler fo...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4898#discussion_r148802300 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java --- @@ -0,0 +1,128 @@ +/* + * Licensed

[GitHub] flink issue #4942: [FLINK-7420] [avro] Move all Avro code to flink-avro (fol...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4942 Great fix for our Avro dependency @StephanEwen, @aljoscha and @twalthr. +1 for merging. ---

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237672#comment-16237672 ] ASF GitHub Bot commented on FLINK-7420: --- Github user tillrohrmann commented on the issue:

[jira] [Created] (FLINK-7973) Fix service shading relocation for S3 file systems

2017-11-03 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-7973: --- Summary: Fix service shading relocation for S3 file systems Key: FLINK-7973 URL: https://issues.apache.org/jira/browse/FLINK-7973 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237632#comment-16237632 ] ASF GitHub Bot commented on FLINK-7420: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4942: [FLINK-7420] [avro] Move all Avro code to flink-av...

2017-11-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4942#discussion_r148789659 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoRegistrationSerializerConfigSnapshot.java --- @@ -217,7 +217,7 @@

[jira] [Comment Edited] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-11-03 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237616#comment-16237616 ] Gary Yao edited comment on FLINK-7880 at 11/3/17 1:55 PM: -- I have further

[jira] [Commented] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-11-03 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237616#comment-16237616 ] Gary Yao commented on FLINK-7880: - I have further isolated the problem. The problem still appears even if

[jira] [Comment Edited] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-11-03 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237584#comment-16237584 ] Kostas Kloudas edited comment on FLINK-7880 at 11/3/17 1:38 PM: I will

[jira] [Commented] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-11-03 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237584#comment-16237584 ] Kostas Kloudas commented on FLINK-7880: --- I will keep on investigating *BUT* I commented out the

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237579#comment-16237579 ] ASF GitHub Bot commented on FLINK-7420: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4942: [FLINK-7420] [avro] Move all Avro code to flink-avro (fol...

2017-11-03 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4942 Personally, I like this Jenkins fellow more... 😉 ---

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237564#comment-16237564 ] ASF GitHub Bot commented on FLINK-7420: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4942: [FLINK-7420] [avro] Move all Avro code to flink-avro (fol...

2017-11-03 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4942 Lets see if Travis agrees. That guy has opinions... ---

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237557#comment-16237557 ] ASF GitHub Bot commented on FLINK-7420: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4942: [FLINK-7420] [avro] Move all Avro code to flink-avro (fol...

2017-11-03 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4942 The follow-up changes look good! (it's very easy to review since it's clearly separated. 😃) If you reviewed Timo's and my changes I would say this is good to go. ---

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237468#comment-16237468 ] ASF GitHub Bot commented on FLINK-4228: --- Github user NicoK commented on a diff in the pull request:

  1   2   >