[jira] [Created] (FLINK-29124) Redundant checkNotNull in cli Package

2022-08-26 Thread ivan Qing (Jira)
ivan Qing created FLINK-29124: - Summary: Redundant checkNotNull in cli Package Key: FLINK-29124 URL: https://issues.apache.org/jira/browse/FLINK-29124 Project: Flink Issue Type: Improvement

Re: [DISCUSS] ARM support for Flink

2022-08-26 Thread bo zhaobo
Hi, Thanks for feeback and descirption, Yang Wang. I saw multiple Flink associated docker images on dockerhub and released with X86 & ARM64. So we think that might be useful for community to setup ARM CI relied on existing CICD system. We are happy that we could help on that via donating ARM

[jira] [Created] (FLINK-29123) Dynamic paramters are not pushed to working with kubertenes

2022-08-26 Thread Peter Vary (Jira)
Peter Vary created FLINK-29123: -- Summary: Dynamic paramters are not pushed to working with kubertenes Key: FLINK-29123 URL: https://issues.apache.org/jira/browse/FLINK-29123 Project: Flink

[jira] [Created] (FLINK-29122) Improve robustness of FileUtils.expandDirectory()

2022-08-26 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-29122: -- Summary: Improve robustness of FileUtils.expandDirectory() Key: FLINK-29122 URL: https://issues.apache.org/jira/browse/FLINK-29122 Project: Flink Issue

[jira] [Created] (FLINK-29121) SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed

2022-08-26 Thread Jark Wu (Jira)
Jark Wu created FLINK-29121: --- Summary: SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed Key: FLINK-29121 URL: https://issues.apache.org/jira/browse/FLINK-29121 Project: Flink

Re: [DISCUSS] ARM support for Flink

2022-08-26 Thread Yang Wang
Thanks Bo for starting this discussion. I think it is really useful to have the CI for ARM platform. But I am not sure what is the current situation. TBH, I have not build an ARM image for Flink. Given that we have not finished the migration from azure pipelines to github action, I believe we

Re: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

2022-08-26 Thread Zheng Yu Chen
HI Hong, Maybe you forgot. I don’t know if the current FLIP still needs to be modified. If not, we will start with the current plan. If you have relevant ideas in the future, please continue to discuss. If not, we will open voting at a later date. Teoh, Hong 于2022年8月22日周一 16:02写道: > > Hi Zheng

Re: [Discuss] Let's Session Cluster JobManager take a breather (FLIP-257: Flink JobManager Process Split)

2022-08-26 Thread Zheng Yu Chen
Hi Chesnay , I have also considered the method you mentioned. If we deploy some load balancing or intelligent scheduling in front of multiple SessionClusters, this may cause the following problems ● Insufficient resource utilization. When we distribute these resources on each cluster, the job

[jira] [Created] (FLINK-29120) Unexpected join hint propagation into view

2022-08-26 Thread lincoln lee (Jira)
lincoln lee created FLINK-29120: --- Summary: Unexpected join hint propagation into view Key: FLINK-29120 URL: https://issues.apache.org/jira/browse/FLINK-29120 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29119) Should clarify how join hints work with CTE

2022-08-26 Thread lincoln lee (Jira)
lincoln lee created FLINK-29119: --- Summary: Should clarify how join hints work with CTE Key: FLINK-29119 URL: https://issues.apache.org/jira/browse/FLINK-29119 Project: Flink Issue Type:

[jira] [Created] (FLINK-29118) Remove default_catalog in the HiveServer2 Endpoint

2022-08-26 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-29118: - Summary: Remove default_catalog in the HiveServer2 Endpoint Key: FLINK-29118 URL: https://issues.apache.org/jira/browse/FLINK-29118 Project: Flink Issue

Re: [DISCUSS] Support 'DYNAMIC MetadataColumn' in flink table

2022-08-26 Thread Timo Walther
Hi Ran, so if I understand it correctly, the problem here is not only backward compatibility but also forward compatibility. You might run different versions of your connector some of them offer a metadata key A and some don't offer it yet. But the DDL should work for both connector

[jira] [Created] (FLINK-29117) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
geonyeong kim created FLINK-29117: - Summary: Tried to associate with unreachable remote address Key: FLINK-29117 URL: https://issues.apache.org/jira/browse/FLINK-29117 Project: Flink Issue

[jira] [Created] (FLINK-29116) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
geonyeong kim created FLINK-29116: - Summary: Tried to associate with unreachable remote address Key: FLINK-29116 URL: https://issues.apache.org/jira/browse/FLINK-29116 Project: Flink Issue

[jira] [Created] (FLINK-29115) Improve the quickstart of Flink ML python API

2022-08-26 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-29115: Summary: Improve the quickstart of Flink ML python API Key: FLINK-29115 URL: https://issues.apache.org/jira/browse/FLINK-29115 Project: Flink Issue Type:

Re: [DISCUSS] Support 'DYNAMIC MetadataColumn' in flink table

2022-08-26 Thread Jark Wu
Hi Ran, If the metadata is from the message properties, then you can manually cast it to your preferred types, such as `my_dyanmic_meta AS CAST(properties['my-new-property’] AS TIMESTAMP)`. If the metadata is not from the message properties, how does the connector know which field to convert

Re: Energy/performance research questions

2022-08-26 Thread Piotr Nowojski
Hi Sana, I don't have much to offer. I haven't heard anyone doing any work directly towards energy efficiency per se, but indirectly yes. I have seen companies optimising performance of their workloads, with an ultimate goal of assigning fewer resources to a cluster in order to save up on a

[jira] [Created] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2022-08-26 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29114: --- Summary: TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch Key: FLINK-29114 URL:

Re: [DISCUSS] Support 'DYNAMIC MetadataColumn' in flink table

2022-08-26 Thread Ran Tao
Hi, TiMo. I think using one map column in the debezium format you illustrated above can't cover the discussed scenario. It's not the same thing. Here is a debezium format example from flink docs: [1] ``` CREATE TABLE KafkaTable ( origin_ts TIMESTAMP(3) METADATA FROM 'value.ingestion-timestamp'

[jira] [Created] (FLINK-29113) Join hint with invalid table name mixed with valid names will not raise an error

2022-08-26 Thread lincoln lee (Jira)
lincoln lee created FLINK-29113: --- Summary: Join hint with invalid table name mixed with valid names will not raise an error Key: FLINK-29113 URL: https://issues.apache.org/jira/browse/FLINK-29113

[jira] [Created] (FLINK-29112) Print the lookup join hint on the node `Correlate` in the origin RelNode tree

2022-08-26 Thread lincoln lee (Jira)
lincoln lee created FLINK-29112: --- Summary: Print the lookup join hint on the node `Correlate` in the origin RelNode tree Key: FLINK-29112 URL: https://issues.apache.org/jira/browse/FLINK-29112 Project:

[jira] [Created] (FLINK-29111) deprecate 'lookup.async' and expose both async and sync lookup capabilities to planner

2022-08-26 Thread lincoln lee (Jira)
lincoln lee created FLINK-29111: --- Summary: deprecate 'lookup.async' and expose both async and sync lookup capabilities to planner Key: FLINK-29111 URL: https://issues.apache.org/jira/browse/FLINK-29111