dev  

Messages by Thread

• [jira] [Created] (FLINK-38023) State Restoration fails when using GenericRecord with new Avro schema Keshav Kansal (Jira)
• [jira] [Created] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing Thorne (Jira)
• [jira] [Created] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE Hao Li (Jira)
• [jira] [Created] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38018) Migrate state processor API from sink API v1 to source API v2 Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-38017) [Release-2.1] Add release note for release 2.1 dalongliu (Jira)
• [jira] [Created] (FLINK-38016) [Release-2.1] Verify that no exclusions were erroneously added to the japicmp plugin dalongliu (Jira)
• [jira] [Created] (FLINK-38015) [Release-2.1] Review and update documentation dalongliu (Jira)
• [jira] [Created] (FLINK-38014) [Release-2.1] Triage release-blocking issues in JIRA dalongliu (Jira)
• [jira] [Created] (FLINK-38013) [Release-2.1] Cross team testing dalongliu (Jira)
• [jira] [Created] (FLINK-38012) [Release-2.1] Review Release Notes in JIRA dalongliu (Jira)
• [jira] [Created] (FLINK-38011) [Release-2.1] Prepare RC0 release dalongliu (Jira)
• [ANNOUNCE] release-2.1 branch cut Ron Liu
• [jira] [Created] (FLINK-38010) [Release-2.1] Create a release branch dalongliu (Jira)
• [jira] [Created] (FLINK-38009) [Release-2.1] Select executing Release Manager dalongliu (Jira)
• [jira] [Created] (FLINK-38008) [Release-2.1] Create a new version in JIRA dalongliu (Jira)
• [jira] [Created] (FLINK-38007) Prepare Flink 2.1 Release dalongliu (Jira)
• [ANNOUNCE] Introducing "Debo" – A Unified Management Tool for the Hadoop Ecosystem, Including Flink Support Surafel Temesgen
• [DISCUSS] FLIP-535: Support Storage Partition Join in Flink Lu Niu
• [jira] [Created] (FLINK-37993) Release Testing Instructions: Verify FLIP-486: Introduce a new DeltaJoin dalongliu (Jira)
• [jira] [Created] (FLINK-38006) Support Python for Flink AWS connectors in Flink 2.0 Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-37996) Release Testing Instructions: Verify FLIP-437: Support ML Models in Flink SQL dalongliu (Jira)
• [jira] [Created] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector dalongliu (Jira)
• [jira] [Created] (FLINK-37997) Release Testing Instructions: Verify FLIP-521: Integrating Variant Type into Flink dalongliu (Jira)
• [jira] [Created] (FLINK-38005) Release Testing Instructions: Verify FLIP-509: Custom Batch Handling in AsyncSink dalongliu (Jira)
• [jira] [Created] (FLINK-38004) Release Testing Instructions: Verify FLIP-522: Add generalized type information to SQL state connector dalongliu (Jira)
• [jira] [Created] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data dalongliu (Jira)
• [jira] [Created] (FLINK-38001) Release Testing Instructions: Verify FLIP-508: Add support for Smile format for Compiled plans dalongliu (Jira)
• [jira] [Created] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API dalongliu (Jira)
• [jira] [Created] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Optimization dalongliu (Jira)
• [jira] [Created] (FLINK-37992) Release Testing Instructions: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner dalongliu (Jira)
• [jira] [Created] (FLINK-37998) Release Testing Instructions: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design dalongliu (Jira)
• [jira] [Created] (FLINK-37995) Release Testing Instructions: Verify FLIP-520: Simplify StructuredType handling dalongliu (Jira)
• [jira] [Created] (FLINK-37994) Release Testing Instructions: Verify FLIP-519: Introduce async lookup key ordered mode dalongliu (Jira)
• [jira] [Created] (FLINK-37991) Upgrade pemja to 0.6.x Xingbo Huang (Jira)
• [KINDLY REMINDER] release-2.1 branch cut Ron Liu
• [jira] [Created] (FLINK-37990) [Umbrella] Test Flink Release 2.1 dalongliu (Jira)
• [SUMMARY] Flink 2.1 Release Sync 06/25/2025 Ron Liu
• [jira] [Created] (FLINK-37989) Add condition support Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37988) Add left join support Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37987) Implement JdbcDynamicTableSinkV2 to use new Sink API v2 Poorvank Bhatia (Jira)
• [jira] [Created] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-37985) Refactor public config options from StreamConfig to JobConfiguration Rui Fan (Jira)
• [jira] [Created] (FLINK-37984) Move Cassandra Sink to Sink V2 Poorvank Bhatia (Jira)
• Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Qiang He
  • Re: Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Leonard Xu
  • Re: Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Qiang He
