[jira] [Created] (FLINK-27162) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure

Yun Gao created FLINK-27162: --- Summary: RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure Key: FLINK-27162 URL: https://issues.apache.org/jira/browse/FLINK-27162 Project: F

Re: [DISCUSS] Flink SQL Syntax for Query/Savepoint Management

Hi Paul, I grant the permission to you. Regarding the "SHOW QUERIES", how will you bookkeep and persist the running and complete queries? Or will you retrieve the queries information from the cluster every time when you receive the command? Best, Jark On Wed, 6 Apr 2022 at 11:23, Paul Lam wro

[jira] [Created] (FLINK-27161) Support user jar from different type of filesystems

Aitozi created FLINK-27161: -- Summary: Support user jar from different type of filesystems Key: FLINK-27161 URL: https://issues.apache.org/jira/browse/FLINK-27161 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27160) Add e2e tests for FlinkSessionJob type

Aitozi created FLINK-27160: -- Summary: Add e2e tests for FlinkSessionJob type Key: FLINK-27160 URL: https://issues.apache.org/jira/browse/FLINK-27160 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-27159) Support first_value/last_value in the Table API

Huang Xingbo created FLINK-27159: Summary: Support first_value/last_value in the Table API Key: FLINK-27159 URL: https://issues.apache.org/jira/browse/FLINK-27159 Project: Flink Issue Type: S

[jira] [Created] (FLINK-27158) Adjust default value of compaction and compress

Jingsong Lee created FLINK-27158: Summary: Adjust default value of compaction and compress Key: FLINK-27158 URL: https://issues.apache.org/jira/browse/FLINK-27158 Project: Flink Issue Type: S

[jira] [Created] (FLINK-27157) Add version field to manifest entries

Jingsong Lee created FLINK-27157: Summary: Add version field to manifest entries Key: FLINK-27157 URL: https://issues.apache.org/jira/browse/FLINK-27157 Project: Flink Issue Type: Sub-task