[jira] [Created] (FLINK-28604) job failover and not restore from checkpoint in zookeeper HA mode

2022-07-18 Thread KevinyhZou (Jira)
KevinyhZou created FLINK-28604: -- Summary: job failover and not restore from checkpoint in zookeeper HA mode Key: FLINK-28604 URL: https://issues.apache.org/jira/browse/FLINK-28604 Project: Flink

[jira] [Created] (FLINK-28603) Flink runtime.rpc.RpcServiceUtils code style

2022-07-18 Thread wuqingzhi (Jira)
wuqingzhi created FLINK-28603: - Summary: Flink runtime.rpc.RpcServiceUtils code style Key: FLINK-28603 URL: https://issues.apache.org/jira/browse/FLINK-28603 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-28602) Changelog cannot close stream normally while enabling compression

2022-07-18 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-28602: Summary: Changelog cannot close stream normally while enabling compression Key: FLINK-28602 URL: https://issues.apache.org/jira/browse/FLINK-28602 Project: Flink

[jira] [Created] (FLINK-28601) Support FeatureHasher in FlinkML

2022-07-18 Thread weibo zhao (Jira)
weibo zhao created FLINK-28601: -- Summary: Support FeatureHasher in FlinkML Key: FLINK-28601 URL: https://issues.apache.org/jira/browse/FLINK-28601 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28600) Support FilterPushDown in flink-connector-jdbc

2022-07-18 Thread Hailin Wang (Jira)
Hailin Wang created FLINK-28600: --- Summary: Support FilterPushDown in flink-connector-jdbc Key: FLINK-28600 URL: https://issues.apache.org/jira/browse/FLINK-28600 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-28599) Adding FlinkJoinToMultiJoinRule to support left/right outer join can be translated to multi join

2022-07-18 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-28599: - Summary: Adding FlinkJoinToMultiJoinRule to support left/right outer join can be translated to multi join Key: FLINK-28599 URL: https://issues.apache.org/jira/browse/FLINK-28599

[jira] [Created] (FLINK-28598) ClusterEntryPoint can't get the real exit reason when shutting down

2022-07-18 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-28598: --- Summary: ClusterEntryPoint can't get the real exit reason when shutting down Key: FLINK-28598 URL: https://issues.apache.org/jira/browse/FLINK-28598 Project: Flink

Re: [DISCUSS] FLIP-248: Introduce dynamic partition pruning

2022-07-18 Thread godfrey he
Hi, Jingong, Jark, Jing, Thanks for for the important inputs. Lake storage is a very important scenario, and consider more generic and extended case, I also would like to use "dynamic filtering" concept instead of "dynamic partition". >maybe the FLIP should also demonstrate the EXPLAIN result, wh

Re: [DISCUSS] FLIP-238: Introduce FLIP-27-based Data Generator Source

2022-07-18 Thread Alexander Fedulov
Hi all, I updated the FLIP [1] to make it more extensible with the introduction of *SourceReaderFactory. *It gives users the ability to further customize the data generation and emission process if needed. I also incorporated the suggestion from Qingsheng and moved to the generator function design

[jira] [Created] (FLINK-28597) Empty checkpoint folders not deleted on job cancellation if their shared state is still in use

2022-07-18 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-28597: - Summary: Empty checkpoint folders not deleted on job cancellation if their shared state is still in use Key: FLINK-28597 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-28596) Support writing arrays to postgres array columns in Flink SQL JDBC connector

2022-07-18 Thread Bobby Richard (Jira)
Bobby Richard created FLINK-28596: - Summary: Support writing arrays to postgres array columns in Flink SQL JDBC connector Key: FLINK-28596 URL: https://issues.apache.org/jira/browse/FLINK-28596 Projec

[jira] [Created] (FLINK-28595) KafkaSource should not read metadata of unmatched regex topics