• Help - Question on triaging slowness Siva Ram Gujju
  • Re: Help - Question on triaging slowness Matt Cuento
  • Re:Re: Help - Question on triaging slowness Xuyang
  • Re: Re: Help - Question on triaging slowness Siva Ram Gujju
• [RESULT] [VOTE] FLIP-533: Cassandra Sink V2 Poorvank Bhatia
• [jira] [Created] (FLINK-37983) Upgrade Kafka Client version to 3.9.1 Thomas Cooper (Jira)
• [DISCUSS] FLIP-534 Reduce OLAP Query Latency In Flink Session Cluster. wj wang
• [jira] [Created] (FLINK-37981) TableAsyncExecutionController does not send the watermark Long.MAX downstream Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-37982) When Watermark is updated, the result output in TableAsyncExecutionController cannot be triggered Qilong Wang (Jira)
• [jira] [Created] (FLINK-37980) Adapt Multi-way join to higher Calcite versions (Calcite 1.35+) Sergey Nuyanzin (Jira)
• [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Hao Li
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Sergey Nuyanzin
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Teunissen, F.G.J. (Fred)
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Sergey Nuyanzin
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
• [jira] [Created] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code Sergei Morozov (Jira)
• [jira] [Created] (FLINK-37978) Change max-buffer config to max-concurrent-operations Hao Li (Jira)
• [jira] [Created] (FLINK-37977) Variant implements Serializable Xuannan Su (Jira)
• Slack invitation Jure Prevc
  • Re: Slack invitation Gustavo de Morais
  • Re: Slack invitation Fabrizzio Chavez
• [jira] [Created] (FLINK-37976) DeltaJoinITCase seems to be struck in CI Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-37975) sync a lot sharding table Post Transform failed tongyp (Jira)
• [DISCUSS] FLIP-440: Annotation naming for PTFs Timo Walther
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Gustavo de Morais
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Hao Li
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Arvid Heise
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Martijn Visser
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Timo Walther
• [jira] [Created] (FLINK-37974) Avoid confusion when declaring table arguments Timo Walther (Jira)
• [jira] [Created] (FLINK-37973) Use RightToLeftJoin Rule for MultiJoins Gustavo de Morais (Jira)
• 2025/06/19 CHI Eastern time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-37972) Support jar and UserClassLoader sharing between jobs. Weijun Wang (Jira)
• CLIFrontend exit codes not reflecting application results? Allison
• [jira] [Created] (FLINK-37971) SQL hints are dropped by planner when Maximilian Michels (Jira)
• [jira] [Created] (FLINK-37970) Support PLAN_TEST_FORCE_OVERWRITE for .xml artifacts Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37969) Allow Transformation subgraphs to be merged during translation Arvid Heise (Jira)
• [SUMMARY] Flink 2.1 Release Sync 06/18/2025 Ron Liu
• [jira] [Created] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis Radha Krishna Peteti (Jira)
• [jira] [Created] (FLINK-37967) Add Confluent product and link to vendor solutions documentation Martijn Visser (Jira)
• [jira] [Created] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin Gustavo de Morais (Jira)
• [KINDLY REMINDER] Flink 2.1 Release Sync 06/18/2025 Ron Liu
• [jira] [Created] (FLINK-37964) AsyncSinkWriterStateSerializer should consider the estimated size of request entry Jiaan Geng (Jira)
• [jira] [Created] (FLINK-37963) Unstable MongoDB unit test cases that triggers JM failover yux (Jira)
• [jira] [Created] (FLINK-37962) Implement visitMultiJoin for RelTimeIndicatorConverter Gustavo de Morais (Jira)
• Flink CDC and Debezium Version Mohsen Rezaei
  • Re: Flink CDC and Debezium Version Leonard Xu
