dev  

Messages by Thread

• [VOTE] FLIP-580: AsyncTableFunction supports user-defined timeout handling logic Kui Yuan
• [jira] [Created] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Xin Gao (Jira)
• [jira] [Created] (FLINK-39836) Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard Yuepeng Pan (Jira)
• [RESULT][VOTE] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
• [SUMMARY] Release 2.3 SYNC - Pending on rc2 voting Yuepeng Pan
• [jira] [Created] (FLINK-39835) AsyncWaitOperator supports soft backpressure to avoid blocking unaligned checkpoint Gen Luo (Jira)
• [VOTE] FLIP-587: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu
  • Re: [VOTE] FLIP-587: Expose per downstream target numRecordsOut metric Gyula Fóra
• [jira] [Created] (FLINK-39834) Oracle CDC may duplicate UNISTR expressions when UNISTR value contains || tianfy (Jira)
• [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
  • Re: [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Gyula Fóra
  • Re: [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Ryan van Huuksloot via dev
• [DISCUSS] Release Flink 2.1.3 Yunfeng Zhou
  • Re: [DISCUSS] Release Flink 2.1.3 weijie guo
• [VOTE] Release 1.20.5, release candidate #1 Yunfeng Zhou
• [jira] [Created] (FLINK-39833) Special characters in column comment and default value are not escaped when building DDL SkylerLin (Jira)
• [jira] [Created] (FLINK-39832) [Bug] Oracle pipeline connector maps NUMBER(p,0) with p>=19 to BIGINT, causing primary key collision and row collapse in downstream sinks Zhouqing (Jira)
• [jira] [Created] (FLINK-39831) Integrate MetricsAware Interface with Native-s3-fs Samrat Deb (Jira)
• [jira] [Created] (FLINK-39830) Introduce MetricsAware Interface Samrat Deb (Jira)
• [RESULT] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
• [jira] [Created] (FLINK-39829) Bump scala to 2.12.21 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39828) Upgrade Calcite version to 1.40.0 Sergey Nuyanzin (Jira)
• [VOTE] Release 2.3.0, release candidate #2 Yuepeng Pan
  • Re: [VOTE] Release 2.3.0, release candidate #2 Sergey Nuyanzin
  • Re: [VOTE] Release 2.3.0, release candidate #2 David Anderson
  • Re: [VOTE] Release 2.3.0, release candidate #2 Yuepeng Pan
• [RESULT][VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 Ferenc Csaky
• [RESULT][VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-39827) [umbrella] Adopt JobInfo on source contexts Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39826) Strengthen autoscaler configuration validation Dennis-Mircea Ciupitu (Jira)
• RE: Re: [DISCUSS] FLIP-316: Introduce SQL Driver Chanhae Oh
  • Re: Re: [DISCUSS] FLIP-316: Introduce SQL Driver Yuepeng Pan
• [jira] [Created] (FLINK-39825) Add support for state TTL in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• [jira] [Created] (FLINK-39824) [mysql-cdc] High CPU usage caused by repeated regex table filtering in large table synchronization Ran Tao (Jira)
• [jira] [Created] (FLINK-39823) SystemTypeInference infers incorrect partition key Timo Walther (Jira)
• [jira] [Created] (FLINK-39822) All createTopics calls in tests should wait for partition assignment Aleksandr Savonin (Jira)
• [DISCUSS] Move flink-ci-docker under Apache Sergey Nuyanzin
  • Re: [DISCUSS] Move flink-ci-docker under Apache Chanhae Oh
  • Re: [DISCUSS] Move flink-ci-docker under Apache Yuepeng Pan
  • Re: [DISCUSS] Move flink-ci-docker under Apache Ferenc Csaky
• [jira] [Created] (FLINK-39821) Make return type of REGEX_REPLACE nullable Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39820) Add doc for delta join in 2.3 Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-39819) Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39818) Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector reswqa (Jira)
• [jira] [Created] (FLINK-39817) Upgrade Calcite version to 1.39.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39816) ES8 SQL sink can not parse response as missing dependency reswqa (Jira)
• [jira] [Created] (FLINK-39815) Mark SecurityManager related tests with FailsOnJava25 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39814) FlinkStateSnapshot-triggered savepoints ignore the referenced FlinkSessionJob state.savepoints.dir lrsb (Jira)
• [DISCUSS] FLIP-586: Introduce the upsert-kinesis Connector Francisco Morillo
• Community over Code Glasgow 2026 Hackathon - Next Steps Bowen, Rich
• [jira] [Created] (FLINK-39813) [Connectors/Kinesis] Add lineage support to Kinesis Streams connector Francisco Morillo (Jira)
• [jira] [Created] (FLINK-39812) Migrate FlinkTypeFactory to java Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39811) S5cmd effective concurrency capped by static part size for small downloads Efrat Levitan (Jira)
• [jira] [Created] (FLINK-39810) [kinesis] Support upsert changelog streams in Kinesis SQL connector Francisco Morillo (Jira)
• [jira] [Created] (FLINK-39809) Update flink-connector-parent to 2.0 for ElasticSearch connector reswqa (Jira)
• [VOTE] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
  • [CANCELLED] [VOTE] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
