[GitHub] [flink] flinkbot edited a comment on issue #9825: [FLINK-14299] Introduce ProcessMetricGroup

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9825: [FLINK-14299] Introduce ProcessMetricGroup URL: https://github.com/apache/flink/pull/9825#issuecomment-536938289 ## CI report: * 53c41b006ae2155206a7843b67721b598b3591d1 : SUCCESS

[GitHub] [flink] tillrohrmann commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-537509801 > About the performance impact, lease refer to [the analysis of JDK CSLM

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330567573 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330566832 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330565842 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330565842 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330565096 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330564637 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330561678 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330561193 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-533068819 ## CI report: * 9cfda801891969ac460f45ea639d636b519f22db : FAILURE

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330560285 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9834: [bp-1.9][FLINK-13827][script] shell variable should be escaped

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9834: [bp-1.9][FLINK-13827][script] shell variable should be escaped URL: https://github.com/apache/flink/pull/9834#issuecomment-537478603 ## CI report: * 65dff9edaba9515d520fdefa5f4b9a7361d3e92f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9827: [FLINK-14303][metrics] Replace JobManagerMetricGroup with ResourceManagerMetricGroup in ResourceManager

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9827: [FLINK-14303][metrics] Replace JobManagerMetricGroup with ResourceManagerMetricGroup in ResourceManager URL: https://github.com/apache/flink/pull/9827#issuecomment-536948437 ## CI report: * fa367aaeb2089366de1d9497f1bbec9b11d75e72 :

[GitHub] [flink] flinkbot edited a comment on issue #9828: [FLINK-14305] Transfer ownership of JobManagerMetricGroup to Dispatcher

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9828: [FLINK-14305] Transfer ownership of JobManagerMetricGroup to Dispatcher URL: https://github.com/apache/flink/pull/9828#issuecomment-536958155 ## CI report: * 582fcdf7a275b9416d2e5f947352bf1310ff5d88 : FAILURE

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330557424 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9825: [FLINK-14299] Introduce ProcessMetricGroup

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9825: [FLINK-14299] Introduce ProcessMetricGroup URL: https://github.com/apache/flink/pull/9825#issuecomment-536938289 ## CI report: * 53c41b006ae2155206a7843b67721b598b3591d1 : SUCCESS

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r33054 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330554852 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330554289 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330552051 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330552051 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
1u0 commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330551710 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330551180 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330550525 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
1u0 commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330549295 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330548923 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r330547315 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330546245 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-533068819 ## CI report: * 9cfda801891969ac460f45ea639d636b519f22db : FAILURE

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r330546245 ## File path:

[GitHub] [flink] TisonKun commented on issue #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils

2019-10-02 Thread GitBox
TisonKun commented on issue #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils URL: https://github.com/apache/flink/pull/9682#issuecomment-537489792 Thanks for your review @zentol ! I can see your concern here. Actually the

[GitHub] [flink] GJL commented on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers

2019-10-02 Thread GitBox
GJL commented on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers URL: https://github.com/apache/flink/pull/8760#issuecomment-537489889 Thanks for updating the PR. I'll have another look This is an

[GitHub] [flink] 1u0 commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
1u0 commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330543800 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9834: [bp-1.9][FLINK-13827][script] shell variable should be escaped

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9834: [bp-1.9][FLINK-13827][script] shell variable should be escaped URL: https://github.com/apache/flink/pull/9834#issuecomment-537478603 ## CI report: * 65dff9edaba9515d520fdefa5f4b9a7361d3e92f : PENDING

[GitHub] [flink] tillrohrmann commented on issue #9827: [FLINK-14303][metrics] Replace JobManagerMetricGroup with ResourceManagerMetricGroup in ResourceManager

2019-10-02 Thread GitBox
tillrohrmann commented on issue #9827: [FLINK-14303][metrics] Replace JobManagerMetricGroup with ResourceManagerMetricGroup in ResourceManager URL: https://github.com/apache/flink/pull/9827#issuecomment-537488117 Thanks for the review @zentol. I've rebased and force pushed to let CI run

[GitHub] [flink] 1u0 commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

2019-10-02 Thread GitBox
1u0 commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r330540787 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11 URL: https://github.com/apache/flink/pull/9833#discussion_r330541171 ## File path:

[jira] [Commented] (FLINK-14225) Travis is unable to parse one of the secure environment variables

2019-10-02 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942797#comment-16942797 ] Gary Yao commented on FLINK-14225: -- [~StephanEwen] Can you help with this? > Travis is unable to parse

[GitHub] [flink] tillrohrmann commented on issue #9825: [FLINK-14299] Introduce ProcessMetricGroup

2019-10-02 Thread GitBox
tillrohrmann commented on issue #9825: [FLINK-14299] Introduce ProcessMetricGroup URL: https://github.com/apache/flink/pull/9825#issuecomment-537485842 Thanks for the review @zentol. I've addressed your comments and pushed a fixup.

[GitHub] [flink] tillrohrmann commented on a change in pull request #9825: [FLINK-14299] Introduce ProcessMetricGroup

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9825: [FLINK-14299] Introduce ProcessMetricGroup URL: https://github.com/apache/flink/pull/9825#discussion_r330539646 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java ##

[GitHub] [flink] tillrohrmann commented on a change in pull request #9825: [FLINK-14299] Introduce ProcessMetricGroup

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9825: [FLINK-14299] Introduce ProcessMetricGroup URL: https://github.com/apache/flink/pull/9825#discussion_r330539760 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java ##

[GitHub] [flink] GJL commented on issue #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout

2019-10-02 Thread GitBox
GJL commented on issue #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout URL: https://github.com/apache/flink/pull/9794#issuecomment-537485003 Merging as soon as build is green.

[GitHub] [flink] tillrohrmann edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

2019-10-02 Thread GitBox
tillrohrmann edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-537483004 One way to solve the problem could be ``` final int numVariables = 8; final double[] c = new

[GitHub] [flink] tillrohrmann commented on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

2019-10-02 Thread GitBox
tillrohrmann commented on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-537483004 One way to solve the problem could be ``` final int numVariables = 8; final double[] c = new

[GitHub] [flink] flinkbot commented on issue #9834: [bp-1.9][FLINK-13827][script] shell variable should be escaped

2019-10-02 Thread GitBox
flinkbot commented on issue #9834: [bp-1.9][FLINK-13827][script] shell variable should be escaped URL: https://github.com/apache/flink/pull/9834#issuecomment-537478603 ## CI report: * 65dff9edaba9515d520fdefa5f4b9a7361d3e92f : UNKNOWN

[GitHub] [flink] zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

2019-10-02 Thread GitBox
zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#discussion_r330530781 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

2019-10-02 Thread GitBox
zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#discussion_r330529529 ## File path:

[GitHub] [flink] tillrohrmann edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

2019-10-02 Thread GitBox
tillrohrmann edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-537474186 Yes, all explicitly configured values should be respected. I agree, the default values of * Framework

[jira] [Commented] (FLINK-14271) Deprecate legacy RestartPipelinedRegionStrategy

2019-10-02 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942781#comment-16942781 ] Zhu Zhu commented on FLINK-14271: - Thanks [~trohrmann]! Let's wait for [~stevenz3wu]'s feedback. >

[GitHub] [flink] tillrohrmann commented on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

2019-10-02 Thread GitBox
tillrohrmann commented on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-537474186 Yes, all explicitly configured values should be respected. I agree, the default values of * Framework Heap

[GitHub] [flink] AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r330522645 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

2019-10-02 Thread GitBox
GJL commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#discussion_r330522635 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r330521780 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330461900 ## File path:

[GitHub] [flink] zentol merged pull request #9740: [hotfix][docs] URL should not point to release-1.8 docs

2019-10-02 Thread GitBox
zentol merged pull request #9740: [hotfix][docs] URL should not point to release-1.8 docs URL: https://github.com/apache/flink/pull/9740 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330513099 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330464428 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330516878 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330517177 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330516661 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330478001 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330515584 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330476481 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330475591 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330515293 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-02 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r330474001 ## File path:

[GitHub] [flink] zentol commented on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

2019-10-02 Thread GitBox
zentol commented on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798#issuecomment-537467031 _As usual_, please include a screenshot of the WebUI when modifying it.

[GitHub] [flink] flinkbot commented on issue #9834: [bp-1.9][FLINK-13827][script] shell variable should be escaped

2019-10-02 Thread GitBox
flinkbot commented on issue #9834: [bp-1.9][FLINK-13827][script] shell variable should be escaped URL: https://github.com/apache/flink/pull/9834#issuecomment-537466604 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] TisonKun opened a new pull request #9834: [FLINK-13827][script] shell variable should be escaped

2019-10-02 Thread GitBox
TisonKun opened a new pull request #9834: [FLINK-13827][script] shell variable should be escaped URL: https://github.com/apache/flink/pull/9834 See also #9800 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-13827) shell variable should be escaped in start-scala-shell.sh

2019-10-02 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942754#comment-16942754 ] Zili Chen commented on FLINK-13827: --- master via 865cc4c7a39f7aa610a02cc4a0f41424edcd6279 > shell

[jira] [Comment Edited] (FLINK-14300) StreamTask#invoke leaks threads if OperatorChain fails to be constructed

2019-10-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942753#comment-16942753 ] Piotr Nowojski edited comment on FLINK-14300 at 10/2/19 12:11 PM: -- Hi

[jira] [Updated] (FLINK-14300) StreamTask#invoke leaks threads if OperatorChain fails to be constructed

2019-10-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-14300: --- Fix Version/s: 1.10.0 > StreamTask#invoke leaks threads if OperatorChain fails to be

[GitHub] [flink] TisonKun closed pull request #9800: [FLINK-13827][script] shell variable should be escaped

2019-10-02 Thread GitBox
TisonKun closed pull request #9800: [FLINK-13827][script] shell variable should be escaped URL: https://github.com/apache/flink/pull/9800 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] TisonKun commented on issue #9800: [FLINK-13827][script] shell variable should be escaped

2019-10-02 Thread GitBox
TisonKun commented on issue #9800: [FLINK-13827][script] shell variable should be escaped URL: https://github.com/apache/flink/pull/9800#issuecomment-537463641 master via 865cc4c7a39f7aa610a02cc4a0f41424edcd6279 This is an

[jira] [Commented] (FLINK-14300) StreamTask#invoke leaks threads if OperatorChain fails to be constructed

2019-10-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942753#comment-16942753 ] Piotr Nowojski commented on FLINK-14300: Hi [~mklein0]. Thank you for reporting and proposing a

[GitHub] [flink] flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese URL: https://github.com/apache/flink/pull/9815#issuecomment-536343016 ## CI report: * 615acdb2511760c55f8831934f710678a8962acc : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#issuecomment-536005650 ## CI report: * 757ae54b3f31a82334fae36d6e714c6aa9ac6581 : FAILURE

[GitHub] [flink] TisonKun commented on issue #9800: [FLINK-13827][script] shell variable should be escaped

2019-10-02 Thread GitBox
TisonKun commented on issue #9800: [FLINK-13827][script] shell variable should be escaped URL: https://github.com/apache/flink/pull/9800#issuecomment-537457189 Thanks for your review @xintongsong & @zentol . Merging to master... @wuchong given there is a release progress under

[jira] [Closed] (FLINK-14214) Performance regression in TwoInputStreamOperator

2019-10-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14214. -- Resolution: Cannot Reproduce > Performance regression in TwoInputStreamOperator >

[GitHub] [flink] pnowojski merged pull request #9779: [FLINK-14214][runtime] Shortcut isAvailable().isDone() anti-starvation check in StreamTwoInputProcesso

2019-10-02 Thread GitBox
pnowojski merged pull request #9779: [FLINK-14214][runtime] Shortcut isAvailable().isDone() anti-starvation check in StreamTwoInputProcesso URL: https://github.com/apache/flink/pull/9779 This is an automated message from

[GitHub] [flink] zentol commented on a change in pull request #9825: [FLINK-14299] Introduce ProcessMetricGroup

2019-10-02 Thread GitBox
zentol commented on a change in pull request #9825: [FLINK-14299] Introduce ProcessMetricGroup URL: https://github.com/apache/flink/pull/9825#discussion_r330501737 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java ## @@

[GitHub] [flink] zentol commented on a change in pull request #9825: [FLINK-14299] Introduce ProcessMetricGroup

2019-10-02 Thread GitBox
zentol commented on a change in pull request #9825: [FLINK-14299] Introduce ProcessMetricGroup URL: https://github.com/apache/flink/pull/9825#discussion_r330499346 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java ## @@

[GitHub] [flink] flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#issuecomment-536005650 ## CI report: * 757ae54b3f31a82334fae36d6e714c6aa9ac6581 : FAILURE

[GitHub] [flink] zentol merged pull request #9668: [hotfix][docs] Fix the wrong characters in the document(building.md, building.zh.md)

2019-10-02 Thread GitBox
zentol merged pull request #9668: [hotfix][docs] Fix the wrong characters in the document(building.md,building.zh.md) URL: https://github.com/apache/flink/pull/9668 This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-13516) YARNSessionFIFOSecuredITCase fails on Java 11

2019-10-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13516. Resolution: Fixed master: d35f6990eb402a2137826b62bca11437728da9c1 >

[GitHub] [flink] zentol merged pull request #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11

2019-10-02 Thread GitBox
zentol merged pull request #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11 URL: https://github.com/apache/flink/pull/9622 This is an automated message from the

[GitHub] [flink] zentol commented on issue #9504: [FLINK-13799][web]: fix error message web submit is disables in the c…

2019-10-02 Thread GitBox
zentol commented on issue #9504: [FLINK-13799][web]: fix error message web submit is disables in the c… URL: https://github.com/apache/flink/pull/9504#issuecomment-537446272 @vthinkxie FLINK-13817 exposes whether submissions are enabled in a more reliable way. The configuration is is

[GitHub] [flink] flinkbot edited a comment on issue #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11 URL: https://github.com/apache/flink/pull/9833#issuecomment-537431999 ## CI report: * 5077c53b7d163f49e5d4a8414c6c0598d4fdb060 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese URL: https://github.com/apache/flink/pull/9815#issuecomment-536343016 ## CI report: * 615acdb2511760c55f8831934f710678a8962acc : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#issuecomment-536005650 ## CI report: * 757ae54b3f31a82334fae36d6e714c6aa9ac6581 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11 URL: https://github.com/apache/flink/pull/9833#issuecomment-537431999 ## CI report: * 5077c53b7d163f49e5d4a8414c6c0598d4fdb060 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese URL: https://github.com/apache/flink/pull/9815#issuecomment-536343016 ## CI report: * 615acdb2511760c55f8831934f710678a8962acc : FAILURE

[GitHub] [flink] zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

2019-10-02 Thread GitBox
zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#discussion_r330483271 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9779: [FLINK-14214][runtime] Shortcut isAvailable().isDone() anti-starvation check in StreamTwoInputProcesso

2019-10-02 Thread GitBox
flinkbot edited a comment on issue #9779: [FLINK-14214][runtime] Shortcut isAvailable().isDone() anti-starvation check in StreamTwoInputProcesso URL: https://github.com/apache/flink/pull/9779#issuecomment-535521325 ## CI report: * 42064500d00956c47a8b37b678c4c9b43170ac4a :

[GitHub] [flink] zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

2019-10-02 Thread GitBox
zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#discussion_r330480845 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

2019-10-02 Thread GitBox
zhuzhurk commented on a change in pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#discussion_r330480920 ## File path:

[GitHub] [flink] flinkbot commented on issue #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11

2019-10-02 Thread GitBox
flinkbot commented on issue #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11 URL: https://github.com/apache/flink/pull/9833#issuecomment-537431999 ## CI report: * 5077c53b7d163f49e5d4a8414c6c0598d4fdb060 : UNKNOWN

[jira] [Commented] (FLINK-14295) Nightly flink-runtime failed with java 11

2019-10-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942676#comment-16942676 ] Chesnay Schepler commented on FLINK-14295: -- Let's split this into 2 tickets since there are 2

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

2019-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r330469316 ## File path:

<    1   2   3   >