• [jira] [Created] (FLINK-37961) Support skip some state operators in TaskManager. Weijun Wang (Jira)
• [jira] [Created] (FLINK-37960) UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint test failed in azure pipeline dalongliu (Jira)
• [jira] [Created] (FLINK-37959) supported All postgres sql 14 field types. ouyangwulin (Jira)
• [jira] [Created] (FLINK-37958) Flink CDC Sink connector support fluss JunboWang (Jira)
• [jira] [Created] (FLINK-37957) Do not write empty lists to compiled plan Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37956) Update SQL gateway for inline structured types Timo Walther (Jira)
• [FLINK-37908] Requesting reviewers on PR Jonathan Du
• Error aware SQL streams David Radley
  • Re: Error aware SQL streams Arvid Heise
  • RE: Error aware SQL streams David Radley
• 2025/06/12 CHI Western time zone workgroup meeting minutes David Radley
• [VOTE] Release 1.20.2, release candidate #2 Ferenc Csaky
  • Re: [VOTE] Release 1.20.2, release candidate #2 Mate Czagany
  • Re: [VOTE] Release 1.20.2, release candidate #2 Márton Balassi
• [jira] [Created] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-37954) Full the exception message when the regular could not be optimized into delta join while delta join strategy is FORCE Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-37953) Add OBF password obfuscation support for SSL configurations Basapuram Kumar (Jira)
• [VOTE] Release 1.19.3, release candidate #2 Ferenc Csaky
  • Re: [VOTE] Release 1.19.3, release candidate #2 Mate Czagany
  • Re: [VOTE] Release 1.19.3, release candidate #2 Márton Balassi
  • Re: [VOTE] Release 1.19.3, release candidate #2 Weiqing Yang
• [jira] [Created] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2 Xuannan Su (Jira)
• [jira] [Created] (FLINK-37950) MongoDB connector should support ordered option Jacob Jona Fahlenkamp (Jira)
• [jira] [Created] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline dalongliu (Jira)
• [jira] [Created] (FLINK-37949) FlinkKinesisConsumer on EFO mode runs into Netty deadlock on client close during stop-with-savepoint Keith Lee (Jira)
• [jira] [Created] (FLINK-37947) Add sql hint to enable this optimization Shuai Xu (Jira)
• [VOTE] FLIP-533: Cassandra Sink V2 Poorvank Bhatia
  • Re: [VOTE] FLIP-533: Cassandra Sink V2 Danny Cranmer
  • Re: [VOTE] FLIP-533: Cassandra Sink V2 Etienne Chauchot
  • Re: [VOTE] FLIP-533: Cassandra Sink V2 Gyula Fóra
  • Re: [VOTE] FLIP-533: Cassandra Sink V2 Ferenc Csaky
  • Re: [VOTE] FLIP-533: Cassandra Sink V2 Sharath
  • Re: [VOTE] FLIP-533: Cassandra Sink V2 Poorvank Bhatia
