[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354186423 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354186185 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354186014 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354185736 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354185698 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354185554 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354185056 ## File path:

[jira] [Updated] (FLINK-15073) sql client fails to run same query multiple times

[ https://issues.apache.org/jira/browse/FLINK-15073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15073: --- Fix Version/s: 1.10.0 > sql client fails to run same query multiple times >

[jira] [Updated] (FLINK-15073) sql client fails to run same query multiple times

[ https://issues.apache.org/jira/browse/FLINK-15073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15073: --- Affects Version/s: 1.10.0 > sql client fails to run same query multiple times >

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354183975 ## File path:

[jira] [Commented] (FLINK-13197) support querying Hive's view in Flink

[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988606#comment-16988606 ] Dawid Wysakowicz commented on FLINK-13197: -- Hey [~danny0405] I think this is could be an

[jira] [Created] (FLINK-15073) sql client fails to run same query multiple times

Kurt Young created FLINK-15073: -- Summary: sql client fails to run same query multiple times Key: FLINK-15073 URL: https://issues.apache.org/jira/browse/FLINK-15073 Project: Flink Issue Type:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354183975 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354183688 ## File path:

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

wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354183500 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354182690 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354182013 ## File path:

[GitHub] [flink] flinkbot commented on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

flinkbot commented on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#issuecomment-562037381 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] WeiZhong94 commented on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

WeiZhong94 commented on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126#issuecomment-562036708 @hequn8128 Thanks for your comments! I have

[GitHub] [flink] wuchong commented on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute

wuchong commented on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute URL: https://github.com/apache/flink/pull/10316#issuecomment-562036887 We introduced `XmlOutput` as a temporary solution to get a right plan XML. Will be removed in FLINK-15064.

[jira] [Commented] (FLINK-13197) support querying Hive's view in Flink

[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988604#comment-16988604 ] Rui Li commented on FLINK-13197: I hit some issue when trying to query views created in Hive. The view

[jira] [Comment Edited] (FLINK-15031) Calculate required shuffle memory cases before allocating slots in resources specified

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988603#comment-16988603 ] Zhu Zhu edited comment on FLINK-15031 at 12/5/19 9:03 AM: -- Thanks [~trohrmann]

[GitHub] [flink] flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] correct the state_backends.zh external link and some other things

flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] correct the state_backends.zh external link and some other things URL: https://github.com/apache/flink/pull/10206#issuecomment-554207625 ## CI report: * 6c2fb0094be219ab90a28b525a5d0c8504f2d45d : SUCCESS

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354179716 ## File path:

[jira] [Updated] (FLINK-13955) Integrate ContinuousFileReaderOperator with StreamTask mailbox execution model

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

[GitHub] [flink] rkhachatryan opened a new pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan opened a new pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435 ## What is the purpose of the change Use mailbox execution model in

[jira] [Commented] (FLINK-15031) Calculate required shuffle memory cases before allocating slots in resources specified

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988603#comment-16988603 ] Zhu Zhu commented on FLINK-15031: - Thanks [~trohrmann] for the feedbacks. I can work on it. Agreed that

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354179274 ## File path:

[GitHub] [flink] wuchong commented on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute

wuchong commented on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute URL: https://github.com/apache/flink/pull/10316#issuecomment-562035759 As discussed offline, we will make `StreamExecWatermarkAssigner` and `StreamExecMiniBatchAssigner` independent,

[GitHub] [flink] HuangXingBo commented on a change in pull request #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py

HuangXingBo commented on a change in pull request #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py URL: https://github.com/apache/flink/pull/10389#discussion_r354177072 ## File path:

[GitHub] [flink] HuangXingBo commented on a change in pull request #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py

HuangXingBo commented on a change in pull request #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py URL: https://github.com/apache/flink/pull/10389#discussion_r354176527 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354176590 ## File path:

[GitHub] [flink] flinkbot commented on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment

flinkbot commented on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619 ## CI report: * e0b1afaebe5bd4fc07e61785a38ef82f55e16f69 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10429: [FLINK-14965] [table-planner-blink] correct the logic of convertToTableStats method in CatalogTableStatisticsConverter

flinkbot edited a comment on issue #10429: [FLINK-14965] [table-planner-blink] correct the logic of convertToTableStats method in CatalogTableStatisticsConverter URL: https://github.com/apache/flink/pull/10429#issuecomment-562021544 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

flinkbot commented on issue #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#issuecomment-562033539 ## CI report: * 735df4f522069f08b8b4b26a0018a6440293c507 : UNKNOWN

[GitHub] [flink] StephanEwen commented on a change in pull request #10384: [FLINK-13373][docs] Remove Tutorials and Examples sections from Getting Started

StephanEwen commented on a change in pull request #10384: [FLINK-13373][docs] Remove Tutorials and Examples sections from Getting Started URL: https://github.com/apache/flink/pull/10384#discussion_r354175999 ## File path: docs/ops/deployment/local.md ## @@ -0,0 +1,178 @@

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

wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354175932 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor…

flinkbot edited a comment on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor… URL: https://github.com/apache/flink/pull/10418#issuecomment-561567846 ## CI report: * 6951e77dff9c9c4fb1945d79ef4253e5ea2c0f0f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10396: [FLINK-14063][table-planner-blink] Operators use fractions to decide how many managed memory to allocate

flinkbot edited a comment on issue #10396: [FLINK-14063][table-planner-blink] Operators use fractions to decide how many managed memory to allocate URL: https://github.com/apache/flink/pull/10396#issuecomment-561124660 ## CI report: * b14ea7de34c32381e404b5cd11321f010453c24d :

[GitHub] [flink] flinkbot edited a comment on issue #10399: [FLINK-14959][table-planner-blink] Support precision of LocalZonedTimestampType in blink planner

flinkbot edited a comment on issue #10399: [FLINK-14959][table-planner-blink] Support precision of LocalZonedTimestampType in blink planner URL: https://github.com/apache/flink/pull/10399#issuecomment-561147932 ## CI report: * 526d1701763e74c12064e6b7f48b8f41f4857bd8 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10434: [FLINK-15072][client] Hijack executeAsync instead of execute in context environment

flinkbot commented on issue #10434: [FLINK-15072][client] Hijack executeAsync instead of execute in context environment URL: https://github.com/apache/flink/pull/10434#issuecomment-562032236 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354174597 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354174597 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

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

azagrebin 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_r354174053 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354173514 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354173514 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354173514 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

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

azagrebin 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_r354172891 ## File path:

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

azagrebin 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_r354172891 ## File path:

[GitHub] [flink] flinkbot commented on issue #10433: [FLINK-15071] YARN vcore capacity check can not pass when use large slotPerTaskManager

flinkbot commented on issue #10433: [FLINK-15071] YARN vcore capacity check can not pass when use large slotPerTaskManager URL: https://github.com/apache/flink/pull/10433#issuecomment-562030768 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

flinkbot edited a comment on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#issuecomment-558970068 ## CI report: * e3aa8e5a567a13f07598ee6fe0e8fb8e72dfb986 : SUCCESS

[jira] [Updated] (FLINK-15072) Hijack executeAsync instead of execute in context environment

[ https://issues.apache.org/jira/browse/FLINK-15072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15072: --- Labels: pull-request-available (was: ) > Hijack executeAsync instead of execute in context

[GitHub] [flink] TisonKun opened a new pull request #10434: [FLINK-15072][client] Hijack executeAsync instead of execute in context environment

TisonKun opened a new pull request #10434: [FLINK-15072][client] Hijack executeAsync instead of execute in context environment URL: https://github.com/apache/flink/pull/10434 ## What is the purpose of the change Currently, if users write program using `executeAsync`, it doesn't work

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354172625 ## File path:

[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] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354171976 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199 ## CI report: * 0b265d192e2a6024e5817317be0317136208ccaf : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp

flinkbot commented on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp URL: https://github.com/apache/flink/pull/10432#issuecomment-562030050 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] KurtYoung commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

KurtYoung commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354171651 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[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

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

azagrebin 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_r354171780 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

JingsongLi commented on a change in pull request #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#discussion_r354171720 ## File path:

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

wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354171589 ## File path:

[GitHub] [flink] wangxiyuan commented on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp

wangxiyuan commented on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp URL: https://github.com/apache/flink/pull/10432#issuecomment-562029792 @StephanEwen, Hi, this is another place that impact flink-table-planner unit test. Please help review. Thank you

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

wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354171105 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints

flinkbot edited a comment on issue #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints URL: https://github.com/apache/flink/pull/10249#issuecomment-555440054 ## CI report: * bd253651412e9ca6857cf0ba299bdd1bf544c2c4 : SUCCESS

[jira] [Updated] (FLINK-15071) YARN vcore capacity check can not pass when use large slotPerTaskManager

[ https://issues.apache.org/jira/browse/FLINK-15071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15071: --- Labels: pull-request-available (was: ) > YARN vcore capacity check can not pass when use

[jira] [Created] (FLINK-15072) Hijack executeAsync instead of execute in context environment

Zili Chen created FLINK-15072: - Summary: Hijack executeAsync instead of execute in context environment Key: FLINK-15072 URL: https://issues.apache.org/jira/browse/FLINK-15072 Project: Flink

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

azagrebin 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_r354170454 ## File path:

[GitHub] [flink] huwh opened a new pull request #10433: [FLINK-15071] YARN vcore capacity check can not pass when use large slotPerTaskManager

huwh opened a new pull request #10433: [FLINK-15071] YARN vcore capacity check can not pass when use large slotPerTaskManager URL: https://github.com/apache/flink/pull/10433 ## What is the purpose of the change This pull request load dynamic properties before check YARN vcore

[GitHub] [flink] wangxiyuan opened a new pull request #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp

wangxiyuan opened a new pull request #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp URL: https://github.com/apache/flink/pull/10432 ## What is the purpose of the change Some math calculation result is different between x86 and aarch64 because of

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354170174 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354169771 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354169328 ## File path:

[GitHub] [flink] JingsongLi commented on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor…

JingsongLi commented on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor… URL: https://github.com/apache/flink/pull/10418#issuecomment-562028316 LGTM after travis success. This is an

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354169399 ## File path:

[jira] [Commented] (FLINK-15063) input group and output group of the task metric are reversed

[ https://issues.apache.org/jira/browse/FLINK-15063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988583#comment-16988583 ] Andrey Zagrebin commented on FLINK-15063: - Thanks for noticing this [~lining] I am assigning you

[jira] [Assigned] (FLINK-15063) input group and output group of the task metric are reversed

[ https://issues.apache.org/jira/browse/FLINK-15063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-15063: --- Assignee: lining > input group and output group of the task metric are reversed >

[GitHub] [flink] KurtYoung commented on a change in pull request #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

KurtYoung commented on a change in pull request #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#discussion_r354168138 ## File path:

[jira] [Updated] (FLINK-15063) input group and output group of the task metric are reversed

[ https://issues.apache.org/jira/browse/FLINK-15063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-15063: Affects Version/s: 1.9.0 > input group and output group of the task metric are reversed >

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

KurtYoung commented on issue #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints URL: https://github.com/apache/flink/pull/10249#issuecomment-562026708 @zjuwangg Please help reviewing codes from hive's side. I don't familiar with hive shim as well...

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

wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354167152 ## File path:

[jira] [Created] (FLINK-15071) YARN vcore capacity check can not pass when use large slotPerTaskManager

huweihua created FLINK-15071: Summary: YARN vcore capacity check can not pass when use large slotPerTaskManager Key: FLINK-15071 URL: https://issues.apache.org/jira/browse/FLINK-15071 Project: Flink

[GitHub] [flink] KurtYoung commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

KurtYoung commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354166618 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java

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

WeiZhong94 commented on a change in pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126#discussion_r354166574 ## File path:

[jira] [Created] (FLINK-15070) Supplement the case of bounded blocking partition for benchmark

zhijiang created FLINK-15070: Summary: Supplement the case of bounded blocking partition for benchmark Key: FLINK-15070 URL: https://issues.apache.org/jira/browse/FLINK-15070 Project: Flink

[GitHub] [flink] flinkbot commented on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment

flinkbot commented on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment URL: https://github.com/apache/flink/pull/10431#issuecomment-562025561 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-15067) Pass execution configuration from TableEnvironment to StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-15067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15067: --- Labels: pull-request-available (was: ) > Pass execution configuration from

[GitHub] [flink] dawidwys opened a new pull request #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment

dawidwys opened a new pull request #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment URL: https://github.com/apache/flink/pull/10431 ## What is the purpose of the change After this PR the `TableEnvironment` passes

[jira] [Created] (FLINK-15069) Supplement the compression case for benchmark

zhijiang created FLINK-15069: Summary: Supplement the compression case for benchmark Key: FLINK-15069 URL: https://issues.apache.org/jira/browse/FLINK-15069 Project: Flink Issue Type: Task

[GitHub] [flink] flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] correct the state_backends.zh external link and some other things

flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] correct the state_backends.zh external link and some other things URL: https://github.com/apache/flink/pull/10206#issuecomment-554207625 ## CI report: * 6c2fb0094be219ab90a28b525a5d0c8504f2d45d : SUCCESS

[jira] [Created] (FLINK-15068) Disable RocksDB's local LOG by default

Nico Kruber created FLINK-15068: --- Summary: Disable RocksDB's local LOG by default Key: FLINK-15068 URL: https://issues.apache.org/jira/browse/FLINK-15068 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on issue #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

flinkbot commented on issue #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#issuecomment-562023662 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] wangxiyuan commented on issue #10424: [FLINK-15060][tests] Add aarch64 support for tpcds e2e test

wangxiyuan commented on issue #10424: [FLINK-15060][tests] Add aarch64 support for tpcds e2e test URL: https://github.com/apache/flink/pull/10424#issuecomment-562023193 @KurtYoung, wow, thanks for your quick merge. This is the newest test result under aarch64 with this PR:

[jira] [Created] (FLINK-15067) Pass execution configuration from TableEnvironment to StreamExecutionEnvironment

Dawid Wysakowicz created FLINK-15067: Summary: Pass execution configuration from TableEnvironment to StreamExecutionEnvironment Key: FLINK-15067 URL: https://issues.apache.org/jira/browse/FLINK-15067

[GitHub] [flink] WeiZhong94 opened a new pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

WeiZhong94 opened a new pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430 ## What is the purpose of the change *This pull request adds command-line options

[GitHub] [flink] flinkbot edited a comment on issue #9985: [FLINK-10968][kubernetes] Implement TaskManager Entrypoint for Kubernetes.

flinkbot edited a comment on issue #9985: [FLINK-10968][kubernetes] Implement TaskManager Entrypoint for Kubernetes. URL: https://github.com/apache/flink/pull/9985#issuecomment-545891561 ## CI report: * e74d80aaf05f631c7757483023657bee6f533e45 : SUCCESS

[jira] [Created] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

Kurt Young created FLINK-15066: -- Summary: Cannot run multiple `insert into csvTable values ()` Key: FLINK-15066 URL: https://issues.apache.org/jira/browse/FLINK-15066 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on issue #10429: [FLINK-14965] [table-planner-blink] correct the logic of convertToTableStats method in CatalogTableStatisticsConverter

flinkbot commented on issue #10429: [FLINK-14965] [table-planner-blink] correct the logic of convertToTableStats method in CatalogTableStatisticsConverter URL: https://github.com/apache/flink/pull/10429#issuecomment-562021544 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10419: [FLINK-15026][SQL-CLIENT]Support create/drop/alter database in sql client

flinkbot edited a comment on issue #10419: [FLINK-15026][SQL-CLIENT]Support create/drop/alter database in sql client URL: https://github.com/apache/flink/pull/10419#issuecomment-561585485 ## CI report: * 043379493823c0ac38c05d355471079d6808d16a : FAILURE

<    4   5   6   7   8   9   10   >