[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r34331 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster.

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster. URL: https://github.com/apache/flink/pull/10245#issuecomment-555375223 ## CI report: * 71f8401be1cb214e56f94e486c495ef7c800cfc4 : PENDING

[GitHub] [flink] KurtYoung commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
KurtYoung commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347783215 ## File path:

[jira] [Created] (FLINK-14851) Make the (Stream)ContextEnvironment use the Executors

2019-11-19 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-14851: -- Summary: Make the (Stream)ContextEnvironment use the Executors Key: FLINK-14851 URL: https://issues.apache.org/jira/browse/FLINK-14851 Project: Flink

[GitHub] [flink] dawidwys commented on a change in pull request #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig

2019-11-19 Thread GitBox
dawidwys commented on a change in pull request #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig URL: https://github.com/apache/flink/pull/10217#discussion_r347784990 ## File path: flink-core/src/main/java/org/apache/flink/api/common/time/Time.java

[jira] [Commented] (FLINK-14851) Make the (Stream)ContextEnvironment use the Executors

2019-11-19 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977242#comment-16977242 ] Zili Chen commented on FLINK-14851: --- I think it could be a step to decouple dependency from

[GitHub] [flink] flinkbot commented on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

2019-11-19 Thread GitBox
flinkbot commented on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-555390439 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Commented] (FLINK-14850) Refactor Executor interface and introduce a minimal JobClient interface

2019-11-19 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977240#comment-16977240 ] Zili Chen commented on FLINK-14850: --- Go ahead! > Refactor Executor interface and introduce a minimal

[jira] [Updated] (FLINK-14853) Use higher granularity units in generated docs for Duration & MemorySize if possible

2019-11-19 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14853: - Description: It was mentioned on two occasions

[GitHub] [flink] docete commented on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

2019-11-19 Thread GitBox
docete commented on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#issuecomment-555400884 > 07:50:04.510 [ERROR] src/test/java/org/apache/flink/table/dataformat/vector/VectorizedColumnBatchTest.java:[34]

[GitHub] [flink] JingsongLi commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table

2019-11-19 Thread GitBox
JingsongLi commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#discussion_r347800163 ## File path:

[GitHub] [flink] HuangXingBo commented on issue #10103: [FLINK-14506][python][build] Improve the release script for Python API release package

2019-11-19 Thread GitBox
HuangXingBo commented on issue #10103: [FLINK-14506][python][build] Improve the release script for Python API release package URL: https://github.com/apache/flink/pull/10103#issuecomment-555404477 @WeiZhong94 Thanks a lot for your review, I have addressed the comments at latest commit.

[GitHub] [flink] klion26 opened a new pull request #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions

2019-11-19 Thread GitBox
klion26 opened a new pull request #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions URL: https://github.com/apache/flink/pull/10248 ## What is the purpose of the change Migrate duration and memory size ConfigOptions in

[GitHub] [flink] flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster.

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster. URL: https://github.com/apache/flink/pull/10245#issuecomment-555375223 ## CI report: * 71f8401be1cb214e56f94e486c495ef7c800cfc4 : FAILURE

[GitHub] [flink] aljoscha commented on a change in pull request #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig

2019-11-19 Thread GitBox
aljoscha commented on a change in pull request #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig URL: https://github.com/apache/flink/pull/10217#discussion_r347814973 ## File path:

[GitHub] [flink] GJL commented on issue #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

2019-11-19 Thread GitBox
GJL commented on issue #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10152#issuecomment-555415983 Merging. Documentation can be fixed later.

[GitHub] [flink] flinkbot edited a comment on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#issuecomment-554261720 ## CI report: * 95ec85f121bef0d4c51ed9846e35277c26c58aac : FAILURE

[jira] [Comment Edited] (FLINK-14815) Expose network pool usage in IOMetricsInfo

2019-11-19 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977303#comment-16977303 ] lining edited comment on FLINK-14815 at 11/19/19 9:39 AM: -- For the pool usages,

[GitHub] [flink] hequn8128 closed pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.

2019-11-19 Thread GitBox
hequn8128 closed pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061

[jira] [Closed] (FLINK-14581) Support to run Python UDF jobs in a YARN cluster