2022-07-18 Thread Afzal Mazhar (Jira)
Afzal Mazhar created FLINK-28595: Summary: KafkaSource should not read metadata of unmatched regex topics Key: FLINK-28595 URL: https://issues.apache.org/jira/browse/FLINK-28595 Project: Flink

[jira] [Created] (FLINK-28594) Add metrics for FlinkService

2022-07-18 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-28594: - Summary: Add metrics for FlinkService Key: FLINK-28594 URL: https://issues.apache.org/jira/browse/FLINK-28594 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28593) Introduce default ingress templates at operator level

2022-07-18 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-28593: - Summary: Introduce default ingress templates at operator level Key: FLINK-28593 URL: https://issues.apache.org/jira/browse/FLINK-28593 Project: Flink Issue

[jira] [Created] (FLINK-28592) Implement custom resource counters as counters not gauges

2022-07-18 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-28592: - Summary: Implement custom resource counters as counters not gauges Key: FLINK-28592 URL: https://issues.apache.org/jira/browse/FLINK-28592 Project: Flink I

[jira] [Created] (FLINK-28591) Array> is not serialized correctly

2022-07-18 Thread Andrzej Swatowski (Jira)
Andrzej Swatowski created FLINK-28591: - Summary: Array> is not serialized correctly Key: FLINK-28591 URL: https://issues.apache.org/jira/browse/FLINK-28591 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28590) flink on yarn checkpoint exception

2022-07-18 Thread wangMu (Jira)
wangMu created FLINK-28590: -- Summary: flink on yarn checkpoint exception Key: FLINK-28590 URL: https://issues.apache.org/jira/browse/FLINK-28590 Project: Flink Issue Type: Bug Affects Versions:

[jira] [Created] (FLINK-28589) Enhance Web UI for Speculative Execution

2022-07-18 Thread Gen Luo (Jira)
Gen Luo created FLINK-28589: --- Summary: Enhance Web UI for Speculative Execution Key: FLINK-28589 URL: https://issues.apache.org/jira/browse/FLINK-28589 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28588) Enhance REST API for Speculative Execution

2022-07-18 Thread Gen Luo (Jira)
Gen Luo created FLINK-28588: --- Summary: Enhance REST API for Speculative Execution Key: FLINK-28588 URL: https://issues.apache.org/jira/browse/FLINK-28588 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28587) FLIP-249: Flink Web UI Enhancement for Speculative Execution

2022-07-18 Thread Gen Luo (Jira)
Gen Luo created FLINK-28587: --- Summary: FLIP-249: Flink Web UI Enhancement for Speculative Execution Key: FLINK-28587 URL: https://issues.apache.org/jira/browse/FLINK-28587 Project: Flink Issue Typ

[jira] [Created] (FLINK-28586) Speculative execution for new sources

2022-07-18 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-28586: --- Summary: Speculative execution for new sources Key: FLINK-28586 URL: https://issues.apache.org/jira/browse/FLINK-28586 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-28585) Speculative execution for InputFormat sources

2022-07-18 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-28585: --- Summary: Speculative execution for InputFormat sources Key: FLINK-28585 URL: https://issues.apache.org/jira/browse/FLINK-28585 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28584) Add an option to ConfigMap that can be set to immutable

2022-07-18 Thread liuzhuo (Jira)
liuzhuo created FLINK-28584: --- Summary: Add an option to ConfigMap that can be set to immutable Key: FLINK-28584 URL: https://issues.apache.org/jira/browse/FLINK-28584 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-28583) make flink dist log4j dependency simple and clear

2022-07-18 Thread jackylau (Jira)
jackylau created FLINK-28583: Summary: make flink dist log4j dependency simple and clear Key: FLINK-28583 URL: https://issues.apache.org/jira/browse/FLINK-28583 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-28582) LSM tree structure may be incorrect when multiple jobs are committing into the same bucket

2022-07-18 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-28582: --- Summary: LSM tree structure may be incorrect when multiple jobs are committing into the same bucket Key: FLINK-28582 URL: https://issues.apache.org/jira/browse/FLINK-28582