[GitHub] [flink] flinkbot edited a comment on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

flinkbot edited a comment on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097#issuecomment-550166959 ## CI report: * f72b6f5096ae65beb1647edc0e1db84ae9d320a9

[GitHub] [flink] flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550174677 ## CI report: * a3db95a7340322421d1fa826dcac850116011687 : FAILURE [Build](https://t

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342950420 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342954153 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342953666 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot commented on issue #10099: [FLINK-14589] [Runtime/Coordination] Redundant slot requests with the same AllocationID lead…

flinkbot commented on issue #10099: [FLINK-14589] [Runtime/Coordination] Redundant slot requests with the same AllocationID lead… URL: https://github.com/apache/flink/pull/10099#issuecomment-550187801 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Commented] (FLINK-14613) Add validation check when applying UDF to tempral table key in Temporal Table Join condition

[ https://issues.apache.org/jira/browse/FLINK-14613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968142#comment-16968142 ] Jark Wu commented on FLINK-14613: - Hi [~hailong wang], I don't fully understand it. The

[jira] [Updated] (FLINK-14589) Redundant slot requests with the same AllocationID leads to inconsistent slot table

[ https://issues.apache.org/jira/browse/FLINK-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14589: --- Labels: pull-request-available (was: ) > Redundant slot requests with the same AllocationID

[jira] [Assigned] (FLINK-14596) Update MapView and ListView interface to new type system

[ https://issues.apache.org/jira/browse/FLINK-14596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14596: --- Assignee: Jark Wu > Update MapView and ListView interface to new type system >

[jira] [Commented] (FLINK-14596) Update MapView and ListView interface to new type system

[ https://issues.apache.org/jira/browse/FLINK-14596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968141#comment-16968141 ] Jark Wu commented on FLINK-14596: - Sorry [~hailong wang], I'm already working on this.

[GitHub] [flink] hwanju opened a new pull request #10099: [FLINK-14589] [Runtime/Coordination] Redundant slot requests with the same AllocationID lead…

hwanju opened a new pull request #10099: [FLINK-14589] [Runtime/Coordination] Redundant slot requests with the same AllocationID lead… URL: https://github.com/apache/flink/pull/10099 …s to inconsistent slot table ## What is the purpose of the change When a slot request is redu

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342952079 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342950891 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342950977 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342950420 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342949904 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342949437 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342949472 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 : FAILURE [Build](https://travis

[jira] [Created] (FLINK-14626) User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn

Victor Wong created FLINK-14626: --- Summary: User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn Key: FLINK-14626 URL: https://issues.apache.org/jira/browse/FLINK-14626

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342949165 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342948970 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342948570 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550174677 ## CI report: * a3db95a7340322421d1fa826dcac850116011687 : PENDING [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550159742 ## CI report: * 3fd9876e046bb9a56f36995084b37675f3929e0d : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] wsry commented on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

wsry commented on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097#issuecomment-550182436 Thanks @zhijiangW for the review. I have resolved all concerns and updated th

[GitHub] [flink] flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate

flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate URL: https://github.com/apache/flink/pull/10082#issuecomment-549698167 ## CI report: * 9ad21545cdce68c8892941e8f33a89147bddb1f6 : SUCCES

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342929996 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342941005 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342942942 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342933234 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342943303 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342937994 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342937349 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342937942 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342937502 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

KarmaGYZ commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r342942576 ## File path: flink-core/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 : FAILURE [Build](https://travis

[jira] [Updated] (FLINK-14604) Bump commons-cli to 1.4

[ https://issues.apache.org/jira/browse/FLINK-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-14604: -- Description: Currently flink is using commons-cli 1.3.1. There is a [bug|https://issues.apache.org/ji

[GitHub] [flink] flinkbot commented on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot commented on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550174677 ## CI report: * a3db95a7340322421d1fa826dcac850116011687 : UNKNOWN Bot commands

[jira] [Updated] (FLINK-14604) Bump commons-cli to 1.4

[ https://issues.apache.org/jira/browse/FLINK-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-14604: -- Description: Currently flink is using commons-cli 1.3.1. There is a [bug|https://issues.apache.org/ji

[GitHub] [flink] flinkbot edited a comment on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

flinkbot edited a comment on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097#issuecomment-550166959 ## CI report: * f72b6f5096ae65beb1647edc0e1db84ae9d320a9

[GitHub] [flink] flinkbot edited a comment on issue #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a'

flinkbot edited a comment on issue #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a' URL: https://github.com/apache/flink/pull/10095#issuecomment-550153081 ## CI report: * 528020239cb7c531bf58a6abc9a68555fe8aa92e : SUCCESS [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #10094: [FLINK-14611][runtime] Move allVerticesInSameSlotSharingGroupByDefault setting from ExecutionConfig to StreamGraph

flinkbot edited a comment on issue #10094: [FLINK-14611][runtime] Move allVerticesInSameSlotSharingGroupByDefault setting from ExecutionConfig to StreamGraph URL: https://github.com/apache/flink/pull/10094#issuecomment-550114409 ## CI report: * 8d20db4cdea3e4e2a69590362675e7bf7e

[GitHub] [flink] flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate

flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate URL: https://github.com/apache/flink/pull/10082#issuecomment-549698167 ## CI report: * 9ad21545cdce68c8892941e8f33a89147bddb1f6 : SUCCES

[jira] [Created] (FLINK-14625) Eliminate cross join in multi join to reduce cost

Leonard Xu created FLINK-14625: -- Summary: Eliminate cross join in multi join to reduce cost Key: FLINK-14625 URL: https://issues.apache.org/jira/browse/FLINK-14625 Project: Flink Issue Type: Im

[GitHub] [flink] guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r342920624 ## File path: flink-container/src/main/java/org/apache/flink/container/

[GitHub] [flink] liupc commented on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

liupc commented on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-550169349 Thanks for your active reply @tillrohrmann , I've fixed those tests, the reason for the tests failure is that

[jira] [Updated] (FLINK-14619) Failed to fetch BLOB

[ https://issues.apache.org/jira/browse/FLINK-14619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liang yu updated FLINK-14619: - Description: java.io.IOException: Failed to fetch BLOB e78e9574da4f5e4bdbc8de9678ebfb36/p-650534cd619de

[GitHub] [flink] zhijiangW commented on a change in pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

zhijiangW commented on a change in pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097#discussion_r342935391 ## File path: flink-runtime/src/main/java/org

[GitHub] [flink] flinkbot commented on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot commented on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550167630 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communit

[GitHub] [flink] zhijiangW commented on a change in pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

zhijiangW commented on a change in pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097#discussion_r342935412 ## File path: flink-runtime/src/main/java/org

[GitHub] [flink] zhijiangW commented on a change in pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

zhijiangW commented on a change in pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097#discussion_r342935446 ## File path: flink-runtime/src/main/java/org

[GitHub] [flink] zhijiangW commented on a change in pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

zhijiangW commented on a change in pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097#discussion_r342935424 ## File path: flink-runtime/src/main/java/org

[GitHub] [flink] liupc commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

liupc commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r342935051 ## File path: flink-dist/src/main/flink-bin/bin/flink-console.sh ## @@ -56,

[jira] [Updated] (FLINK-14326) Support to apply watermark assigner according to the WatermarkSpec in TableSourceTable

[ https://issues.apache.org/jira/browse/FLINK-14326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14326: --- Labels: pull-request-available (was: ) > Support to apply watermark assigner according to t

[GitHub] [flink] flinkbot commented on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

flinkbot commented on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097#issuecomment-550166959 ## CI report: * f72b6f5096ae65beb1647edc0e1db84ae9d320a9 : UNKN

[GitHub] [flink] flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550159742 ## CI report: * 3fd9876e046bb9a56f36995084b37675f3929e0d : PENDING [Build](https://travis-ci.c

[GitHub] [flink] wuchong opened a new pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong opened a new pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098 ## What is the purpose of the change This support DDL watermark end-to-end in blink planner.

[GitHub] [flink] flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate

flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate URL: https://github.com/apache/flink/pull/10082#issuecomment-549698167 ## CI report: * 9ad21545cdce68c8892941e8f33a89147bddb1f6 : SUCCES

[GitHub] [flink] guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r342920624 ## File path: flink-container/src/main/java/org/apache/flink/container/

[GitHub] [flink] zhuzhurk commented on issue #10094: [FLINK-14611][runtime] Move allVerticesInSameSlotSharingGroupByDefault setting from ExecutionConfig to StreamGraph

zhuzhurk commented on issue #10094: [FLINK-14611][runtime] Move allVerticesInSameSlotSharingGroupByDefault setting from ExecutionConfig to StreamGraph URL: https://github.com/apache/flink/pull/10094#issuecomment-550165387 @flinkbot run travis --

[jira] [Updated] (FLINK-14326) Support to apply watermark assigner according to the WatermarkSpec in TableSourceTable

[ https://issues.apache.org/jira/browse/FLINK-14326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14326: Description: Apply watermark assigner according to the {{WatermarkSpec}} in {{TableSourceTable}} when {{S

[GitHub] [flink] flinkbot edited a comment on issue #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a'

flinkbot edited a comment on issue #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a' URL: https://github.com/apache/flink/pull/10095#issuecomment-550153081 ## CI report: * 528020239cb7c531bf58a6abc9a68555fe8aa92e : PENDING [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot commented on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot commented on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550159742 ## CI report: * 3fd9876e046bb9a56f36995084b37675f3929e0d : UNKNOWN Bot commands The @f

[GitHub] [flink] flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate

flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate URL: https://github.com/apache/flink/pull/10082#issuecomment-549698167 ## CI report: * 9ad21545cdce68c8892941e8f33a89147bddb1f6 : SUCCES

[GitHub] [flink] zhuzhurk commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

zhuzhurk commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r342928270 ## File path: flink-container/src/test/java/org/apache/flink/container

[GitHub] [flink] flinkbot commented on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

flinkbot commented on issue #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097#issuecomment-550158833 Thanks a lot for your contribution to the Apache Flink project. I'm the @

[jira] [Updated] (FLINK-14603) NetworkBufferPoolTest.testBlockingRequestFromMultiLocalBufferPool timeout in travis

[ https://issues.apache.org/jira/browse/FLINK-14603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14603: --- Labels: pull-request-available test-stability (was: test-stability) > NetworkBufferPoolTest

[GitHub] [flink] wsry opened a new pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded.

wsry opened a new pull request #10097: [FLINK-14603][runtime]Notify the potential buffer consumers if the size of LocalBufferPool has been expanded. URL: https://github.com/apache/flink/pull/10097 ## What is the purpose of the change Currently, when the size of ```LocalBufferPool``` is e

[GitHub] [flink] flinkbot commented on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot commented on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550155300 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[jira] [Updated] (FLINK-14623) Add computed column information into TableSchema

[ https://issues.apache.org/jira/browse/FLINK-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14623: --- Labels: pull-request-available (was: ) > Add computed column information into TableSchema >

[GitHub] [flink] danny0405 opened a new pull request #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

danny0405 opened a new pull request #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096 …hema ## What is the purpose of the change This patch add computed column info into the `TableSchema`, also fix so

[GitHub] [flink] flinkbot commented on issue #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a'

flinkbot commented on issue #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a' URL: https://github.com/apache/flink/pull/10095#issuecomment-550153081 ## CI report: * 528020239cb7c531bf58a6abc9a68555fe8aa92e : UNKNOWN Bot commands The @flinkb

[GitHub] [flink] guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r342921109 ## File path: flink-container/src/test/java/org/apache/flink/container/

[GitHub] [flink] guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r342921023 ## File path: flink-container/src/main/java/org/apache/flink/container/

[GitHub] [flink] flinkbot commented on issue #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a'

flinkbot commented on issue #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a' URL: https://github.com/apache/flink/pull/10095#issuecomment-550149083 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Created] (FLINK-14624) Support computed column as rowtime attribute

Jark Wu created FLINK-14624: --- Summary: Support computed column as rowtime attribute Key: FLINK-14624 URL: https://issues.apache.org/jira/browse/FLINK-14624 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14623) Add computed column information into TableSchema

Danny Chen created FLINK-14623: -- Summary: Add computed column information into TableSchema Key: FLINK-14623 URL: https://issues.apache.org/jira/browse/FLINK-14623 Project: Flink Issue Type: Sub-

[GitHub] [flink] guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r342920624 ## File path: flink-container/src/main/java/org/apache/flink/container/

[jira] [Updated] (FLINK-14601) CLI documentation for list is missing '-a'

[ https://issues.apache.org/jira/browse/FLINK-14601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14601: --- Labels: pull-request-available (was: ) > CLI documentation for list is missing '-a' > -

[GitHub] [flink] zoudaokoulife opened a new pull request #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a'

zoudaokoulife opened a new pull request #10095: [FLINK-14601] [client] CLI documentation for list is missing '-a' URL: https://github.com/apache/flink/pull/10095 ## What is the purpose of the change resolve the issue CLI documentation for list is missing '-a' described in [FLIN

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r342914775 ## File path: flink-container/src/main/java/org/apache/flink/container/

[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#issuecomment-549401980 ## CI report: * 5b7e9e832ed26f476d0149663b2f0dec9f1bc427 : SUCCES

[GitHub] [flink] zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate

zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate URL: https://github.com/apache/flink/pull/10082#discussion_r342911786 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] wangyang0918 commented on issue #10089: [FLINK-12342][yarn] Remove container requests in order to reduce excess containers

wangyang0918 commented on issue #10089: [FLINK-12342][yarn] Remove container requests in order to reduce excess containers URL: https://github.com/apache/flink/pull/10089#issuecomment-550136405 I have tested the PR in the following cases. Ask 1000 containers with 500ms `containerRequestH

[jira] [Created] (FLINK-14622) Cooperate WatermarkSpec in TableSourceScan with minibatch configuration

Jark Wu created FLINK-14622: --- Summary: Cooperate WatermarkSpec in TableSourceScan with minibatch configuration Key: FLINK-14622 URL: https://issues.apache.org/jira/browse/FLINK-14622 Project: Flink

[jira] [Created] (FLINK-14621) Do not generate watermark assigner operator if no time attribute operations on rowtime

Jark Wu created FLINK-14621: --- Summary: Do not generate watermark assigner operator if no time attribute operations on rowtime Key: FLINK-14621 URL: https://issues.apache.org/jira/browse/FLINK-14621 Project:

[GitHub] [flink] guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r342908412 ## File path: flink-clients/src/main/java/org/apache/flink/client/progr

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #10094: [FLINK-14611][runtime] Move allVerticesInSameSlotSharingGroupByDefault setting from ExecutionConfig to StreamGraph

flinkbot edited a comment on issue #10094: [FLINK-14611][runtime] Move allVerticesInSameSlotSharingGroupByDefault setting from ExecutionConfig to StreamGraph URL: https://github.com/apache/flink/pull/10094#issuecomment-550114409 ## CI report: * 8d20db4cdea3e4e2a69590362675e7bf7e

[GitHub] [flink] flinkbot edited a comment on issue #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn

flinkbot edited a comment on issue #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn URL: https://github.com/apache/flink/pull/10084#issuecomment-549724300 ## CI report: * 0fca3b7914151ce638faa282a6c75096c6f404ed : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#issuecomment-549401980 ## CI report: * 5b7e9e832ed26f476d0149663b2f0dec9f1bc427 : SUCCES

[GitHub] [flink] zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate

zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate URL: https://github.com/apache/flink/pull/10082#discussion_r342905519 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate

zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a meter ‘numberOfRestarts’ to show number of restarts as well as its rate URL: https://github.com/apache/flink/pull/10082#discussion_r342904050 ## File path: flink-runtime/src/main/java/org/apache/fli

[jira] [Updated] (FLINK-14620) Rewrite the elasticsearch related end-to-end tests by using the newly introduce e2e java framework

[ https://issues.apache.org/jira/browse/FLINK-14620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng Hu updated FLINK-14620: - Attachment: FLINK-14620.v01.patch > Rewrite the elasticsearch related end-to-end tests by using the newl

[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#issuecomment-549401980 ## CI report: * 5b7e9e832ed26f476d0149663b2f0dec9f1bc427 : SUCCES

[GitHub] [flink] zjuwangg commented on a change in pull request #10093: [FLINK-14579][sql cli] enable SQL CLI to configure modules via yaml config

zjuwangg commented on a change in pull request #10093: [FLINK-14579][sql cli] enable SQL CLI to configure modules via yaml config URL: https://github.com/apache/flink/pull/10093#discussion_r342900270 ## File path: flink-table/flink-sql-client/conf/sql-client-defaults.yaml #

  1   2   3   4   5   >