[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354210083 ## File path:

[GitHub] [flink] zentol merged pull request #10363: [FLINK-14104][build] Upgrade to flink-shaded 9.0

2019-12-05 Thread GitBox
zentol merged pull request #10363: [FLINK-14104][build] Upgrade to flink-shaded 9.0 URL: https://github.com/apache/flink/pull/10363 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354208892 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

2019-12-05 Thread GitBox
carp84 commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#discussion_r354209108 ## File path:

[GitHub] [flink] TisonKun commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
TisonKun commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-562057572 I address the comments. Will rebase later. This is

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

2019-12-05 Thread GitBox
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354207645 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

2019-12-05 Thread GitBox
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354207645 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354184876 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354204395 ## File path: tools/jenkins/run_case.py ## @@ -0,0 +1,131 @@

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354206567 ## File path: tools/jenkins/utils.py ## @@ -0,0 +1,70 @@

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354183164 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354206465 ## File path: tools/jenkins/utils.py ## @@ -0,0 +1,70 @@

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354199881 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354202268 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354200974 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354184888 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354202705 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354185294 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354175138 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354172620 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354203132 ## File path: tools/jenkins/run_case.py ## @@ -0,0 +1,131 @@

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354197180 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

2019-12-05 Thread GitBox
klion26 commented on a change in pull request #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#discussion_r354184006 ## File path: tools/jenkins/restapi_common.py ## @@ -0,0

[GitHub] [flink] aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-562055537 Also, feel free to rebase on master and squash into final commits when you're done with addressing the comments. That

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354205253 ## File path:

[jira] [Assigned] (FLINK-15031) Calculate required shuffle memory cases before allocating slots in resources specified

2019-12-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15031: - Assignee: Zhu Zhu > Calculate required shuffle memory cases before allocating slots in

[GitHub] [flink] aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354204878 ## File path: flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java

[GitHub] [flink] carp84 commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

2019-12-05 Thread GitBox
carp84 commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#discussion_r354204039 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

2019-12-05 Thread GitBox
carp84 commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#discussion_r354204499 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354203645 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354203808 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354202847 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

2019-12-05 Thread GitBox
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354196126 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354202101 ## File path: flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java

[GitHub] [flink] TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354202037 ## File path: flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354201105 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354200552 ## File path: flink-core/src/main/java/org/apache/flink/core/execution/JobClient.java

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354179274 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354200321 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
TisonKun commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354199784 ## File path: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java

[GitHub] [flink] aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354200182 ## File path: flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354199195 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

2019-12-05 Thread GitBox
xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#discussion_r354198697 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354198627 ## File path:

[jira] [Updated] (FLINK-15074) Connection timed out, Standalone cluster

2019-12-05 Thread gameking (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gameking updated FLINK-15074: - Summary: Connection timed out, Standalone cluster (was: Connection timed out, Standalone) >

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r35419 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354197703 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

2019-12-05 Thread GitBox
flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126#issuecomment-551413525 ## CI report: *

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

2019-12-05 Thread GitBox
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354196126 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354197011 ## File path: flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354197125 ## File path:

[jira] [Resolved] (FLINK-14781) [ZH] clarify that a RocksDB dependency in pom.xml may not be needed

2019-12-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14781. - Resolution: Fixed Fixed in 1.10.0: 4b95648975056db58c6d5a669aad9d6fbd6e9f99 > [ZH] clarify that a

[jira] [Updated] (FLINK-14781) [ZH] clarify that a RocksDB dependency in pom.xml may not be needed

2019-12-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14781: Fix Version/s: 1.10.0 > [ZH] clarify that a RocksDB dependency in pom.xml may not be needed >

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354196649 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354195897 ## File path: flink-core/src/main/java/org/apache/flink/core/execution/JobClient.java

[GitHub] [flink] wuchong merged pull request #10206: [FLINK-14781] [docs-zh] correct the state_backends.zh external link and some other things

2019-12-05 Thread GitBox
wuchong merged pull request #10206: [FLINK-14781] [docs-zh] correct the state_backends.zh external link and some other things URL: https://github.com/apache/flink/pull/10206 This is an automated message from the Apache Git

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

2019-12-05 Thread GitBox
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354196126 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354195543 ## File path: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java

[GitHub] [flink] flinkbot commented on issue #10434: [FLINK-15072][client] Hijack executeAsync instead of execute in context environment

2019-12-05 Thread GitBox
flinkbot commented on issue #10434: [FLINK-15072][client] Hijack executeAsync instead of execute in context environment URL: https://github.com/apache/flink/pull/10434#issuecomment-562048009 ## CI report: * 3657f8be3e9a8eb83712a9eeafe0bc8e3c182c95 : UNKNOWN Bot

[GitHub] [flink] flinkbot commented on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

2019-12-05 Thread GitBox
flinkbot commented on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#issuecomment-562048103 ## CI report: * d07737bd54c586aa87204c6ac298309f432cc06c : UNKNOWN Bot

[GitHub] [flink] aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
aljoscha commented on a change in pull request #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#discussion_r354194861 ## File path:

[GitHub] [flink] flinkbot commented on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp

2019-12-05 Thread GitBox
flinkbot commented on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp URL: https://github.com/apache/flink/pull/10432#issuecomment-562047809 ## CI report: * a69782464ce80d238c4ea94045b603738d62d13c : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot commented on issue #10433: [FLINK-15071] YARN vcore capacity check can not pass when use large slotPerTaskManager

2019-12-05 Thread GitBox
flinkbot commented on issue #10433: [FLINK-15071] YARN vcore capacity check can not pass when use large slotPerTaskManager URL: https://github.com/apache/flink/pull/10433#issuecomment-562047908 ## CI report: * ad17546e86c7273f447591448b9bea9dafa83d8e : UNKNOWN Bot

[GitHub] [flink] aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments

2019-12-05 Thread GitBox
aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-562047708 Yes, the `JobContext` seems good to me! What do you think, @zjffdu?

[GitHub] [flink] flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment

2019-12-05 Thread GitBox
flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619 ## CI report: * e0b1afaebe5bd4fc07e61785a38ef82f55e16f69 :

[GitHub] [flink] flinkbot edited a comment on issue #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

2019-12-05 Thread GitBox
flinkbot edited a comment on issue #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#issuecomment-562033539 ## CI report: * 735df4f522069f08b8b4b26a0018a6440293c507 :

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354193828 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354193534 ## File path:

[GitHub] [flink] klion26 commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

2019-12-05 Thread GitBox
klion26 commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api URL: https://github.com/apache/flink/pull/10344#issuecomment-562047203 Currently, I set the default value of "stateBackend" to "disabled", because when I run job(disabled

[GitHub] [flink] flinkbot edited a comment on issue #10415: [FLINK-15049][table-planner-blink] Compile error when hash join with …

2019-12-05 Thread GitBox
flinkbot edited a comment on issue #10415: [FLINK-15049][table-planner-blink] Compile error when hash join with … URL: https://github.com/apache/flink/pull/10415#issuecomment-561528911 ## CI report: * e838831b098e3043b6576aec5ba38ee6bdc29422 : FAILURE

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

2019-12-05 Thread GitBox
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354193194 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354193043 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354193089 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354192518 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

2019-12-05 Thread GitBox
flinkbot edited a comment on issue #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#issuecomment-561380440 ## CI report: * 0effd7f6b294b7f2da91c7681aa6e8ae51390efc : UNKNOWN *

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354192518 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354191889 ## File path:

[jira] [Created] (FLINK-15074) Connection timed out, Standalone

2019-12-05 Thread gameking (Jira)
gameking created FLINK-15074: Summary: Connection timed out, Standalone Key: FLINK-15074 URL: https://issues.apache.org/jira/browse/FLINK-15074 Project: Flink Issue Type: Bug

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354191588 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

2019-12-05 Thread GitBox
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354191429 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354191336 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

2019-12-05 Thread GitBox
JingsongLi commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354191173 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354191336 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354190944 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354190647 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354190715 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

2019-12-05 Thread GitBox
flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api URL: https://github.com/apache/flink/pull/10344#issuecomment-559371382 ## CI report: * fbd6e8914b49348a275657130ebdd9413d7d17c6 : SUCCESS

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354189844 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

2019-12-05 Thread GitBox
JingsongLi commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354189419 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute

2019-12-05 Thread GitBox
flinkbot edited a comment on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute URL: https://github.com/apache/flink/pull/10316#issuecomment-558248395 ## CI report: * 3624bce085de9f708f4d5fb4a8a7617884c0adf8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

2019-12-05 Thread GitBox
flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199 ## CI report: * 0b265d192e2a6024e5817317be0317136208ccaf : SUCCESS

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-12-05 Thread GitBox
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354188862 ## File path:

[jira] [Updated] (FLINK-15072) Hijack executeAsync instead of execute in context environment

2019-12-05 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-15072: -- Description: See also the pull request. > Hijack executeAsync instead of execute in context

[GitHub] [flink] wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

2019-12-05 Thread GitBox
wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354188018 ## File path:

[jira] [Closed] (FLINK-14890) TestHarness for KeyedBroadcastProcessFunction

2019-12-05 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14890. Fix Version/s: 1.10.0 Resolution: Fixed Implemented on master in

[GitHub] [flink] WeiZhong94 commented on issue #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py

2019-12-05 Thread GitBox
WeiZhong94 commented on issue #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py URL: https://github.com/apache/flink/pull/10389#issuecomment-562042910 @HuangXingBo Thanks for your review! I have removed the

[GitHub] [flink] flinkbot edited a comment on issue #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints

2019-12-05 Thread GitBox
flinkbot edited a comment on issue #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints URL: https://github.com/apache/flink/pull/10249#issuecomment-555440054 ## CI report: * bd253651412e9ca6857cf0ba299bdd1bf544c2c4 : SUCCESS

[GitHub] [flink] WeiZhong94 commented on a change in pull request #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py

2019-12-05 Thread GitBox
WeiZhong94 commented on a change in pull request #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py URL: https://github.com/apache/flink/pull/10389#discussion_r354187503 ## File path:

[GitHub] [flink] aljoscha commented on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions

2019-12-05 Thread GitBox
aljoscha commented on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions URL: https://github.com/apache/flink/pull/10286#issuecomment-562042753 Thanks! I merged this and put some minor changes on top. 

[GitHub] [flink] aljoscha closed pull request #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions

2019-12-05 Thread GitBox
aljoscha closed pull request #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions URL: https://github.com/apache/flink/pull/10286 This is an automated message from the Apache Git Service. To

<    3   4   5   6   7   8   9   10   >