[GitHub] [flink] xuyang1706 commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.

xuyang1706 commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution. URL: https://github.com/apache/flink/pull/9733#discussion_r339420157 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/s

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#issuecomment-546323476 ## CI report: * 5f0728f214a49413f94ef838a9e40dda023ebb8b : SUCCESS [Build](https://travis-ci.com/flink-ci/flin

[jira] [Created] (FLINK-14541) AggregateITCase.testTimeDistinct failed on travis

Jark Wu created FLINK-14541: --- Summary: AggregateITCase.testTimeDistinct failed on travis Key: FLINK-14541 URL: https://issues.apache.org/jira/browse/FLINK-14541 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Zhang updated FLINK-14539: Description: Currently unique key metadata of a project relnode are only kept in the following th

[jira] [Closed] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes

[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun closed FLINK-14230. - > Change the endInput call of the downstream operator to after the upstream > operator closes > --

[jira] [Updated] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes

[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-14230: - Fix Version/s: 1.10.0 > Change the endInput call of the downstream operator to after the upstream > op

[jira] [Resolved] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes

[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang resolved FLINK-14230. -- Resolution: Fixed Merged in master: ecc802064d35d22162a3bd57a522b4c77c56e390 > Change the endInput c

[jira] [Updated] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes

[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-14230: - Description: This ticket is for fixing the error of propagating "endInput" on the chain immediately aft

[GitHub] [flink] zhijiangW merged pull request #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

zhijiangW merged pull request #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854 This is an automated message f

[GitHub] [flink] thousandhu commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint.

thousandhu commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint. URL: https://github.com/apache/flink/pull/9986#discussion_r339416114 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesSe

[GitHub] [flink] thousandhu commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint.

thousandhu commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint. URL: https://github.com/apache/flink/pull/9986#discussion_r339416046 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesRe

[jira] [Resolved] (FLINK-14415) ValueLiteralExpression#equals should take array value into account

[ https://issues.apache.org/jira/browse/FLINK-14415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14415. - Fix Version/s: 1.10.0 Resolution: Fixed 1.10.0: 27307b4f44d42a4d79a4ee52cb27f4f1581745c1 > Value

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339415727 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/tab

[jira] [Commented] (FLINK-14540) Rethink of TableSource#explainSource()

[ https://issues.apache.org/jira/browse/FLINK-14540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960792#comment-16960792 ] Jark Wu commented on FLINK-14540: - cc [~rongrong] [~ykt836] [~godfreyhe] [~lzljs3620320]

[GitHub] [flink] wuchong merged pull request #9915: [FLINK-14415][table-common] ValueLiteralExpression#equals should take array value into account

wuchong merged pull request #9915: [FLINK-14415][table-common] ValueLiteralExpression#equals should take array value into account URL: https://github.com/apache/flink/pull/9915 This is an automated message from the Apache Gi

[jira] [Issue Comment Deleted] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13148: -- Comment: was deleted (was: Hi, [~kkl0u] do you think we can have this feature

[jira] [Commented] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960793#comment-16960793 ] Congxian Qiu(klion26) commented on FLINK-13148: --- kindly ping [~kkl0u] > E

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : FAILURE [Build](https://travis-ci.c

[jira] [Created] (FLINK-14540) Rethink of TableSource#explainSource()

Jark Wu created FLINK-14540: --- Summary: Rethink of TableSource#explainSource() Key: FLINK-14540 URL: https://issues.apache.org/jira/browse/FLINK-14540 Project: Flink Issue Type: Improvement

[GitHub] [flink] zhijiangW commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546808886 I finished reviewing the whole codes and left some comments. In addition, we als

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339413971 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#issuecomment-546323476 ## CI report: * 5f0728f214a49413f94ef838a9e40dda023ebb8b : SUCCESS [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339413614 ## File path: flink-runtime/src/test/java/org/apache/fl

[jira] [Resolved] (FLINK-14396) Implement rudimentary non-blocking network output

[ https://issues.apache.org/jira/browse/FLINK-14396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang resolved FLINK-14396. -- Resolution: Fixed Merged in master : ad70e062c1d4a867b7eec7a03239c5a6ce52c23e > Implement rudimentary

[GitHub] [flink] lirui-apache commented on a change in pull request #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

lirui-apache commented on a change in pull request #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#discussion_r339412850 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/h

[jira] [Comment Edited] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960781#comment-16960781 ] Kevin Zhang edited comment on FLINK-14539 at 10/28/19 6:12 AM: ---

[GitHub] [flink] KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339412246 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/de

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960781#comment-16960781 ] Kevin Zhang commented on FLINK-14539: - I indend to implement this using a RexBiVisit

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339412132 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339411501 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339411516 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] TisonKun commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

TisonKun commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#discussion_r339411427 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339411225 ## File path: flink-runtime/src/test/java/org/apache/fl

[jira] [Created] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

Kevin Zhang created FLINK-14539: --- Summary: Unique key metadata should be ketp when using concat or concat_ws in some cases Key: FLINK-14539 URL: https://issues.apache.org/jira/browse/FLINK-14539 Project

[GitHub] [flink] flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-539497852 ## CI report: * 9adcb150ed88bfa077642f6f590ec4ae9183baf5 :

[jira] [Commented] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960773#comment-16960773 ] Zili Chen commented on FLINK-10435: --- I agree that this is a bug to be fixed. Thanks fo

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339410721 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-546787757 ## CI report: * 4b0f9efdc169d3b6375d469cd3512e87e98f0f19 : SUCCESS [Build](https://travis-ci.com/flink-ci

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339408894 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339407704 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339408191 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339408562 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/

[jira] [Commented] (FLINK-14498) Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool

[ https://issues.apache.org/jira/browse/FLINK-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960766#comment-16960766 ] Jiayi Liao commented on FLINK-14498: [~kevin.cyj] Thanks for you explaination :). >

[jira] [Commented] (FLINK-14498) Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool

[ https://issues.apache.org/jira/browse/FLINK-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960764#comment-16960764 ] Yingjie Cao commented on FLINK-14498: - [~wind_ljy] The PR is based on another PR  [h

[GitHub] [flink] zhijiangW merged pull request #9905: [FLINK-14396][network] Implement rudimentary non-blocking network output

zhijiangW merged pull request #9905: [FLINK-14396][network] Implement rudimentary non-blocking network output URL: https://github.com/apache/flink/pull/9905 This is an automated message from the Apache Git Service. To respon

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339407219 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339407217 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/sourc

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339407007 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339406809 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/so

[jira] [Comment Edited] (FLINK-14498) Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool

[ https://issues.apache.org/jira/browse/FLINK-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960762#comment-16960762 ] Jiayi Liao edited comment on FLINK-14498 at 10/28/19 5:27 AM:

[jira] [Commented] (FLINK-14498) Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool

[ https://issues.apache.org/jira/browse/FLINK-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960762#comment-16960762 ] Jiayi Liao commented on FLINK-14498: [~zjwang][~kevin.cyj] Maybe I'm not very famil

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339406297 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/

[jira] [Commented] (FLINK-14026) Manage the resource of Python worker properly

[ https://issues.apache.org/jira/browse/FLINK-14026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960761#comment-16960761 ] Dian Fu commented on FLINK-14026: - [~sunjincheng121] Thanks a lot for the remind. I have

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339406308 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/sourc

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339405733 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/so

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339405733 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/so

[jira] [Commented] (FLINK-14538) Metrics of Status.JVM.Memory.NonHeap.Max is always -1

[ https://issues.apache.org/jira/browse/FLINK-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960759#comment-16960759 ] Shuwen Zhou commented on FLINK-14538: - [~wind_ljy] It was deployed on Yarn cluster.

[GitHub] [flink] flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-539497852 ## CI report: * 9adcb150ed88bfa077642f6f590ec4ae9183baf5 :

[jira] [Commented] (FLINK-14538) Metrics of Status.JVM.Memory.NonHeap.Max is always -1

[ https://issues.apache.org/jira/browse/FLINK-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960754#comment-16960754 ] Jiayi Liao commented on FLINK-14538: [~jacobc3] This usually means the nonHeap memor

[GitHub] [flink] flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-546787757 ## CI report: * 4b0f9efdc169d3b6375d469cd3512e87e98f0f19 : PENDING [Build](https://travis-ci.com/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-539497852 ## CI report: * 9adcb150ed88bfa077642f6f590ec4ae9183baf5 :

[jira] [Commented] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

[ https://issues.apache.org/jira/browse/FLINK-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960752#comment-16960752 ] Congxian Qiu(klion26) commented on FLINK-14264: --- Kindly ping [~aljoscha].

[jira] [Updated] (FLINK-14538) Metrics of Status.JVM.Memory.NonHeap.Max is always -1

[ https://issues.apache.org/jira/browse/FLINK-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuwen Zhou updated FLINK-14538: Description: I'm collecting JobManager and TaskManager status metrics to DataDog. While all metri

[jira] [Updated] (FLINK-14538) Metrics of Status.JVM.Memory.NonHeap.Max is always -1

[ https://issues.apache.org/jira/browse/FLINK-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuwen Zhou updated FLINK-14538: Summary: Metrics of Status.JVM.Memory.NonHeap.Max is always -1 (was: Metrics of TaskManager Statu

[GitHub] [flink] flinkbot commented on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

flinkbot commented on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-546787757 ## CI report: * 4b0f9efdc169d3b6375d469cd3512e87e98f0f19 : UNKNOWN Bot commands The @flinkbot bot

[jira] [Updated] (FLINK-14538) Metrics of TaskManager Status.JVM.Memory.NonHeap.Max is always -1

[ https://issues.apache.org/jira/browse/FLINK-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuwen Zhou updated FLINK-14538: Description: I'm collecting TaskManager status metrics to DataDog. While all metrics of TaskManag

[jira] [Created] (FLINK-14538) Metrics of TaskManager Status.JVM.Memory.NonHeap.Max is always -1

Shuwen Zhou created FLINK-14538: --- Summary: Metrics of TaskManager Status.JVM.Memory.NonHeap.Max is always -1 Key: FLINK-14538 URL: https://issues.apache.org/jira/browse/FLINK-14538 Project: Flink

[GitHub] [flink] Henvealf commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

Henvealf commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r339399783 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30 +16

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339398802 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] sunhaibotb edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

sunhaibotb edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-546785241 I've addressed the lastest comments and added some detailed descrip

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339398713 ## File path: flink-runtime/src/test/java/org/apache/fl

[jira] [Comment Edited] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960738#comment-16960738 ] Yang Wang edited comment on FLINK-10435 at 10/28/19 4:14 AM: -

[GitHub] [flink] wangyang0918 opened a new pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

wangyang0918 opened a new pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010 ## What is the purpose of the change This PR is to fix the bug when deploying on yarn in attach mode that flink client h

[jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10435: --- Labels: pull-request-available (was: ) > Client sporadically hangs after Ctrl + C > ---

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE [Build]

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339397642 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r339284001 ## File path: flink-core/src/test/java/org/apache/flink/util/FileUtilsTest.java ###

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE [Build](http

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339397163 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339396841 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339396836 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339396074 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/ca

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339395859 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/tab

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339389965 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/sourc

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339392752 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/tab

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339395422 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/tab

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339393494 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/tab

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339395831 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/c

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339393920 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/d

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339392415 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/a

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339392857 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/a

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339393982 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/d

[GitHub] [flink] flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#issuecomment-539878774 ## CI report: * c8bf66050c865904c402bdc9c079a6e4de1a064c : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7 :

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE [Build](http

[GitHub] [flink] KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339394157 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/ta

[GitHub] [flink] flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546558980 ## CI report: * 74748e2c09f1b2b0b9bfb3c1850cd71696d30df8 : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9915: [FLINK-14415][table-common] ValueLiteralExpression#equals should take array value into account

flinkbot edited a comment on issue #9915: [FLINK-14415][table-common] ValueLiteralExpression#equals should take array value into account URL: https://github.com/apache/flink/pull/9915#issuecomment-542752172 ## CI report: * d6f66852e76bac070b37e7e9c7365423e5b66853 : SUCCESS [Buil

  1   2   >