• [jira] [Created] (FLINK-39808) Tighten `FlinkVersion.isSupported()` to reject `@Deprecated` versions and restore the deprecate-and-raise-floor pattern Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39807) [umbrella] FLIP-577: AI-Native Flink — Umbrella for Multimodal Data Processing Guowei Ma (Jira)
• [RESULT][VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
• [jira] [Created] (FLINK-39806) Add java25 required flags Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39805) FlinkConfigBuilder uses platform-default charset when writing log/pod-template files Pavel Zeger (Jira)
• [jira] [Created] (FLINK-39804) Nested projection fields not pushed down to source Daniel Rossos (Jira)
• [jira] [Created] (FLINK-39803) E2E tests fail due to native access and deprecated method warnings on JDK 25 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39802) Fix flaky ProfilingServiceTest.testRollingDeletion by isolating the test and applying Interface Segregation to ProfilingService Jira
• [jira] [Created] (FLINK-39801) Skip serializing empty partitionKeys / orderKeys / orderDirections in TABLE_ARG_CALL compiled plan Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39800) Extend Restore test coverage for TO_CHANGELOG / FROM_CHANGELOG Gustavo de Morais (Jira)
• [VOTE] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
  • Re: [VOTE] FLIP-578: In-place Table to Materialized Table conversion Timo Walther
  • Re: [VOTE] FLIP-578: In-place Table to Materialized Table conversion Sergey Nuyanzin
  • Re: [VOTE] FLIP-578: In-place Table to Materialized Table conversion Fabian Hueske
  • Re: [VOTE] FLIP-578: In-place Table to Materialized Table conversion Yuepeng Pan
  • Re: [VOTE] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
• [jira] [Created] (FLINK-39799) Preserve user-typed query text for materialized table and view definitions Ramin Gharib (Jira)
• [VOTE] FLIP-584: Support Pluggable Storage Backend for HistoryServer zihao chen
  • Re: [VOTE] FLIP-584: Support Pluggable Storage Backend for HistoryServer Charles Zhang
  • Re:Re: [VOTE] FLIP-584: Support Pluggable Storage Backend for HistoryServer 魏祚
  • Re: Re: [VOTE] FLIP-584: Support Pluggable Storage Backend for HistoryServer Feng Jin