• [jira] [Created] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN slankka (Jira)
• [jira] [Created] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37944) New test harness for KeyedProcessFunction using State V2 Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37943) mongo cdc bug can not read stream data sunshuxian (Jira)
• [jira] [Created] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:2.0-scala_2.12-java11 guoqinglong (Jira)
• [SUMMARY] Flink 2.1 Release Sync 06/11/2025 Ron Liu
• [jira] [Created] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-37940) Support retry for ML_PREDICT Shengkai Fang (Jira)
• [jira] [Created] (FLINK-37938) ml evaluate implementation for different task types Hao Li (Jira)
• [jira] [Created] (FLINK-37939) Metrics for ml predict function Hao Li (Jira)
• [jira] [Created] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split. Etienne Chauchot (Jira)
• [jira] [Created] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37935) Allow to read WindowingStrategy by downstream projects Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37934) Get the case-sensitive variable names and method names of mysql are not standardized, and need to be adjusted Jira
• [jira] [Created] (FLINK-37933) Move TransformationScan/SinkProvider out of planner Arvid Heise (Jira)
• [jira] [Created] (FLINK-37932) Set a Default User Agent for GCS FileSystem Connector for Better Observability Shruti Singhania (Jira)
• [jira] [Created] (FLINK-37931) LookupJoinUtil failed to compile Zakelly Lan (Jira)
• [KINDLY REMINDER] Flink 2.1 Release Sync 06/11/2025 Ron Liu
• [DISCUSS] FLIP Suggestion: Externalize and Modernize Apache Pinot Connector Poorvank Bhatia
• [jira] [Created] (FLINK-37930) Generalize the AsyncExecutionController Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37929) Support cdc stream for ml_predict Hao Li (Jira)
• [jira] [Created] (FLINK-37928) Support only insert only stream for ml_predict Hao Li (Jira)
• [jira] [Created] (FLINK-37927) Add batch mode support for AsyncTableFunction Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37926) Support type casting between variant and constructed type Xuannan Su (Jira)
• [jira] [Created] (FLINK-37924) Support variant field accessing Xuannan Su (Jira)
• [jira] [Created] (FLINK-37925) Support type casting between variant and primitive type Xuannan Su (Jira)
• [jira] [Created] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL Xuannan Su (Jira)
• [jira] [Created] (FLINK-37922) Integrating Variant Type into Flink Xuannan Su (Jira)
• [jira] [Created] (FLINK-37921) Refactor current implementation with implementation in FLIP-425 Shuai Xu (Jira)
• Invitation to Slack Алексей Поздняков
  • Re: Invitation to Slack Jonathan Du
• [jira] [Created] (FLINK-37920) Reuse same utils for AsyncScalar, AsyncLookupJoin and AsyncMLPredict Shengkai Fang (Jira)
• [jira] [Created] (FLINK-37919) Logback | Not applied Dheeraj Panangat (Jira)
• [jira] [Created] (FLINK-37918) Restore the ability to set an interval for GetRecords calls to Kinesis shards. hajimeni (Jira)
• [jira] [Created] (FLINK-37917) Add support for MultiJoinedRowData Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37916) FLIP-516: Add StreamPhysicalMultiJoin physical node Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37915) Migrate Firehose and Kinesis Stream IT Test to E2E test package Daren Wong (Jira)
• [jira] [Created] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types Ramin Gharib (Jira)
• [jira] [Created] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction Ramin Gharib (Jira)
• [jira] [Created] (FLINK-37912) Typing the DataStream interfaces Joey Pereira (Jira)
• [RESULT][VOTE] FLIP 505: Flink History Server Scalability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
• [jira] [Created] (FLINK-37911) [Helm] Reorganize Helm chart templates Yi Chen (Jira)
• [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink David Radley
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Poorvank Bhatia
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Sharath
  • RE: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Nic Townsend
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Lajith Koova
  • FW: Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink David Radley
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Tom Cooper
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Mark Nuttall
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Ferenc Csaky
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Anu K T
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Sebastien Pereira
  • RE: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Ammu P
  • RE: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Mehdi Deboub
  • RE: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Mehdi Deboub
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Leonard Xu
• [RESULT][VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Xintong Song
• [jira] [Created] (FLINK-37910) FLIP-516: Add StreamExecMultiJoin exec node Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37909) Flink CDC source connector for mongodb repeatedly failing in streaming mode with ChangeStreamHistoryLost error Sachin Mittal (Jira)
• [jira] [Created] (FLINK-37908) KinesisStreamsSource connector de/registration strategy fails on automated restarts Jonathan Du (Jira)
• [jira] [Created] (FLINK-37907) Allow to access memberExecNodes in BatchExecMultipleInput Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc Weijie Guo (Jira)
• [jira] [Created] (FLINK-37905) Transform will throw exceptions when handling chinese characters Ruan Hang (Jira)
• 2025/06/05 CHI Eastern time zone workgroup meeting minutes David Radley

• Earlier messages