[jira] [Created] (FLINK-37274) Add examples for datastream api v2

xuhuang created FLINK-37274: --- Summary: Add examples for datastream api v2 Key: FLINK-37274 URL: https://issues.apache.org/jira/browse/FLINK-37274 Project: Flink Issue Type: New Feature Co

[jira] [Created] (FLINK-37264) two bugs of DSv2

xuhuang created FLINK-37264: --- Summary: two bugs of DSv2 Key: FLINK-37264 URL: https://issues.apache.org/jira/browse/FLINK-37264 Project: Flink Issue Type: New Feature Components: API / Da

[jira] [Created] (FLINK-37189) Incorrect version string of maven-enforcer-plugin requireJavaVersion

xuhuang created FLINK-37189: --- Summary: Incorrect version string of maven-enforcer-plugin requireJavaVersion Key: FLINK-37189 URL: https://issues.apache.org/jira/browse/FLINK-37189 Project: Flink I

[jira] [Created] (FLINK-37136) FLIP-501: Support Window Extension in DataStream V2 API

xuhuang created FLINK-37136: --- Summary: FLIP-501: Support Window Extension in DataStream V2 API Key: FLINK-37136 URL: https://issues.apache.org/jira/browse/FLINK-37136 Project: Flink Issue Type: New

[jira] [Created] (FLINK-37135) FLIP-500: Support Join Extension in DataStream V2 API

xuhuang created FLINK-37135: --- Summary: FLIP-500: Support Join Extension in DataStream V2 API Key: FLINK-37135 URL: https://issues.apache.org/jira/browse/FLINK-37135 Project: Flink Issue Type: New F

[jira] [Created] (FLINK-37112) FLIP-499: Support Event Time by Generalized Watermark in DataStream V2

xuhuang created FLINK-37112: --- Summary: FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Key: FLINK-37112 URL: https://issues.apache.org/jira/browse/FLINK-37112 Project: Flink

[jira] [Created] (FLINK-36960) FLIP-467 Introduce Generalized Watermarks for DataStream V2

xuhuang created FLINK-36960: --- Summary: FLIP-467 Introduce Generalized Watermarks for DataStream V2 Key: FLINK-36960 URL: https://issues.apache.org/jira/browse/FLINK-36960 Project: Flink Issue Type

[jira] [Created] (FLINK-36880) Hybrid Shuffle support batch job recovery

xuhuang created FLINK-36880: --- Summary: Hybrid Shuffle support batch job recovery Key: FLINK-36880 URL: https://issues.apache.org/jira/browse/FLINK-36880 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36873) Adapting batch job progress recovery to Apache Celeborn

xuhuang created FLINK-36873: --- Summary: Adapting batch job progress recovery to Apache Celeborn Key: FLINK-36873 URL: https://issues.apache.org/jira/browse/FLINK-36873 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-36815) series bugs of DSv2

xuhuang created FLINK-36815: --- Summary: series bugs of DSv2 Key: FLINK-36815 URL: https://issues.apache.org/jira/browse/FLINK-36815 Project: Flink Issue Type: Bug Components: API / DataStr

[jira] [Created] (FLINK-36462) Revert "remove per-job"

xuhuang created FLINK-36462: --- Summary: Revert "remove per-job" Key: FLINK-36462 URL: https://issues.apache.org/jira/browse/FLINK-36462 Project: Flink Issue Type: Bug Reporter: xuhuang

[jira] [Created] (FLINK-36444) unstable test case SimpleRecoveryITCaseBase#testFailedRunThenSuccessfulRun

xuhuang created FLINK-36444: --- Summary: unstable test case SimpleRecoveryITCaseBase#testFailedRunThenSuccessfulRun Key: FLINK-36444 URL: https://issues.apache.org/jira/browse/FLINK-36444 Project: Flink

[jira] [Created] (FLINK-36433) non-keyed fullWindowPartition#reduce may throw NPE

xuhuang created FLINK-36433: --- Summary: non-keyed fullWindowPartition#reduce may throw NPE Key: FLINK-36433 URL: https://issues.apache.org/jira/browse/FLINK-36433 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36423) Support RichMapPartitionFunction on KyedPartitionWindowedStream

xuhuang created FLINK-36423: --- Summary: Support RichMapPartitionFunction on KyedPartitionWindowedStream Key: FLINK-36423 URL: https://issues.apache.org/jira/browse/FLINK-36423 Project: Flink Issue

[jira] [Created] (FLINK-36401) PR ci failed

xuhuang created FLINK-36401: --- Summary: PR ci failed Key: FLINK-36401 URL: https://issues.apache.org/jira/browse/FLINK-36401 Project: Flink Issue Type: Bug Reporter: xuhuang The PR CI

[jira] [Created] (FLINK-36336) Remove deprecated dataset API

xuhuang created FLINK-36336: --- Summary: Remove deprecated dataset API Key: FLINK-36336 URL: https://issues.apache.org/jira/browse/FLINK-36336 Project: Flink Issue Type: New Feature Repor

[jira] [Created] (FLINK-36310) Remove per-job and run-application deprecated APIs

xuhuang created FLINK-36310: --- Summary: Remove per-job and run-application deprecated APIs Key: FLINK-36310 URL: https://issues.apache.org/jira/browse/FLINK-36310 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-35992) NettyShuffleMaster not close tiered-storage resources

xuhuang created FLINK-35992: --- Summary: NettyShuffleMaster not close tiered-storage resources Key: FLINK-35992 URL: https://issues.apache.org/jira/browse/FLINK-35992 Project: Flink Issue Type: Bug