• [jira] [Created] (FLINK-39798) Add uber jar for es8 module reswqa (Jira)
• [jira] [Created] (FLINK-39797) [Flink CDC][Fluss] Support disabling automatic table creation and fail when target table does not exist liting liu (Jira)
• [jira] [Created] (FLINK-39796) Flink docker CI failure in master Hao Li (Jira)
• [jira] [Created] (FLINK-39795) MongoDB CDC does not use index when reading shard collection chunks Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39794) StreamNetworkBenchmarkEnvironment uses InetAddress.getLocalHost(), causing SSL hostname-verification failures on cloud CI runners Martijn Visser (Jira)
• [jira] [Created] (FLINK-39793) Bump quartz to 2.5.2 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39792) Add multi-headers metadata key to Kafka connector Arvid Heise (Jira)
• [jira] [Created] (FLINK-39791) Helm chart silently ignores defaultConfiguration.config.yaml; always mounts flink-conf.yaml from chart defaults Gerk Elznik (Jira)
• [jira] [Created] (FLINK-39790) State latency/size tracking metrics not exported without sampling Efrat Levitan (Jira)
• [jira] [Created] (FLINK-39789) AvroSchemaConverter.convertToDataType(String) ignores local-timestamp-* and timestamp-nanos logical types, silently maps to BIGINT Shekhar Prasad Rajak (Jira)
• [jira] [Created] (FLINK-39788) Pekko error "Actor not found" when Kubernetes namespace starts from digit Vladislav Keda (Jira)
• [jira] [Created] (FLINK-39787) Build broken for flink-benchmarks David Anderson (Jira)
• [jira] [Created] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure Samrat Deb (Jira)
• [DISCUSS] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
  • Re: [DISCUSS] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
  • Re: [DISCUSS] FLIP-583: Expose JobInfo on Source contexts Yuepeng Pan
  • Re: [DISCUSS] FLIP-583: Expose JobInfo on Source contexts Rui Fan
  • Re: [DISCUSS] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
• [jira] [Created] (FLINK-39785) Add end-to-end tests for LATERAL SNAPSHOT join Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39784) Add translation rule to block usage of SNAPSHOT function outside of LATERAL context Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39782) Add SNAPSHOT built-in table function definition Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39783) Add translation rules to convert lateral call of SNAPSHOT function into join operator Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39781) Add operator for LATERAL SNAPSHOT Join Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39780) Make TABLE keyword optional in LATERAL context Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39779) FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39778) Recoverable writer silently loses the in-flight tail on resume Samrat Deb (Jira)
• [jira] [Created] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator Yanquan Lv (Jira)
• [jira] [Created] (FLINK-39776) Expose JobInfo on Source contexts Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39775) Snapshot split metadata is not released after switching to stream phase, causing large JobManager coordinator state and OOM with many snapshot splits yuanfenghu (Jira)
• [jira] [Created] (FLINK-39774) Format YEAR-MONTH interval keys as months instead of days Fan Deng (Jira)
• [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region 熊饶饶
  • Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region zihao chen
  • Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region Gen Luo
• [jira] [Created] (FLINK-39773) ClusterEntryPointTest fails on java25 Sergey Nuyanzin (Jira)
• [DISCUSS] FLIP-582: Support RpcOperator Service Yi Zhang
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Charles Zhang
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Guowei Ma
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Guowei Ma
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Hongshun Wang
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Xintong Song
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Yi Zhang
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Yi Zhang
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Yi Zhang
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Gen Luo
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Guowei Ma
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Lei Yang
  • Re: [DISCUSS] FLIP-582: Support RpcOperator Service Yuan Mei
• [jira] [Created] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39771) [JUnit5 Migration] Module: flink-cep Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39770) [JUnit5 Migration] Module: flink-state-processing-api Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39769) [JUnit5 Migration] Module: flink-examples-streaming Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39768) Module: flink-avro - migrate AvroStreamingFileSinkITCase straggler Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39767) [JUnit5 Migration] Module: flink-statebackend-forst Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39766) Remove AggregatedMetric copy that made redundant by Flink 1.20 dependency upgrade Aleksandr Savonin (Jira)
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.15.0 released Gyula Fóra
• [DISCUSS] CEP NFA partial match accumulation causes unbounded memory/CPU growth for high-frequency start events 1193179897
• [jira] [Created] (FLINK-39765) Add FLIP-314 lineage support (LineageVertexProvider) to MySQL CDC source connector Jaskaran Singh Kukreja (Jira)
• [VOTE] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Martijn Visser
  • Re: [VOTE] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Gabor Somogyi
