[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352455881 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352455990 ## File path:

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

[ https://issues.apache.org/jira/browse/FLINK-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985879#comment-16985879 ] Wei Zhong commented on FLINK-14604: --- [~chesnay] Sorry for the late reply. In the initial design, the

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352455574 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352455381 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352455116 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352454548 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog

lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog URL: https://github.com/apache/flink/pull/10325#discussion_r352454042 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352452680 ## File path:

[jira] [Issue Comment Deleted] (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: -- Comment: was deleted (was: [~chesnay] Sorry for the late reply. During this time I conducted a

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352452241 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352451669 ## File path:

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

[ https://issues.apache.org/jira/browse/FLINK-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985874#comment-16985874 ] Wei Zhong commented on FLINK-14604: --- [~chesnay] Sorry for the late reply. During this time I conducted

[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=16985873#comment-16985873 ] Yingjie Cao commented on FLINK-14845: - Based on the above discussions, I have given an

[GitHub] [flink] xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352451669 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352451400 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10318: [FLINK-14721][hive]HiveTableSource implement LimitableTableSource interface

lirui-apache commented on a change in pull request #10318: [FLINK-14721][hive]HiveTableSource implement LimitableTableSource interface URL: https://github.com/apache/flink/pull/10318#discussion_r352448492 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9985: [FLINK-10968][kubernetes] Implement TaskManager Entrypoint for Kubernetes.

zhijiangW commented on a change in pull request #9985: [FLINK-10968][kubernetes] Implement TaskManager Entrypoint for Kubernetes. URL: https://github.com/apache/flink/pull/9985#discussion_r352451266 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9985: [FLINK-10968][kubernetes] Implement TaskManager Entrypoint for Kubernetes.

zhijiangW commented on a change in pull request #9985: [FLINK-10968][kubernetes] Implement TaskManager Entrypoint for Kubernetes. URL: https://github.com/apache/flink/pull/9985#discussion_r352450855 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

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

[ https://issues.apache.org/jira/browse/FLINK-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-14845: Labels: pull-request-available (was: ) > Introduce data compression to blocking shuffle. >

[GitHub] [flink] flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-560214201 ## CI report: * af7ab17308bafebf22198881ad59ec4516da43e2 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10376: [FLINK-14907] [filesystem] Make Azure Storage Key configurable via Environment Variable

flinkbot commented on issue #10376: [FLINK-14907] [filesystem] Make Azure Storage Key configurable via Environment Variable URL: https://github.com/apache/flink/pull/10376#issuecomment-560269221 ## CI report: * ab1dcfbe1fac150e4be884dba92e29f0e345847b : UNKNOWN Bot

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352448923 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352447974 ## File path:

[GitHub] [flink] KurtYoung commented on issue #10318: [FLINK-14721][hive]HiveTableSource implement LimitableTableSource interface

KurtYoung commented on issue #10318: [FLINK-14721][hive]HiveTableSource implement LimitableTableSource interface URL: https://github.com/apache/flink/pull/10318#issuecomment-560267204 @zjuwangg could you rebase to master?

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352447200 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352446502 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352445624 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352445624 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352444665 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352444389 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog

lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog URL: https://github.com/apache/flink/pull/10325#discussion_r352442401 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog

lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog URL: https://github.com/apache/flink/pull/10325#discussion_r352439590 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog

lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog URL: https://github.com/apache/flink/pull/10325#discussion_r352443158 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog

lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog URL: https://github.com/apache/flink/pull/10325#discussion_r352441337 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog

lirui-apache commented on a change in pull request #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog URL: https://github.com/apache/flink/pull/10325#discussion_r352439856 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#discussion_r352443161 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#discussion_r352442350 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#discussion_r352441725 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#discussion_r352440159 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

xintongsong commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352440321 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#discussion_r352439583 ## File path:

[jira] [Assigned] (FLINK-15004) Choose SortMergeJoin instead of HashJoin if the statistics is unknown

[ https://issues.apache.org/jira/browse/FLINK-15004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15004: -- Assignee: godfrey he > Choose SortMergeJoin instead of HashJoin if the statistics is unknown

[jira] [Assigned] (FLINK-14662) Distinguish unknown CatalogTableStatistics and zero

[ https://issues.apache.org/jira/browse/FLINK-14662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14662: -- Assignee: Terry Wang > Distinguish unknown CatalogTableStatistics and zero >

[GitHub] [flink] flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-560214201 ## CI report: * af7ab17308bafebf22198881ad59ec4516da43e2 : SUCCESS

[jira] [Commented] (FLINK-14662) Distinguish unknown CatalogTableStatistics and zero

[ https://issues.apache.org/jira/browse/FLINK-14662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985857#comment-16985857 ] Terry Wang commented on FLINK-14662: +1 for this issue. I'd like to fix it. > Distinguish unknown

[GitHub] [flink] zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#discussion_r352438110 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#discussion_r352437741 ## File path:

[jira] [Closed] (FLINK-14135) Introduce vectorized orc InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-14135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14135. -- Fix Version/s: 1.10.0 Resolution: Fixed merged to master:

[GitHub] [flink] KurtYoung closed pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

KurtYoung closed pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022 This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot commented on issue #10376: [FLINK-14907] [filesystem] Make Azure Storage Key configurable via Environment Variable

flinkbot commented on issue #10376: [FLINK-14907] [filesystem] Make Azure Storage Key configurable via Environment Variable URL: https://github.com/apache/flink/pull/10376#issuecomment-560253884 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] wangyang0918 commented on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-560253778 @zhuzhurk Thanks a lot for your detailed review. I will address your comments one by one.

[GitHub] [flink] KurtYoung commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

KurtYoung commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#discussion_r352436580 ## File path:

[jira] [Updated] (FLINK-14907) Support to Configure Azure Storage Key via Environment Variable

[ https://issues.apache.org/jira/browse/FLINK-14907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14907: --- Labels: pull-request-available (was: ) > Support to Configure Azure Storage Key via

[GitHub] [flink] knaufk opened a new pull request #10376: [FLINK-14907] [filesystem] Make Azure Storage Key configurable via Environment Variable

knaufk opened a new pull request #10376: [FLINK-14907] [filesystem] Make Azure Storage Key configurable via Environment Variable URL: https://github.com/apache/flink/pull/10376 ## What is the purpose of the change Make Azure Storage Key configurable via Environment Variable

[jira] [Updated] (FLINK-10934) Support per-job mode in kubernetes

[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-10934: -- Summary: Support per-job mode in kubernetes (was: Implement KubernetesJobClusterEntrypoint) >

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

[ https://issues.apache.org/jira/browse/FLINK-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14847: -- Assignee: Rui Li > Support retrieving Hive PK constraints >

[jira] [Closed] (FLINK-15005) Change CatalogTableStats.UNKNOW and HiveStatsUtil stats default value

[ https://issues.apache.org/jira/browse/FLINK-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15005. -- Resolution: Duplicate > Change CatalogTableStats.UNKNOW and HiveStatsUtil stats default value >

[GitHub] [flink] wangxlong commented on issue #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor

wangxlong commented on issue #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor URL: https://github.com/apache/flink/pull/10357#issuecomment-560250990 > Thanks for driving this and leave some comments and IMO we should discuss and confirm the semantics

[GitHub] [flink] zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#discussion_r352434569 ## File path:

[jira] [Commented] (FLINK-14990) Add bit functions to Blink planner

[ https://issues.apache.org/jira/browse/FLINK-14990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985850#comment-16985850 ] hailong wang commented on FLINK-14990: -- Hi [~jark]. OH, I am so sorry for opening pull request

[GitHub] [flink] flinkbot edited a comment on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements

flinkbot edited a comment on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements URL: https://github.com/apache/flink/pull/10127#issuecomment-551413577 ## CI report: * 02df4747bebc7f7601bce39dea46ea285c46 : SUCCESS

[jira] [Commented] (FLINK-15005) Change CatalogTableStats.UNKNOW and HiveStatsUtil stats default value

[ https://issues.apache.org/jira/browse/FLINK-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985846#comment-16985846 ] Terry Wang commented on FLINK-15005: Yes, It's duplicated. > Change CatalogTableStats.UNKNOW and

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-560214201 ## CI report: * af7ab17308bafebf22198881ad59ec4516da43e2 : SUCCESS

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

[ https://issues.apache.org/jira/browse/FLINK-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985838#comment-16985838 ] Rui Li commented on FLINK-14847: [~dwysakowicz] Yes please assign this one to me. Thank you. > Support

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

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

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

wsry commented on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-560241774 I opened this PR for FLINK-14845, could you please take a look? @pnowojski @zhijiangW

[GitHub] [flink] flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-560214201 ## CI report: * af7ab17308bafebf22198881ad59ec4516da43e2 : SUCCESS

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

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

[GitHub] [flink] JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#discussion_r352426954 ## File path:

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

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

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

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

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

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

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

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

[GitHub] [flink] KurtYoung commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

KurtYoung commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#discussion_r352425132 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements

flinkbot edited a comment on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements URL: https://github.com/apache/flink/pull/10127#issuecomment-551413577 ## CI report: * 02df4747bebc7f7601bce39dea46ea285c46 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner

flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner URL: https://github.com/apache/flink/pull/10315#issuecomment-558221318 ## CI report: * 05b30617c280796e80e8569dae48b726cddb23d8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-555964030 ## CI report: * 72414aad5f654b834205103f23fbbfc3d5466748 : FAILURE

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

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

[GitHub] [flink] flinkbot edited a comment on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements

flinkbot edited a comment on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements URL: https://github.com/apache/flink/pull/10127#issuecomment-551413577 ## CI report: * 02df4747bebc7f7601bce39dea46ea285c46 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

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

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

[GitHub] [flink] flinkbot edited a comment on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time

flinkbot edited a comment on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time URL: https://github.com/apache/flink/pull/8746#issuecomment-528887595 ## CI report: * ed381a566a61e9d5e0677cc0b68e1eee4a4bf46d : SUCCESS

[jira] [Updated] (FLINK-15001) The digest of sub-plan reuse should contain retraction traits for stream physical nodes

[ https://issues.apache.org/jira/browse/FLINK-15001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15001: --- Description: This bug is found in [FLINK-14946|

[GitHub] [flink] JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#discussion_r352414765 ## File path:

[jira] [Updated] (FLINK-15001) The digest of sub-plan reuse should contain retraction traits for stream physical nodes

[ https://issues.apache.org/jira/browse/FLINK-15001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15001: --- Summary: The digest of sub-plan reuse should contain retraction traits for stream physical nodes

[GitHub] [flink] JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#discussion_r352414765 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

[GitHub] [flink] KurtYoung commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

KurtYoung commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#discussion_r352413977 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10375: [Flink-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

flinkbot edited a comment on issue #10375: [Flink-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-560214201 ## CI report: * af7ab17308bafebf22198881ad59ec4516da43e2 : PENDING

[GitHub] [flink] zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

zhijiangW commented on a change in pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#discussion_r352413463 ## File path:

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

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

[GitHub] [flink] docete commented on a change in pull request #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor

docete commented on a change in pull request #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor URL: https://github.com/apache/flink/pull/10357#discussion_r352411691 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

zhuzhurk commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352413026 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor

docete commented on a change in pull request #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor URL: https://github.com/apache/flink/pull/10357#discussion_r352412430 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

zhuzhurk commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r352411148 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor

docete commented on a change in pull request #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor URL: https://github.com/apache/flink/pull/10357#discussion_r352411945 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor

docete commented on a change in pull request #10357: [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor URL: https://github.com/apache/flink/pull/10357#discussion_r352411847 ## File path:

  1   2   3   4   >