2019-11-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14581. --- Resolution: Resolved > Support to run Python UDF jobs in a YARN cluster >

[GitHub] [flink] klion26 commented on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions

2019-11-19 Thread GitBox
klion26 commented on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions URL: https://github.com/apache/flink/pull/10248#issuecomment-555419565 cc @dawidwys

[jira] [Commented] (FLINK-14581) Support to run Python UDF jobs in a YARN cluster

2019-11-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977308#comment-16977308 ] Hequn Cheng commented on FLINK-14581: - Resolved in 1.10.0 via 

[jira] [Assigned] (FLINK-14581) Support to run Python UDF jobs in a YARN cluster

2019-11-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14581: --- Assignee: Wei Zhong > Support to run Python UDF jobs in a YARN cluster >

[GitHub] [flink] flinkbot edited a comment on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions URL: https://github.com/apache/flink/pull/10248#issuecomment-555408694 ## CI report: * b1bdc03483cd3b64e114edbc585e2ff7986dea97 :

[GitHub] [flink] flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10103: [FLINK-14506][python][build] Improve the release script for Python API release package

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10103: [FLINK-14506][python][build] Improve the release script for Python API release package URL: https://github.com/apache/flink/pull/10103#issuecomment-550222346 ## CI report: * 7c842be4f1d79ff3206322d72f4cb1dcebd52c7e : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#issuecomment-554384687 ## CI report: * f0ffbf0cff4a72ded1062772674408f58783cbfb : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig URL: https://github.com/apache/flink/pull/10217#issuecomment-554326000 ## CI report: * 2278c6ee6cf4439cb802702ce9ab318a1e2942e3 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#issuecomment-554261720 ## CI report: * 95ec85f121bef0d4c51ed9846e35277c26c58aac : FAILURE

[GitHub] [flink] pnowojski edited a comment on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

2019-11-19 Thread GitBox
pnowojski edited a comment on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#issuecomment-555382238 @AT-Fieldless there is already an existing class `NetUtils` (`org.apache.flink.util.NetUtils`) inside

[GitHub] [flink] pnowojski commented on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

2019-11-19 Thread GitBox
pnowojski commented on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#issuecomment-555382238 @AT-Fieldless there is already an existing class `NetUtils` (`org.apache.flink.util.NetUtils`) insided

[GitHub] [flink] flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-544813931 ## CI report: * 6f90b457e56a0a8cb45d63c1b05b47d2e38030a1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9973: [FLINK-9955] Add Kubernetes ClusterDescriptor to support deploying session cluster.

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9973: [FLINK-9955] Add Kubernetes ClusterDescriptor to support deploying session cluster. URL: https://github.com/apache/flink/pull/9973#issuecomment-545325448 ## CI report: * 450cd1029219372cdc4f05f4bf6bc3ff6e43dc90 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-521131546 ## CI report: * 22d047614613c293a7aca416268449b3cabcad6a :

[GitHub] [flink] flinkbot edited a comment on issue #9957: [FLINK-10932] Initialize flink-kubernetes module

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9957: [FLINK-10932] Initialize flink-kubernetes module URL: https://github.com/apache/flink/pull/9957#issuecomment-544504781 ## CI report: * 41f3075d918578641781d15eb8c4d3cfc9bb4ada : FAILURE

[jira] [Updated] (FLINK-14813) Expose the new mechanism implemented in FLINK-14472 as a "is back-pressured" metric

2019-11-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14813: --- Labels: pull-request-available (was: ) > Expose the new mechanism implemented in

[GitHub] [flink] flinkbot edited a comment on issue #9957: [FLINK-10932] Initialize flink-kubernetes module

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9957: [FLINK-10932] Initialize flink-kubernetes module URL: https://github.com/apache/flink/pull/9957#issuecomment-544504781 ## CI report: * 41f3075d918578641781d15eb8c4d3cfc9bb4ada : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-544813931 ## CI report: * 6f90b457e56a0a8cb45d63c1b05b47d2e38030a1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9973: [FLINK-9955] Add Kubernetes ClusterDescriptor to support deploying session cluster.

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9973: [FLINK-9955] Add Kubernetes ClusterDescriptor to support deploying session cluster. URL: https://github.com/apache/flink/pull/9973#issuecomment-545325448 ## CI report: * 450cd1029219372cdc4f05f4bf6bc3ff6e43dc90 : SUCCESS