• [jira] [Created] (FLINK-39764) Support dynamic table options in Table API Mika Naylor (Jira)
• [jira] [Created] (FLINK-39763) Allow inferring constants with `IS NOT DISTINCT FROM` Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39762) Wget is absent for java25 docker Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning Jira
• [jira] [Created] (FLINK-39760) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39756) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39759) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39758) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39757) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39754) DataOutputSerializer.resize() int overflow causes O(n²) growth near 2 GB Saulius Valatka (Jira)
• [jira] [Created] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
• [jira] [Created] (FLINK-39752) Thread EventRecorder through FlinkResourceContext instead of holding it on the factory Dennis-Mircea Ciupitu (Jira)
• [DISCUSS] Introducing DECLARE VARIABLE in Flink SQL Chanhae Oh
• [jira] [Created] (FLINK-39751) Introduce FailsOnJava25 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39750) Drop FailsOnJava11 Sergey Nuyanzin (Jira)
• [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function FeatZhang
  • Re: [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function 熊饶饶
  • Re: [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function Timo Walther
  • Re: [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function FeatZhang
  • Re: [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function FeatZhang
• [jira] [Created] (FLINK-39749) [mysql-cdc] Introduce scan.incremental.snapshot.string-key.compare-mode to align Java and MySQL ordering for string chunk keys Ziyan Lee (Jira)
• [DISCUSS] Release Flink 1.20.5 Yunfeng Zhou
  • Re: [DISCUSS] Release Flink 1.20.5 Xintong Song
• [jira] [Created] (FLINK-39748) Postgres CDC snapshot produces wrong values for TIMESTAMP / TIMESTAMPTZ / DATE columns with historical dates Di Wu (Jira)
• [jira] [Created] (FLINK-39747) Upgrade test to junit 5 Fan Deng (Jira)
• [jira] [Created] (FLINK-39746) Add jdk25 profile in in common_docker.sh Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39745) Web dashboard: surface watermark lag as a per-job timeline Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39744) Release Testing: Verify FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39743) Incorrect Expected Processing Rate Computation Devika Sudheer (Jira)
• [jira] [Created] (FLINK-39742) FlinkImageBuilder checks for Java 25 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39741) Add generic type hints to DataStream functions in functions.py Vaibhav S Gowda (Jira)
• [jira] [Created] (FLINK-39740) LinkedMultiSetState updates highestSqnAndSizeState unconditionally Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-39739) Add java25 to docker imae Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39738) React to checkpoint ACK RPC failures Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-39737) Add native s3 connector throttling support Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-39736) Do not allow security manager for jdk24+ Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39735) Expose input upsert key on TableSemantics for ProcessTableFunctions Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39734) Exclude 2.1 and 2.2 from GHA nightly Sergey Nuyanzin (Jira)
• [REVIEW] Pavel Zeger
• [RESULT][VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 Gabor Somogyi
• Flink Consumption of ASF Shared GitHub-hosted Runners Robert Thomson
  • Re: Flink Consumption of ASF Shared GitHub-hosted Runners Sergey Nuyanzin
  • Re: Flink Consumption of ASF Shared GitHub-hosted Runners Robert Metzger
• [jira] [Created] (FLINK-39733) Do not use net.jcip.annotations Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39732) Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) Hongshun Wang (Jira)
• Slack invitation Alexis Sarda-Espinosa
  • Re: Slack invitation Weiqing Yang
  • Slack invitation Soumitra Kumar
  • Re: Slack invitation Leonard Xu
• [jira] [Created] (FLINK-39731) SqlValidatorImpl should reject MATCH_RECOGNIZE with duplicate MEASURE Sergey Nuyanzin (Jira)
• [VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
  • Re: [VOTE] Release flink-connector-http v1.0.0, release candidate 2 Ferenc Csaky
  • RE: [VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
  • RE: [VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
  • Re: [VOTE] Release flink-connector-http v1.0.0, release candidate 2 Nic Townsend
• [jira] [Created] (FLINK-39730) ApplicationExceptionsHandler silently ignores maxExceptions parameter; ApplicationExceptionsMessageParameters is unreachable via typed REST client Jubin Soni (Jira)
• [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Kui Yuan
  • Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Xia Sun
  • Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Gen Luo
  • Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Lincoln Lee
  • Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Kui Yuan
  • Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Alan Sheinberg via dev

• Earlier messages