dev  

Messages by Date

• 2024/09/11 [jira] [Created] (FLINK-36261) Revisit all breaking changes before Flink 2.0 Preview Xintong Song (Jira)
• 2024/09/11 [jira] [Created] (FLINK-36260) numBytesInLocal and numBuffersInLocal being reported as remote Piotr Nowojski (Jira)
• 2024/09/11 Re: Flink CDC 3.3 Kick Off Proposal Leonard Xu
• 2024/09/11 [jira] [Created] (FLINK-36259) TPC-H E2E test failed due to TM heartbeat timeout Weijie Guo (Jira)
• 2024/09/11 [jira] [Created] (FLINK-36258) testRecursiveUploadForYarnS3n failed due to no AWS Credentials provided Weijie Guo (Jira)
• 2024/09/11 [jira] [Created] (FLINK-36257) Remove simple deprecated APIs Weijie Guo (Jira)
• 2024/09/11 Re: Flink CDC 3.3 Kick Off Proposal Xiqian YU
• 2024/09/11 Flink CDC 3.3 Kick Off Proposal Yanquan Lv
• 2024/09/10 [jira] [Created] (FLINK-36256) flink sql optimization exception wenhao.yu (Jira)
• 2024/09/10 [jira] [Created] (FLINK-36255) Some hive IT case failed with exit code 239 Weijie Guo (Jira)
• 2024/09/10 [jira] [Created] (FLINK-36254) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed on AZP Weijie Guo (Jira)
• 2024/09/10 [jira] [Created] (FLINK-36253) Wordcount on Docker test failed due to mismatch output hash Weijie Guo (Jira)
• 2024/09/10 [jira] [Created] (FLINK-36252) AsyncWaitOperatorTest.testProcessingTimeUnorderedWithRetry failed on AZP Weijie Guo (Jira)
• 2024/09/10 [jira] [Created] (FLINK-36251) Remove StateBackend-related configuration getters/setters that return/set complex Java objects Junrui Li (Jira)
• 2024/09/10 [jira] [Created] (FLINK-36250) Remove CheckpointStorage-related configuration getters/setters that return/set complex Java objects Junrui Li (Jira)
• 2024/09/10 [jira] [Created] (FLINK-36249) Remove RestartStrategy-related configuration getters/setters Junrui Li (Jira)
• 2024/09/10 [jira] [Created] (FLINK-36248) Introduce new Join Operator with Async State API xuyang (Jira)
• 2024/09/10 [jira] [Created] (FLINK-36247) Potential transaction leak during MySQL snapshot phase Xin Gong (Jira)
• 2024/09/10 Re: [ANNOUNCE] Apache Flink CDC 3.2.0 released Ahmed Hamdy
• 2024/09/10 [jira] [Created] (FLINK-36246) Move async state related operators flink-runtime Zakelly Lan (Jira)
• 2024/09/09 [jira] [Created] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API in 2.0 Qingsheng Ren (Jira)
• 2024/09/09 [jira] [Created] (FLINK-36244) Remove Queryable State Zakelly Lan (Jira)
• 2024/09/09 [jira] [Created] (FLINK-36243) Store namespace in ContextKey Yanfei Lei (Jira)
• 2024/09/09 [jira] [Created] (FLINK-36242) Fix unstable test in MaterializedTableITCase Feng Jin (Jira)
• 2024/09/09 [jira] [Created] (FLINK-36239) DDB Streams Connector reprocessing due to DescribeStream inconsistencies for trimmed shards Abhi Gupta (Jira)
• 2024/09/09 [jira] [Created] (FLINK-36236) JdbcSourceBuilder overrides set connection provider Jira
• 2024/09/09 Re: Flink Releases Aleksandr Pilipenko
• 2024/09/08 Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization. Lei Yang
• 2024/09/06 Re: .ClassNotFoundException: org.apache.flink.table.data.util.DataFormatConverters$RowConverter Feng Jin
• 2024/09/05 [DISCUSS] (FLINK-23598) DataOutputSerializer.writeBytes updates position twice shalini manohar
• 2024/09/05 Re: .ClassNotFoundException: org.apache.flink.table.data.util.DataFormatConverters$RowConverter Taher Koitawala
• 2024/09/05 [jira] [Created] (FLINK-36233) Reuseable view in Flink SQL Yi Cai (Jira)
• 2024/09/05 [jira] [Created] (FLINK-36232) Incorrect vararg handling in Python Table API Dylan He (Jira)
• 2024/09/05 [jira] [Created] (FLINK-36231) Optimize built-in function REGEXP_EXTRACT and REGEXP_REPLACE with regex cache Dylan He (Jira)
• 2024/09/05 Flink Releases David Radley
• 2024/09/05 [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format #2 David Mariassy
• 2024/09/05 [jira] [Created] (FLINK-36228) MongoDB sink should be asynchronous Jacob Jona Fahlenkamp (Jira)
• 2024/09/04 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #1 Qingsheng Ren
• 2024/09/04 [jira] [Created] (FLINK-36224) Add the version mapping between pipeline connectors and flink Thorne (Jira)
• 2024/09/04 [jira] [Created] (FLINK-36223) SplitFetcher thread 0 received unexpected exception while polling the records zjf (Jira)
• 2024/09/04 [jira] [Created] (FLINK-36221) Add specification about CAST ... AS ... built-in functions yux (Jira)
• 2024/09/04 [jira] [Created] (FLINK-36218) Documentations clean up before CDC 3.2.0 release yux (Jira)
• 2024/09/04 [jira] [Created] (FLINK-36217) Remove powermock usage Sergey Nuyanzin (Jira)
• 2024/09/04 [jira] [Created] (FLINK-36214) Error log when building flink-cdc-pipeline-udf-examples from source code lincoln lee (Jira)
• 2024/09/04 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #1 Lincoln Lee
• 2024/09/04 [jira] [Created] (FLINK-36213) CDC Datastream API sync error zigaai (Jira)
• 2024/09/03 Re: [DISCUSSION] Disabling japicmp plugin in master for 2.0 Matthias Pohl
• 2024/09/03 [jira] [Created] (FLINK-36211) Shade kafka related package in Kafka Pipeline connector. LvYanquan (Jira)
• 2024/09/03 [jira] [Created] (FLINK-36210) Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode xiaochen.zhou (Jira)
• 2024/09/03 [jira] [Created] (FLINK-36209) Reduce some redundant operations in the initialization of KafkaSourceEnumState xiaochen.zhou (Jira)
• 2024/09/03 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #1 Xiqian YU
• 2024/09/03 [jira] [Created] (FLINK-36208) use ThreadLocalRandom in Flink AbstractID Sean Sullivan (Jira)
• 2024/09/03 [jira] [Created] (FLINK-36207) Disabling japicmp plugin for deprecated APIs Matthias Pohl (Jira)
• 2024/09/03 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #1 Leonard Xu
• 2024/09/03 [jira] [Created] (FLINK-36206) Support flink-connector-aws-base to allow custom override configuration Abhi Gupta (Jira)
• 2024/09/03 [jira] [Created] (FLINK-36205) DDB Streams connector should be able to resolve the stream ARN from given Table name Hong Liang Teoh (Jira)
• 2024/09/03 [jira] [Created] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot Abhi Gupta (Jira)
• 2024/09/03 Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Arvid Heise
• 2024/09/03 [jira] [Created] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher Abhi Gupta (Jira)
• 2024/09/03 Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Danny Cranmer
• 2024/09/03 Re: [VOTE] FLIP-477: Amazon SQS Source Connector Saurabh Singh
• 2024/09/03 [jira] [Created] (FLINK-36202) Remove all deprecated datastream api Weijie Guo (Jira)
• 2024/09/02 [jira] [Created] (FLINK-36201) StateLocalitySlotAssigner will be used even if local recovery is disable for Adaptive Scheduler Rui Fan (Jira)
• 2024/09/02 [jira] [Created] (FLINK-36200) Breaking changes for Flink 3.0 Xintong Song (Jira)
• 2024/09/02 [jira] [Created] (FLINK-36199) Remove RuntimeContext#getExecutionConfig Weijie Guo (Jira)
• 2024/09/02 [jira] [Created] (FLINK-36198) Remove legacy hybrid shuffle mode Weijie Guo (Jira)
• 2024/09/02 [jira] [Created] (FLINK-36197) Bump curator-test version Siddharth R (Jira)
• 2024/09/02 [jira] [Created] (FLINK-36196) Have a UX for customer where customer just gives table name and gets the stream arn which is enabled Abhi Gupta (Jira)
• 2024/09/02 [jira] [Created] (FLINK-36195) Migrate DDB Streams specific retry configuration to flink-connector-base Abhi Gupta (Jira)
• 2024/09/02 [jira] [Created] (FLINK-36194) Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions Matthias Pohl (Jira)
• 2024/09/01 Re: [DISCUSSION] Disabling japicmp plugin in master for 2.0 Xintong Song
• 2024/09/01 [jira] [Created] (FLINK-36193) Allow applying new SchemaChangeEvents to sink connectors yux (Jira)
• 2024/09/01 [jira] [Created] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task. yuanfenghu (Jira)
• 2024/09/01 Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization. Lincoln Lee
• 2024/08/31 [jira] [Created] (FLINK-36191) FsMergingCheckpointStorageLocationTest generates test data not in tmp folder Sergey Nuyanzin (Jira)
• 2024/08/31 [jira] [Created] (FLINK-36190) Completed checkpoint's file cannot be discarded due to network issues Alexis Sarda-Espinosa (Jira)
• 2024/08/30 Match recognize references old type system in docs. David Radley
• 2024/08/30 [jira] [Created] (FLINK-36189) Documentation build is failing with NPM installation problem Martijn Visser (Jira)
• 2024/08/30 RE: Flink aggregation docs David Radley
• 2024/08/30 Re: Flink aggregation docs Martijn Visser
• 2024/08/30 Flink aggregation docs David Radley
• 2024/08/30 [jira] [Created] (FLINK-36188) HBase disable buffer flush lose efficacy MOBIN (Jira)
• 2024/08/30 [VOTE] Apache Flink CDC Release 3.2.0, release candidate #1 Qingsheng Ren
• 2024/08/30 [jira] [Created] (FLINK-36187) Reimplement UniformShardAssigner using Kinesis shard hashes Hong Liang Teoh (Jira)
• 2024/08/29 Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization. Lei Yang
• 2024/08/29 [jira] [Created] (FLINK-36186) Speed up RocksDB close during manual compaction Yue Ma (Jira)
• 2024/08/29 [jira] [Created] (FLINK-36185) Remove RuntimeContext#getExecutionConfig Junrui Li (Jira)
• 2024/08/29 [jira] [Created] (FLINK-36184) Transform Operator swallows schema changes from tables not present in transform rules yux (Jira)
• 2024/08/29 [jira] [Created] (FLINK-36183) Lenient mode doesn't work with route blocks yux (Jira)
• 2024/08/29 [jira] [Created] (FLINK-36182) PyFlink SQL Job Got IllegalStateException During Task Manager Shutdown EMERSON WANG (Jira)
• 2024/08/29 [jira] [Created] (FLINK-36181) Drop support for Java 8 and use Java 17 by default Martijn Visser (Jira)
• 2024/08/29 Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization. Lincoln Lee
• 2024/08/29 [jira] [Created] (FLINK-36180) Flink pulsar connector when restoring from the state, the unconsumed messages of the first batch will be lost Wenbing Shen (Jira)
• 2024/08/29 [jira] [Created] (FLINK-36179) Bump log4j version Siddharth R (Jira)
• 2024/08/29 [jira] [Created] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent LvYanquan (Jira)
• 2024/08/29 Re: [DISCUSSION] Disabling japicmp plugin in master for 2.0 Gabor Somogyi
• 2024/08/29 [jira] [Created] (FLINK-36177) Deprecating KafkaShuffle Arvid Heise (Jira)
• 2024/08/29 [DISCUSSION] Disabling japicmp plugin in master for 2.0 Matthias Pohl
• 2024/08/29 [jira] [Created] (FLINK-36176) Remove support for ancient Kafka versions Arvid Heise (Jira)
• 2024/08/29 [jira] [Created] (FLINK-36175) Remove `register_table_source` and `register_table_sink` in python module xuyang (Jira)
• 2024/08/29 [jira] [Created] (FLINK-36174) CDC yaml without pipeline will throw NullPointException Hongshun Wang (Jira)
• 2024/08/29 [RESULT][VOTE] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
• 2024/08/29 [jira] [Created] (FLINK-36173) Invalid link in checkpoint documentation Gabor Somogyi (Jira)
• 2024/08/28 [jira] [Created] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs Junrui Li (Jira)
• 2024/08/28 [jira] [Created] (FLINK-36171) Remove APIs about ManagedTable xuyang (Jira)
• 2024/08/28 [jira] [Created] (FLINK-36170) Bump assertj-core version Siddharth R (Jira)
• 2024/08/28 [jira] [Created] (FLINK-36169) Support namespace level resource check before scaling up Zhenqiu Huang (Jira)
• 2024/08/28 [jira] [Created] (FLINK-36168) AdaptiveSchedulerTest doesn't follow the production lifecycle Matthias Pohl (Jira)
• 2024/08/28 [SUMMARY] Flink 2.0 Release Sync 08/28/2024 Xintong Song
• 2024/08/28 [jira] [Created] (FLINK-36167) testSinkDisorderChangeLog failed on AZP Weijie Guo (Jira)
• 2024/08/28 [jira] [Created] (FLINK-36166) testJoinDisorderChangeLog failed on AZP Weijie Guo (Jira)
• 2024/08/27 [jira] [Created] (FLINK-36165) Support obtaining snapshot data of the scope Thorne (Jira)
• 2024/08/27 [jira] [Created] (FLINK-36164) JdbcIncrementalSource CheckPoint Timeout Due to Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned PostgreSQL Table tchivs (Jira)
• 2024/08/27 [jira] [Created] (FLINK-36163) Kafka cdc pipeline source supports protobuf format. Hongshun Wang (Jira)
• 2024/08/27 PostCommitTopology question Péter Váry
• 2024/08/27 [jira] [Created] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference Gyula Fora (Jira)
• 2024/08/27 [jira] [Created] (FLINK-36161) Integration Test Example uses deprecated SinkFunction Wolff Bock von Wuelfingen (Jira)
• 2024/08/27 [jira] [Created] (FLINK-36160) Support hive advanced configuration zhuanshenbsj1 (Jira)
• 2024/08/27 [jira] [Created] (FLINK-36159) FLIP-470: Support Adaptive Broadcast Join xingbe (Jira)
• 2024/08/26 Re: [VOTE] FLIP-474: Store operator name and UID in state metadata Yun Tang
• 2024/08/26 [KINDLY REMINDER] Flink 2.0 Release Sync 08/28/2024 Xintong Song
• 2024/08/26 Re: [VOTE] FLIP-474: Store operator name and UID in state metadata Rui Fan
• 2024/08/26 [jira] [Created] (FLINK-36158) Support for StreamGraph store Junrui Li (Jira)
• 2024/08/26 [jira] [Created] (FLINK-36157) FLIP-473 Introduce New SQL Operators Based on Asynchronous State APIs xuyang (Jira)
• 2024/08/26 Re: [VOTE] FLIP-474: Store operator name and UID in state metadata Zakelly Lan
• 2024/08/26 Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Zakelly Lan
• 2024/08/26 Re:RE: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
• 2024/08/26 [RESULT][VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
• 2024/08/26 [jira] [Created] (FLINK-36156) SinkV2: Provide the ability to set Committer Operator parallelism Rodrigo Meneses (Jira)
• 2024/08/26 Re: [VOTE] FLIP-474: Store operator name and UID in state metadata clara xiong
• 2024/08/26 Re: [VOTE] FLIP-474: Store operator name and UID in state metadata Peter Huang
• 2024/08/26 Re: [VOTE] FLIP-474: Store operator name and UID in state metadata Őrhidi Mátyás
• 2024/08/26 Re: [VOTE] FLIP-474: Store operator name and UID in state metadata Gyula Fóra
• 2024/08/26 Re: [VOTE] FLIP-474: Store operator name and UID in state metadata Ferenc Csaky
• 2024/08/26 [jira] [Created] (FLINK-36155) ByteBuf.release() was not called before it's garbage-collected Keith Lee (Jira)
• 2024/08/26 Re: [VOTE] FLIP-474: Store operator name and UID in state metadata Márton Balassi
• 2024/08/26 [jira] [Created] (FLINK-36154) Support parse json ignore field key case KevinyhZou (Jira)
• 2024/08/26 [VOTE] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
• 2024/08/26 Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
• 2024/08/25 [jira] [Created] (FLINK-36153) MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode yux (Jira)
• 2024/08/25 [jira] [Created] (FLINK-36152) Traverse through the superclass hierarchy to extract generic type. Xinglong Wang (Jira)
• 2024/08/25 [jira] [Created] (FLINK-36151) Add documentations for Schema Evolution related options yux (Jira)
• 2024/08/25 Re: Flink CDC insert-only changelog mode Hongshun Wang
• 2024/08/25 [jira] [Created] (FLINK-36150) tables.exclude is not valid if scan.binlog.newly-added-table.enabled is true. Hongshun Wang (Jira)
• 2024/08/24 [jira] [Created] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states. luolei (Jira)
• 2024/08/23 [jira] [Created] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase. LvYanquan (Jira)
• 2024/08/23 [jira] [Created] (FLINK-36147) Removes deprecated location field Matthias Pohl (Jira)
• 2024/08/23 [jira] [Created] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager Jira
• 2024/08/23 [jira] [Created] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference Gyula Fora (Jira)
• 2024/08/23 [DISCUSS] FLIP-319: Integrating with Kafka’s proper support for 2PC participation (KIP-939). David Radley
• 2024/08/23 RE: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs David Radley
• 2024/08/23 [jira] [Created] (FLINK-36144) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data mumu (Jira)
• 2024/08/23 [jira] [Created] (FLINK-36143) Sink ES occurred "version conflict" sanqingleo (Jira)
• 2024/08/22 Re: [EXTERNAL] - Re: Discussion on Vertica-Flink Connector Vikas Garg
• 2024/08/22 [jira] [Created] (FLINK-36142) Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36141) Set the scanNewlyAddedTableEnabled is true, but does not support automatic identification new table zhongyuandong (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36140) Log a warning when pods are terminated by kubernetes Clara Xiong (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36139) ClassCastException when checkpointing AggregateFunction Vladislav Keda (Jira)
• 2024/08/22 Re: Flink CDC insert-only changelog mode Daniel Henneberger
• 2024/08/22 [jira] [Created] (FLINK-36138) KinesisStreamsSource.buil() should have helpful null errors Jira
• 2024/08/22 [jira] [Created] (FLINK-36137) Missing JarURI leads to null pointer in reconciler Gyula Fora (Jira)
• 2024/08/22 Re: [jira](FLINK-36127) Apply for a jira account and repair bug Leonard Xu
• 2024/08/22 Re: [jira](FLINK-36127) Apply for a jira account and repair bug Yu Chen
• 2024/08/22 [jira](FLINK-36127) Apply for a jira account and repair bug Yunming Tang
• 2024/08/22 Re: [jira](FLINK-35444) Apply for a jira account and repair bug Kaiyuan Zheng
• 2024/08/22 [jira] [Created] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc. xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc. xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes. xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process. xuyang (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level. xuyang (Jira)
• 2024/08/22 Re: [jira](FLINK-35444) Apply for a jira account and repair bug Leonard Xu
• 2024/08/22 [jira] [Created] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data mumu (Jira)
• 2024/08/22 [jira] [Created] (FLINK-36130) flink cdc submit yaml task zzm (Jira)
• 2024/08/22 Re: [jira](FLINK-35444) Apply for a jira account and repair bug Gabor Somogyi
• 2024/08/22 [jira](FLINK-35444) Apply for a jira account and repair bug 郑恺原
• 2024/08/22 Issue with table.optimizer.join-reorder-enabled and lookup join Tamas Sule
• 2024/08/21 [jira] [Created] (FLINK-36129) Autoscaler is compatible with Flink 1.20 Rui Fan (Jira)
• 2024/08/21 Re: Flink CDC insert-only changelog mode Hongshun Wang
• 2024/08/21 Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0 Xiqian YU
• 2024/08/21 Re: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Lincoln Lee
• 2024/08/21 Re: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Feng Jin
• 2024/08/21 Re: [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Ron Liu
• 2024/08/21 [jira] [Created] (FLINK-36128) Promote LENIENT mode as the default schema evolution behavior yux (Jira)
• 2024/08/21 Flink CDC insert-only changelog mode Daniel Henneberger
• 2024/08/21 Re: [VOTE] FLIP-477: Amazon SQS Source Connector Aleksandr Pilipenko
• 2024/08/21 [jira] [Created] (FLINK-36127) Support sorting watermark on flink web Yu Chen (Jira)
• 2024/08/21 Re: [VOTE] FLIP-477: Amazon SQS Source Connector Ahmed Hamdy
• 2024/08/21 [jira] [Created] (FLINK-36126) Qualification of current catalog and current database should happen during execution, not parsing Sergey Nuyanzin (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36125) File not found exception on restoring state handles with file merging Burak Ozakinci (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36124) S3RecoverableFsDataOutputStream.sync closes the stream and further write operation throw exception Gabor Somogyi (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36123) Add PERCENTILE function Dylan He (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36122) Redundant cast in outer layer when comparing Row Types for equality xuyang (Jira)
• 2024/08/21 [RESULT][VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan
• 2024/08/21 Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan
• 2024/08/21 [jira] [Created] (FLINK-36120) Internal APIs for declaring and defining the record processing Zakelly Lan (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36121) Snapshot the in-flight async state requests Zakelly Lan (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36119) Conditional branchings APIs under `StateFuture` Zakelly Lan (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36118) FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan (Jira)
• 2024/08/21 [jira] [Created] (FLINK-36117) Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend. wang qian (Jira)
• 2024/08/21 Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Yuan Mei

• Earlier messages
• Later messages