[jira] [Created] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data

2024-09-26 Thread Yang Li (Jira)
Yang Li created FLINK-36377: --- Summary: Support the use of the LAST_VALUE aggregate function on ROW type data Key: FLINK-36377 URL: https://issues.apache.org/jira/browse/FLINK-36377 Project: Flink

[jira] [Created] (FLINK-34563) Autoscaling decision improvement

2024-03-01 Thread Yang LI (Jira)
Yang LI created FLINK-34563: --- Summary: Autoscaling decision improvement Key: FLINK-34563 URL: https://issues.apache.org/jira/browse/FLINK-34563 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-34096) Upscale of kafka source operator leads to some splits getting lost

2024-01-15 Thread Yang LI (Jira)
Yang LI created FLINK-34096: --- Summary: Upscale of kafka source operator leads to some splits getting lost Key: FLINK-34096 URL: https://issues.apache.org/jira/browse/FLINK-34096 Project: Flink Iss

[jira] [Created] (FLINK-33966) Fix the getNumRecordsInPerSecond Utility Function

2024-01-02 Thread Yang LI (Jira)
Yang LI created FLINK-33966: --- Summary: Fix the getNumRecordsInPerSecond Utility Function Key: FLINK-33966 URL: https://issues.apache.org/jira/browse/FLINK-33966 Project: Flink Issue Type: Bug