[jira] [Updated] (FLINK-14852) translate concepts/programming-model to chinese

2019-11-19 Thread Zhangcheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhangcheng Hu updated FLINK-14852: -- Description: translate content of flink\docs\concepts\programming-model.zh.md to chinese hey

[jira] [Updated] (FLINK-14042) Different RelDataTypes generated for same TemporalTableFunction

2019-11-19 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuval Itzchakov updated FLINK-14042: Affects Version/s: 1.8.2 1.9.0 1.9.1 >

[GitHub] [flink] JingsongLi commented on issue #10059: [FLINK-14543][table] Support partition for temporary table

2019-11-19 Thread GitBox
JingsongLi commented on issue #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#issuecomment-555403432 Thanks @dawidwys for your reviewing, updated, In the past, I misunderstood the relationship between

[jira] [Comment Edited] (FLINK-14854) Add executeAsync() method to environments

2019-11-19 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977291#comment-16977291 ] Zili Chen edited comment on FLINK-14854 at 11/19/19 9:21 AM: - In previous

[jira] [Commented] (FLINK-14854) Add executeAsync() method to environments

2019-11-19 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977298#comment-16977298 ] Zili Chen commented on FLINK-14854: --- my plan to expose job client from job submission is replacing the

[GitHub] [flink] HuangXingBo commented on a change in pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink r

2019-11-19 Thread GitBox
HuangXingBo commented on a change in pull request #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#discussion_r347703910 ## File path:

[GitHub] [flink] HuangXingBo commented on a change in pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink r

2019-11-19 Thread GitBox
HuangXingBo commented on a change in pull request #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#discussion_r347333939 ## File path:

[GitHub] [flink] HuangXingBo commented on a change in pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink r

2019-11-19 Thread GitBox
HuangXingBo commented on a change in pull request #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#discussion_r347702295 ## File path:

[GitHub] [flink] HuangXingBo commented on a change in pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink r

2019-11-19 Thread GitBox
HuangXingBo commented on a change in pull request #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#discussion_r347702534 ## File path:

[GitHub] [flink] HuangXingBo commented on a change in pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink r

2019-11-19 Thread GitBox
HuangXingBo commented on a change in pull request #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#discussion_r347348659 ## File path:

[GitHub] [flink] HuangXingBo commented on a change in pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink r

2019-11-19 Thread GitBox
HuangXingBo commented on a change in pull request #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#discussion_r347351634 ## File path:

[GitHub] [flink] HuangXingBo commented on a change in pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink r

2019-11-19 Thread GitBox
HuangXingBo commented on a change in pull request #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#discussion_r347816271 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

2019-11-19 Thread GitBox
GJL commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10152#discussion_r347822104 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

2019-11-19 Thread GitBox
GJL commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10152#discussion_r347821813 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

2019-11-19 Thread GitBox
GJL commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10152#discussion_r347821445 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-544813931 ## CI report: * 6f90b457e56a0a8cb45d63c1b05b47d2e38030a1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9957: [FLINK-10932] Initialize flink-kubernetes module

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9957: [FLINK-10932] Initialize flink-kubernetes module URL: https://github.com/apache/flink/pull/9957#issuecomment-544504781 ## CI report: * 41f3075d918578641781d15eb8c4d3cfc9bb4ada : FAILURE

[GitHub] [flink] lirui-apache commented on issue #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints

2019-11-19 Thread GitBox
lirui-apache commented on issue #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints URL: https://github.com/apache/flink/pull/10249#issuecomment-555430204 cc @godfreyhe @xuefuz @bowenli86 @zjuwangg This is an

[GitHub] [flink] wangyang0918 commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

2019-11-19 Thread GitBox
wangyang0918 commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-555429583 @TisonKun @walterddr Sorry for late and really thanks for your review. I have addressed all

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347774795 ## File path:

[jira] [Created] (FLINK-14850) Refactor Executor interface and introduce a minimal JobClient interface

2019-11-19 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-14850: -- Summary: Refactor Executor interface and introduce a minimal JobClient interface Key: FLINK-14850 URL: https://issues.apache.org/jira/browse/FLINK-14850 Project:

