dev  

Messages by Date

• 2024/09/17 [jira] [Created] (FLINK-36306) Remove deprecated API for 2.0-preview Weijie Guo (Jira)
• 2024/09/17 [NOTICE] Flink 2.0 Release Sync Canceled for 09/18/2024 Xintong Song
• 2024/09/17 [jira] [Created] (FLINK-36305) Remove deprecated Table/SQL config options Xuannan Su (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36304) Remove deprecated Statebackend config options Xuannan Su (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36303) PostgreSQL timestamp precision 0 not supported Ken Geis (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36302) FileSourceTextLinesITCase timed out Matthias Pohl (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36301) TPC-H end-to-end test fails due to TimeoutException Matthias Pohl (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36300) TableEnvHiveConnectorITCase.testDateTimestampPartitionColumns times out Matthias Pohl (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36299) AdaptiveSchedulerTest.testStatusMetrics times out Matthias Pohl (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Matthias Pohl (Jira)
• 2024/09/17 Non-nullable children of nullable arrays and objects in SQL not working with Avro format David Radley
• 2024/09/17 [jira] [Created] (FLINK-36297) SIGSEGV caused CI failure Matthias Pohl (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36296) Add incremental shard discovery for DDB Streams source Abhi Gupta (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36295) AdaptiveSchedulerClusterITCase. testCheckpointStatsPersistedAcrossRescale failed with Matthias Pohl (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36294) table stage failed with general junit5 TestEngine failure Matthias Pohl (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36293) RocksDBWriteBatchWrapperTest.testAsyncCancellation Matthias Pohl (Jira)
• 2024/09/17 [jira] [Created] (FLINK-36292) SplitFetcherManagerTest.testCloseCleansUpPreviouslyClosedFetcher times out Matthias Pohl (Jira)
• 2024/09/16 [jira] [Created] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side Matthias Pohl (Jira)
• 2024/09/16 Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Arvid Heise
• 2024/09/16 [jira] [Created] (FLINK-36290) OutOfMemoryError in connect test run Matthias Pohl (Jira)
• 2024/09/16 [jira] [Created] (FLINK-36289) Create Prometheus Flink connector release Hong Liang Teoh (Jira)
• 2024/09/16 [jira] [Created] (FLINK-36288) Set up architectural test Hong Liang Teoh (Jira)
• 2024/09/16 [jira] [Created] (FLINK-36287) Sink with topologies should not participate in UC Arvid Heise (Jira)
• 2024/09/16 [jira] [Created] (FLINK-36286) Set up pull request template Hong Liang Teoh (Jira)
• 2024/09/15 [jira] [Created] (FLINK-36285) Modify column type failed when downstream's column with defalut value linqigeng (Jira)
• 2024/09/14 Re: FLINK-36240 assignment request Ferenc Csaky
• 2024/09/14 [jira] [Created] (FLINK-36284) StreamTableEnvironment#toDataStream(Table table, Class<T> targetClass) is not suitable for setting targetClass as a class generated by Avro. xuyang (Jira)
• 2024/09/13 [jira] [Created] (FLINK-36283) The new PERCENTILE function doesn't follow user function first behavior when it encounters a user function with same name lincoln lee (Jira)
• 2024/09/13 [jira] [Created] (FLINK-36282) Incorrect data type mysql pipeline connector linqigeng (Jira)
• 2024/09/13 [jira] [Created] (FLINK-36281) resourceSpec replace SlotSharingGroupUtils.extractResourceSpec(slotSharingGroup) Caican Cai (Jira)
• 2024/09/13 [jira] [Created] (FLINK-36280) Snapshot scan mode do not support batch execution mode, and not as expected in mode streaming HunterXHunter (Jira)
• 2024/09/13 FLINK-36240 assignment request Arek Dankiewicz
• 2024/09/13 [jira] [Created] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails Matthias Pohl (Jira)
• 2024/09/13 Re: [VOTE] FLIP-475: Support Adaptive Skewed Join Optimization Lincoln Lee
• 2024/09/13 PR 25290 Robin Moffatt
• 2024/09/13 [jira] [Created] (FLINK-36278) Fix Kafka connector logs getting too big Arvid Heise (Jira)
• 2024/09/13 [jira] [Created] (FLINK-36277) Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal` xuyang (Jira)
• 2024/09/13 [jira] [Created] (FLINK-36276) Fix the description of MySqlDataSourceOptions.`scan.startup.mode`. HunterXHunter (Jira)
• 2024/09/13 Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Saurabh Singh
• 2024/09/13 Re: [VOTE] FLIP-475: Support Adaptive Skewed Join Optimization Rui Fan
• 2024/09/12 Re: [VOTE] FLIP-475: Support Adaptive Skewed Join Optimization Zhu Zhu
• 2024/09/12 [jira] [Created] (FLINK-36275) Remove deprecated ProgramArgsQueryParameter Weijie Guo (Jira)
• 2024/09/12 [jira] [Created] (FLINK-36274) Remove legacy ExternalizedCheckpointCleanup Zakelly Lan (Jira)
• 2024/09/12 [jira] [Created] (FLINK-36273) Remove deprecated Table/SQL configuration in 2.0 xuyang (Jira)
• 2024/09/12 [jira] [Created] (FLINK-36272) YarnFileStageTestS3ITCase fails on master Matthias Pohl (Jira)
• 2024/09/12 [jira] [Created] (FLINK-36271) Support json and jsonb type in PostgreSQL JDBC Dialect Jira
• 2024/09/12 [jira] [Created] (FLINK-36270) DDB Streams Connector performance issue due to splitsAvailableForAssignment function Abhi Gupta (Jira)
• 2024/09/12 [jira] [Created] (FLINK-36269) Remove `fromTableSource` in python module xuyang (Jira)
• 2024/09/12 [jira] [Created] (FLINK-36268) Disable Avro Confluent Schema Registry nightly end-to-end test for 2.0 breaking change Weijie Guo (Jira)
• 2024/09/12 Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Arvid Heise
• 2024/09/12 [VOTE] FLIP-475: Support Adaptive Skewed Join Optimization Lei Yang
• 2024/09/11 [jira] [Created] (FLINK-36267) SPLIT doesn't support SMP characters if delimiter is empty Dylan He (Jira)
• 2024/09/11 [jira] [Created] (FLINK-36266) Insert into as select * behaves incorrect Sergey Nuyanzin (Jira)
• 2024/09/11 [jira] [Created] (FLINK-36265) List and track the deprecated APIs for the 2.0-preview release. Jiangjie Qin (Jira)
• 2024/09/11 [jira] [Created] (FLINK-36264) Unable to customize rest-service.exposed.type parameter chenyuzhi (Jira)
• 2024/09/11 [jira] [Created] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink LvYanquan (Jira)
• 2024/09/11 [SUMMARY] Flink 2.0 Release Sync 09/11/2024 Xintong Song
• 2024/09/11 [jira] [Created] (FLINK-36262) Port fix for CALCITE-5965 Sergey Nuyanzin (Jira)
• 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)

• Earlier messages
• Later messages