[GitHub] [flink] becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#discussion_r355161078 ## File path: flink-core/src/main/java/org/apache/flink/util/AutoContextClassLoader.ja

[GitHub] [flink] becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#discussion_r355170733 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/OperatorC

[GitHub] [flink] becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#discussion_r355170391 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.ja

[GitHub] [flink] becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#discussion_r355171592 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/ta

[GitHub] [flink] becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#discussion_r355165198 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskEx

[GitHub] [flink] becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

becketqin commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#discussion_r355165029 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/Scheduler

[GitHub] [flink] Aitozi commented on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file

Aitozi commented on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file URL: https://github.com/apache/flink/pull/8479#issuecomment-562928477 Thanks @carp84 for help review this PR , and I have rebased the master solve

[jira] [Comment Edited] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990784#comment-16990784 ] Piotr Nowojski edited comment on FLINK-15103 at 12/8/19 9:32 AM: -

[jira] [Comment Edited] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990784#comment-16990784 ] Piotr Nowojski edited comment on FLINK-15103 at 12/8/19 9:32 AM: -

[GitHub] [flink] wangyang0918 commented on a change in pull request #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster.

wangyang0918 commented on a change in pull request #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster. URL: https://github.com/apache/flink/pull/10245#discussion_r355171235 ## File path: flink-clients/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#issuecomment-562648066 ## CI report: * 9802f136dd38c6ba22752a7761e644b7bd05e99d

[GitHub] [flink] flinkbot edited a comment on issue #10371: [FLINK-14953][formats] use table type to build parquet FilterPredicate

flinkbot edited a comment on issue #10371: [FLINK-14953][formats] use table type to build parquet FilterPredicate URL: https://github.com/apache/flink/pull/10371#issuecomment-560045651 ## CI report: * 24326ffa979a4f9ed56265c0db11a874d3c4d2a2 : FAILURE [Build](https://travis-ci.c

[jira] [Commented] (FLINK-14845) Introduce data compression to blocking shuffle.

[ https://issues.apache.org/jira/browse/FLINK-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990786#comment-16990786 ] Piotr Nowojski commented on FLINK-14845: Thanks [~kevin.cyj] and [~zjwang] for y

[GitHub] [flink] wangyang0918 commented on a change in pull request #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster.

wangyang0918 commented on a change in pull request #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster. URL: https://github.com/apache/flink/pull/10245#discussion_r355171293 ## File path: flink-clients/src/main/java/org/apache/flink

[GitHub] [flink] wangyang0918 commented on a change in pull request #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster.

wangyang0918 commented on a change in pull request #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster. URL: https://github.com/apache/flink/pull/10245#discussion_r355171235 ## File path: flink-clients/src/main/java/org/apache/flink

[jira] [Commented] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990784#comment-16990784 ] Piotr Nowojski commented on FLINK-15103: I think that would be ok, however bigge

[GitHub] [flink] flinkbot edited a comment on issue #10484: [FLINK-14906][table] create and drop temp system functions from DDL t…

flinkbot edited a comment on issue #10484: [FLINK-14906][table] create and drop temp system functions from DDL t… URL: https://github.com/apache/flink/pull/10484#issuecomment-562914317 ## CI report: * c604c9f8704578c33884b2faf8d163a7482795c4 : SUCCESS [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#issuecomment-562648066 ## CI report: * 9802f136dd38c6ba22752a7761e644b7bd05e99d

[jira] [Created] (FLINK-15129) Return JobClient instead of JobClient Future from executeAsync()

Aljoscha Krettek created FLINK-15129: Summary: Return JobClient instead of JobClient Future from executeAsync() Key: FLINK-15129 URL: https://issues.apache.org/jira/browse/FLINK-15129 Project: Fli

[jira] [Commented] (FLINK-15129) Return JobClient instead of JobClient Future from executeAsync()

[ https://issues.apache.org/jira/browse/FLINK-15129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990773#comment-16990773 ] Aljoscha Krettek commented on FLINK-15129: -- cc [~kkloudas] [~tison] [~zjffdu] W

[GitHub] [flink] leonardBang commented on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

leonardBang commented on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#issuecomment-562924814 @JingsongLi @wuchong Could you have a more look？ thanks very much.

[GitHub] [flink] hequn8128 commented on a change in pull request #10377: [FLINK-15001] [table-planner-blink] The digest of sub-plan reuse should contain retraction traits for stream physical nodes

hequn8128 commented on a change in pull request #10377: [FLINK-15001] [table-planner-blink] The digest of sub-plan reuse should contain retraction traits for stream physical nodes URL: https://github.com/apache/flink/pull/10377#discussion_r355169122 ## File path: flink-table/flink

[GitHub] [flink] lirui-apache commented on issue #10401: [FLINK-15020][hive] Support timestamp type in hive

lirui-apache commented on issue #10401: [FLINK-15020][hive] Support timestamp type in hive URL: https://github.com/apache/flink/pull/10401#issuecomment-562924214 > LGTM. can you open a ticket for updating documentation? Opened FLINK-15128 for it.

[jira] [Created] (FLINK-15128) Document support for Hive timestamp type

Rui Li created FLINK-15128: -- Summary: Document support for Hive timestamp type Key: FLINK-15128 URL: https://issues.apache.org/jira/browse/FLINK-15128 Project: Flink Issue Type: Task Compo

[GitHub] [flink] flinkbot edited a comment on issue #10484: [FLINK-14906][table] create and drop temp system functions from DDL t…

flinkbot edited a comment on issue #10484: [FLINK-14906][table] create and drop temp system functions from DDL t… URL: https://github.com/apache/flink/pull/10484#issuecomment-562914317 ## CI report: * c604c9f8704578c33884b2faf8d163a7482795c4 : PENDING [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#issuecomment-562912876 ## CI report: * f7d3793fc60c8700f99adf52ed760e9665f42a90 : FAILURE [Build](https://travis-ci.co

[GitHub] [flink] zhuzhurk commented on a change in pull request #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster.

zhuzhurk commented on a change in pull request #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster. URL: https://github.com/apache/flink/pull/10245#discussion_r355160547 ## File path: flink-clients/src/main/java/org/apache/flink/cli

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

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 [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #10474: [FLINK-15116] Make JobClient stateless, remove AutoCloseable

flinkbot edited a comment on issue #10474: [FLINK-15116] Make JobClient stateless, remove AutoCloseable URL: https://github.com/apache/flink/pull/10474#issuecomment-562698759 ## CI report: * b29a8cc494e7033b9c8fb21ab982060b57aa90f3 : CANCELED [Build](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#issuecomment-562648066 ## CI report: * 9802f136dd38c6ba22752a7761e644b7bd05e99d

<    1   2   3   4   5