[GitHub] [flink] dianfu commented on a change in pull request #10188: [FLINK-14066][python] Support to install pyflink in windows

2019-11-19 Thread GitBox
dianfu commented on a change in pull request #10188: [FLINK-14066][python] Support to install pyflink in windows URL: https://github.com/apache/flink/pull/10188#discussion_r347785992 ## File path: flink-python/setup.py ## @@ -108,8 +119,13 @@

[GitHub] [flink] flinkbot edited a comment on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#issuecomment-554261720 ## CI report: * 95ec85f121bef0d4c51ed9846e35277c26c58aac : FAILURE

[GitHub] [flink] dawidwys commented on a change in pull request #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig

2019-11-19 Thread GitBox
dawidwys commented on a change in pull request #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig URL: https://github.com/apache/flink/pull/10217#discussion_r347788410 ## File path:

[jira] [Updated] (FLINK-14852) translate concepts/programming-model to chinese

2019-11-19 Thread Zhangcheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhangcheng Hu updated FLINK-14852: -- Priority: Minor (was: Major) > translate concepts/programming-model to chinese >

[GitHub] [flink] flinkbot edited a comment on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#issuecomment-554261720 ## CI report: * 95ec85f121bef0d4c51ed9846e35277c26c58aac : FAILURE

[GitHub] [flink] JingsongLi commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table

2019-11-19 Thread GitBox
JingsongLi commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#discussion_r347799275 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table

2019-11-19 Thread GitBox
JingsongLi commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#discussion_r347799275 ## File path:

[GitHub] [flink] aljoscha commented on issue #10243: [BP-1.9][FLINK-13749][client] Make client respect classloading policy

2019-11-19 Thread GitBox
aljoscha commented on issue #10243: [BP-1.9][FLINK-13749][client] Make client respect classloading policy URL: https://github.com/apache/flink/pull/10243#issuecomment-555405795 Thanks a lot, @link3280! This is an automated

[GitHub] [flink] aljoscha commented on issue #10242: [BP-1.8][FLINK-13749][client] Make client respect classloading policy

2019-11-19 Thread GitBox
aljoscha commented on issue #10242: [BP-1.8][FLINK-13749][client] Make client respect classloading policy URL: https://github.com/apache/flink/pull/10242#issuecomment-555405820 Thanks a lot, @link3280! This is an automated

[jira] [Comment Edited] (FLINK-14854) Add executeAsync() method to environments

2019-11-19 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977291#comment-16977291 ] Zili Chen edited comment on FLINK-14854 at 11/19/19 9:19 AM: - In previous

[jira] [Commented] (FLINK-14854) Add executeAsync() method to environments

2019-11-19 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977291#comment-16977291 ] Zili Chen commented on FLINK-14854: --- In previous discussion we separate the stage into 1. submit job

[jira] [Created] (FLINK-14855) travis-ci error.

2019-11-19 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-14855: --- Summary: travis-ci error. Key: FLINK-14855 URL: https://issues.apache.org/jira/browse/FLINK-14855 Project: Flink Issue Type: Bug Components:

[jira] [Comment Edited] (FLINK-14854) Add executeAsync() method to environments

2019-11-19 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977298#comment-16977298 ] Zili Chen edited comment on FLINK-14854 at 11/19/19 9:29 AM: - my plan to

[jira] [Commented] (FLINK-14815) Expose network pool usage in IOMetricsInfo

2019-11-19 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977303#comment-16977303 ] lining commented on FLINK-14815: For the pool usages, in the case of data skew, although the average is

[jira] [Commented] (FLINK-14814) Show the vertex that produces the backpressure source in the job

2019-11-19 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977229#comment-16977229 ] Piotr Nowojski commented on FLINK-14814: Ok, sounds good [~lining]. One thing: > pool usage

[GitHub] [flink] flinkbot edited a comment on issue #10246: [FLINK-10937][dist] Add kubernetes-entry.sh and kubernetes-session.sh.

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10246: [FLINK-10937][dist] Add kubernetes-entry.sh and kubernetes-session.sh. URL: https://github.com/apache/flink/pull/10246#issuecomment-555375256 ## CI report: * 9f06575f29a7cb1102357c8919b57b3471dc80fd : PENDING

[GitHub] [flink] aljoscha commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema

2019-11-19 Thread GitBox
aljoscha commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema URL: https://github.com/apache/flink/pull/8371#issuecomment-555384761 There are build failures because of checkstyle: https://travis-ci.com/flink-ci/flink/builds/137108234

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r34131 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347775584 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347768262 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347779068 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347767780 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

2019-11-19 Thread GitBox
wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347768806 ## File path:

[GitHub] [flink] jinglining opened a new pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

2019-11-19 Thread GitBox
jinglining opened a new pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247 ## What is the purpose of the change This pull request exposes whether a task is back-pressured metric which define in

[GitHub] [flink] dawidwys commented on a change in pull request #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig

2019-11-19 Thread GitBox
dawidwys commented on a change in pull request #10217: [FLINK-14786][configuration] Add configure method to ExecutionConfig URL: https://github.com/apache/flink/pull/10217#discussion_r347792653 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10237: [FLINK-14362][runtime] Change DefaultSchedulingResultPartition to return correct partition state

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10237: [FLINK-14362][runtime] Change DefaultSchedulingResultPartition to return correct partition state URL: https://github.com/apache/flink/pull/10237#issuecomment-555034534 ## CI report: * 5bb85aa49e52a19e22bec321a0f3d0309456515d : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230#issuecomment-554717265 ## CI report: * 520a41fb6c3b0fdde8fdcea87a348d12918b2481 : CANCELED

[jira] [Commented] (FLINK-13749) Make Flink client respect classloading policy

2019-11-19 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977280#comment-16977280 ] Aljoscha Krettek commented on FLINK-13749: -- Fixed on release-1.8 in

[jira] [Updated] (FLINK-13749) Make Flink client respect classloading policy

2019-11-19 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13749: - Fix Version/s: 1.9.2 1.8.3 > Make Flink client respect classloading

[GitHub] [flink] flinkbot commented on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions

2019-11-19 Thread GitBox
flinkbot commented on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions URL: https://github.com/apache/flink/pull/10248#issuecomment-555406359 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] zhuzhurk commented on a change in pull request #10179: [FLINK-14734][runtime] Add a ResourceSpec in SlotSharingGroup to describe its overall resources

2019-11-19 Thread GitBox
zhuzhurk commented on a change in pull request #10179: [FLINK-14734][runtime] Add a ResourceSpec in SlotSharingGroup to describe its overall resources URL: https://github.com/apache/flink/pull/10179#discussion_r346923349 ## File path:

[GitHub] [flink] flinkbot commented on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions

2019-11-19 Thread GitBox
flinkbot commented on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions URL: https://github.com/apache/flink/pull/10248#issuecomment-555408694 ## CI report: * b1bdc03483cd3b64e114edbc585e2ff7986dea97 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-555395817 ## CI report: * 09feda98fa486bb4c3aaf8bba3806cae08b53c23 : PENDING

[jira] [Commented] (FLINK-14854) Add executeAsync() method to environments

2019-11-19 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977286#comment-16977286 ] Zili Chen commented on FLINK-14854: --- Hi [~aljoscha], in my opinion the difference stays in

[GitHub] [flink] flinkbot edited a comment on issue #10246: [FLINK-10937][dist] Add kubernetes-entry.sh and kubernetes-session.sh.

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #10246: [FLINK-10937][dist] Add kubernetes-entry.sh and kubernetes-session.sh. URL: https://github.com/apache/flink/pull/10246#issuecomment-555375256 ## CI report: * 9f06575f29a7cb1102357c8919b57b3471dc80fd : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-11-19 Thread GitBox
flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] Mrart commented on a change in pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

2019-11-19 Thread GitBox
Mrart commented on a change in pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230#discussion_r347821177 ## File path:

[GitHub] [flink] Mrart commented on a change in pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

2019-11-19 Thread GitBox
Mrart commented on a change in pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230#discussion_r347821177 ## File path:

[jira] [Updated] (FLINK-14847) Support retrieving Hive PK constraints

2019-11-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14847: --- Labels: pull-request-available (was: ) > Support retrieving Hive PK constraints >

  1   2   3   4   5   6   7   >