Messages by Date
-
2026/02/03
Re: [PR] [hotfix] Use Thread Context ClassLoader for user class loading [flink-agents]
via GitHub
-
2026/02/03
Re: [PR] [hotfix] Use Thread Context ClassLoader for user class loading [flink-agents]
via GitHub
-
2026/02/03
Re: [PR] [hotfix] Use Thread Context ClassLoader for user class loading [flink-agents]
via GitHub
-
2026/02/03
[PR] [hotfix] Use Thread Context ClassLoader for user class loading [flink-agents]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-39022][core] Set security.ssl.algorithms default value to modern cipher suite [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-39022][core] Set security.ssl.algorithms default value to modern cipher suite [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)
ASF GitHub Bot (Jira)
-
2026/02/03
Re: [PR] [FLINK-39022][core] Set security.ssl.algorithms default value to modern cipher suite [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-21672][test] amend unit test so it tolerates IBM java [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink]
via GitHub
-
2026/02/03
[jira] [Commented] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)
david radley (Jira)
-
2026/02/03
Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink]
via GitHub
-
2026/02/03
[PR] [hotfix][test] amend unit test so it works with IBM java [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink]
via GitHub
-
2026/02/03
[PR] [FLINK-39022][core] Set security.ssl.algorithms default value to modern cipher suite [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39022) Update default cipher suite value in SecurityOptions
ASF GitHub Bot (Jira)
-
2026/02/03
Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-25538] Migrate tests from JUnit 4 to JUnit 5 [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] Bump org.assertj:assertj-core from 3.25.3 to 3.27.7 [flink-connector-opensearch]
via GitHub
-
2026/02/03
[jira] [Commented] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF
david radley (Jira)
-
2026/02/03
Re: [PR] [Hotfix] Update log4j to 2.25.3 [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-38512) Postgres YAML CDC support database name with middlescore
ASF GitHub Bot (Jira)
-
2026/02/03
[PR] [FLINK-38512][postgres] Update database name validation to allow hyphens [flink-cdc]
via GitHub
-
2026/02/03
[PR] Flink community blog February 2026 [flink-web]
via GitHub
-
2026/02/03
[jira] [Assigned] (FLINK-39022) Update default cipher suite value in SecurityOptions
Ferenc Csaky (Jira)
-
2026/02/03
Re: [PR] [Hotfix][Flink-CI-Tools] Update Guava to 32.0.1 [flink]
via GitHub
-
2026/02/03
Re: [PR] [DRAFT][hotfix] Wait for leader election to prevent OUT_OF_ORDER issues [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-39011][table-api-java] Accept UnresolvedDataType in BaseExpression.cast() [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39022) Update default cipher suite value in SecurityOptions
Imre Balassa (Jira)
-
2026/02/03
Re: [PR] [FLINK-25538] Migrate tests from JUnit 4 to JUnit 5 [flink-connector-kafka]
via GitHub
-
2026/02/03
[PR] [FLINK-39011][table-api-java] Accept UnresolvedDataType in BaseExpression.cast() [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39011) Cast does not support UnresolvedDataType
ASF GitHub Bot (Jira)
-
2026/02/03
[jira] [Updated] (FLINK-39022) Update default cipher suite value in SecurityOptions
Imre Balassa (Jira)
-
2026/02/03
[jira] [Updated] (FLINK-39022) Update default cipher suite value in SecurityOptions,
Imre Balassa (Jira)
-
2026/02/03
Re: [PR] [FLINK-25538] Migrate tests from JUnit 4 to JUnit 5 [flink-connector-kafka]
via GitHub
-
2026/02/03
[PR] [DRAFT][hotfix] Wait for leader election to prevent OUT_OF_ORDER issues [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38957][table-planner] Support `ProcessTableFunction` registration via `CompiledPlan` [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39022) Update default cipher suite value in SecurityOptions
Imre Balassa (Jira)
-
2026/02/03
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38986][runtime][test] Update further tests with modern cipher suite [flink]
via GitHub
-
2026/02/03
[jira] [Created] (FLINK-39022) Update default cipher suite value in SecurityOptions
Imre Balassa (Jira)
-
2026/02/03
Re: [PR] [FLINK-38986][runtime][test] Update further tests with modern cipher suite [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink]
via GitHub
-
2026/02/03
Re: [PR] [Hotfix] Update log4j to 2.25.3 [flink]
via GitHub
-
2026/02/03
Re: [PR] [Hotfix] Update log4j to 2.25.3 [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink]
via GitHub
-
2026/02/03
Re: [PR] [Hotfix] Update log4j to 2.25.3 [flink]
via GitHub
-
2026/02/03
[jira] [Created] (FLINK-39021) Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments
Liu (Jira)
-
2026/02/03
[PR] Update log4j to 2.25.3 [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-35637][table-planner] Fix ScalarFunctionCallGen for complex ar… [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-35637) ScalarFunctionCallGen does not handle complex argument type properly
ASF GitHub Bot (Jira)
-
2026/02/03
[PR] [FLINK-35637][table-planner] Fix ScalarFunctionCallGen for complex ar… [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38992] Expire associated state together for non-time over windows [flink]
via GitHub
-
2026/02/03
[jira] [Closed] (FLINK-39008) Support record types natively in DataTypeExtractor
Timo Walther (Jira)
-
2026/02/03
Re: [PR] [FLINK-39008][table-common] Support record types natively in DataTypeExtractor [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-39016][Runtime/REST] Add configurable TTL for ExecutionGraph cache independent of web refresh interval [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc]
via GitHub
-
2026/02/03
Re: [PR] [hotfix] Fix kafka connection flakeyness in tests [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc]
via GitHub
-
2026/02/03
Re: [PR] [hotfix] Fix kafka connection flakeyness in tests [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-39016][Runtime/REST] Add configurable TTL for ExecutionGraph cache independent of web refresh interval [flink]
via GitHub
-
2026/02/03
[PR] Kubernetes Operator 1.14.0 [flink-web]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38998][table] Fix cascaded event time WindowAggregate does not produce data when offset is specified [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38539][table] Fix integer overflow in AbstractBytesMultiMap wh… [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-39008][table-common] Support record types natively in DataTypeExtractor [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-37586][udf] Add support for options in user-defined functions and update related documentation [flink-cdc]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc]
via GitHub
-
2026/02/03
[jira] [Commented] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields
Natea Eshetu Beshada (Jira)
-
2026/02/03
Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink]
via GitHub
-
2026/02/03
[jira] [Commented] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables
Leonard Xu (Jira)
-
2026/02/03
[jira] [Updated] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables
Leonard Xu (Jira)
-
2026/02/03
[jira] [Assigned] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables
Leonard Xu (Jira)
-
2026/02/03
Re: [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-38543) Change the overall UC restore process, JM and task initialization
Rui Fan (Jira)
-
2026/02/03
[jira] [Closed] (FLINK-29855) UDF randomly processed input data twice
Natea Eshetu Beshada (Jira)
-
2026/02/03
[jira] [Commented] (FLINK-29855) UDF randomly processed input data twice
Natea Eshetu Beshada (Jira)
-
2026/02/03
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39020) When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.)
Jira
-
2026/02/03
[jira] [Assigned] (FLINK-38987) Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem
Maximilian Michels (Jira)
-
2026/02/03
Re: [PR] [FLINK-29855][table-planner] Fix non-deterministic UDF evaluated mult… [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-29855][table-planner] Fix non-deterministic UDF evaluated mult… [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39020) When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.)
ASF GitHub Bot (Jira)
-
2026/02/03
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING [flink]
via GitHub
-
2026/02/03
[PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39018) Support checkpoint for LocalInputChannel
Rui Fan (Jira)
-
2026/02/03
[jira] [Updated] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments
Gyula Fora (Jira)
-
2026/02/03
[jira] [Updated] (FLINK-38421) BlueGreen Deployment Documentation
Gyula Fora (Jira)
-
2026/02/03
[jira] [Updated] (FLINK-37411) Introduce the rollback mechanism for Autoscaler
Gyula Fora (Jira)
-
2026/02/03
[jira] [Assigned] (FLINK-37411) Introduce the rollback mechanism for Autoscaler
Gyula Fora (Jira)
-
2026/02/03
[jira] [Created] (FLINK-39020) When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.)
Jira
-
2026/02/03
[jira] [Updated] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables
suhwan (Jira)
-
2026/02/03
Re: [PR] [FLINK-38943][runtime] Support Adaptive Partition Selection for RescalePartitioner and RebalancePartitioner [flink]
via GitHub
-
2026/02/03
Re: [PR] Debugging the Blue/Green e2e tests [flink-kubernetes-operator]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38539][table] Fix integer overflow in AbstractBytesMultiMap wh… [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink]
via GitHub
-
2026/02/03
[jira] [Closed] (FLINK-38912) Upgrade Flink to use Netty 4.2.6.Final
Ferenc Csaky (Jira)
-
2026/02/03
Re: [PR] [hotfix][docs] Pull request to update documentation for Flink 2.0 support. [flink-kubernetes-operator]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38912] Upgrade Netty to 4.2.6.Final [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-39008][table-common] Support record types natively in DataTypeExtractor [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables
suhwan (Jira)
-
2026/02/03
[jira] [Assigned] (FLINK-38912) Upgrade Flink to use Netty 4.2.6.Final
Ferenc Csaky (Jira)
-
2026/02/03
Re: [PR] [FLINK-39008][table-common] Support record types natively in DataTypeExtractor [flink]
via GitHub
-
2026/02/03
[jira] [Created] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables
suhwan (Jira)
-
2026/02/03
[jira] [Commented] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables
suhwan (Jira)
-
2026/02/03
[jira] [Created] (FLINK-39018) Support checkpoint for LocalInputChannel
Rui Fan (Jira)
-
2026/02/03
[jira] [Updated] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor / AbstractBytesMultiMap with memory state backend
ASF GitHub Bot (Jira)
-
2026/02/03
[PR] [FLINK-38539][table] Fix integer overflow in AbstractBytesMultiMap wh… [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38912] Upgrade Netty to 4.2.6.Final [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression)
Wei Zhong (Jira)
-
2026/02/03
Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression)
Wei Zhong (Jira)
-
2026/02/03
[jira] [Updated] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression)
Wei Zhong (Jira)
-
2026/02/03
Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink]
via GitHub
-
2026/02/03
[jira] [Created] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression)
Wei Zhong (Jira)
-
2026/02/03
[PR] [HOTFIX] Fix tests flakeyness [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-29855][table-planner] Fix non-deterministic UDF evaluated mult… [flink]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-25538] Migrate tests from JUnit 4 to JUnit 5 [flink-connector-kafka]
via GitHub
-
2026/02/03
Re: [PR] [FLINK-39016][Runtime/REST] Add configurable TTL for ExecutionGraph cache independent of web refresh interval [flink]
via GitHub
-
2026/02/03
[jira] [Closed] (FLINK-35476) The IF built-in function returns an exception when returning a string
Natea Eshetu Beshada (Jira)
-
2026/02/03
Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc]
via GitHub
-
2026/02/03
[PR] [FLINK-39016][Runtime/REST] Add configurable TTL for ExecutionGraph cache independent of web refresh interval [flink]
via GitHub
-
2026/02/03
[jira] [Updated] (FLINK-39016) Add configurable TTL for ExecutionGraph cache independent of web refresh interval
ASF GitHub Bot (Jira)
-
2026/02/02
Re: [PR] [FLINK-38089] Avoid pushing down non-deterministic filter in FILTER_RULES [flink]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink]
via GitHub
-
2026/02/02
[jira] [Updated] (FLINK-39015) Fix MultiJoin rowadata behaviour for HeapStateBackend
ASF GitHub Bot (Jira)
-
2026/02/02
[PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink]
via GitHub
-
2026/02/02
[jira] [Created] (FLINK-39016) Add configurable TTL for ExecutionGraph cache independent of web refresh interval
Liu (Jira)
-
2026/02/02
Re: [PR] [FLINK-29855][table-planner] Fix non-deterministic UDF evaluated mult… [flink]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records [flink]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models [flink]
via GitHub
-
2026/02/02
Re: [PR] Fix the conversion to relational algebra issue in Batch Mode [flink]
via GitHub
-
2026/02/02
Re: [PR] Fix the conversion to relational algebra issue in Batch Mode [flink]
via GitHub
-
2026/02/02
[jira] [Updated] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode
Archit Goyal (Jira)
-
2026/02/02
[PR] Fix the conversion to relational algebra issue in Batch Mode [flink]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-38869] InitializationContext for KafkaSubscriber [flink-connector-kafka]
via GitHub
-
2026/02/02
[jira] [Updated] (FLINK-39015) Fix MultiJoin rowadata behaviour for HeapStateBackend
Dmitriy Linevich (Jira)
-
2026/02/02
[jira] [Updated] (FLINK-39015) Fix MultiJoin rowadata behaviour for HeapStateBackend
Dmitriy Linevich (Jira)
-
2026/02/02
Re: [PR] [FLINK-38969][SQL] Extend json_string to convert variant type [flink]
via GitHub
-
2026/02/02
[jira] [Updated] (FLINK-39015) Fix MultiJoin rowadata behaviour for HeapStateBackend
Dmitriy Linevich (Jira)
-
2026/02/02
[jira] [Updated] (FLINK-39015) Fix MultiJoin rowadata behaviour for HeapStateBackend
Dmitriy Linevich (Jira)
-
2026/02/02
[jira] [Created] (FLINK-39015) Fix ro
Dmitriy Linevich (Jira)
-
2026/02/02
[jira] [Assigned] (FLINK-38751) RowTimeRangeBoundedPrecedingFunction incorrectly cleans lastTriggeringTsState, may not discard expired data
Natea Eshetu Beshada (Jira)
-
2026/02/02
[jira] [Assigned] (FLINK-38822) Extend URL_DECODE with a recursive parameter for multi-level decoding
Natea Eshetu Beshada (Jira)
-
2026/02/02
[jira] [Updated] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode
Archit Goyal (Jira)
-
2026/02/02
[jira] [Updated] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode
Archit Goyal (Jira)
-
2026/02/02
[jira] [Created] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode
Archit Goyal (Jira)
-
2026/02/02
[jira] [Commented] (FLINK-39009) flink postgres unnest insert way
Gaurav Miglani (Jira)
-
2026/02/02
Re: [PR] [FLINK-29855][table-planner] Fix non-deterministic UDF evaluated mult… [flink]
via GitHub
-
2026/02/02
[jira] [Updated] (FLINK-29855) UDF randomly processed input data twice
ASF GitHub Bot (Jira)
-
2026/02/02
[PR] [FLINK-29855][table-planner] Fix non-deterministic UDF evaluated mult… [flink]
via GitHub
-
2026/02/02
Re: [D] Flink Agents Support Multi-JDK Versions [flink-agents]
via GitHub
-
2026/02/02
Re: [D] Support Java Async Execution [flink-agents]
via GitHub
-
2026/02/02
Re: [D] Flink Multi-Version Support [flink-agents]
via GitHub
-
2026/02/02
Re: [D] Support Fine-Grain Durable Execution [flink-agents]
via GitHub
-
2026/02/02
Re: [D] Improve Python Async Execution API [flink-agents]
via GitHub
-
2026/02/02
Re: [D] Resource Cross-Language Support for Flink Agents [flink-agents]
via GitHub
-
2026/02/02
Re: [D] Flink-Agents Memory Design [flink-agents]
via GitHub
-
2026/02/02
[jira] [Assigned] (FLINK-29855) UDF randomly processed input data twice
Natea Eshetu Beshada (Jira)
-
2026/02/02
Re: [PR] [FLINK-38941][python] Add Python building blocks for async Python scalar function [flink]
via GitHub
-
2026/02/02
Re: [PR] [hotfix] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) [flink-cdc]
via GitHub
-
2026/02/02
[jira] [Resolved] (FLINK-38846) Binlog client use LinkedList to store binlog content
Yanquan Lv (Jira)
-
2026/02/02
Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc]
via GitHub
-
2026/02/02
Re: [PR] [chore][improve] Improve flaky test case FlussSinkITCase [flink-cdc]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-38846][mysql] Optimize LinkedList processing in handleChange method to reduce complexity [flink-cdc]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-38941][python] Add Python building blocks for async Python scalar function [flink]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-38468][flink-table-planner] When the coalesce parameter contains a function, convert it to case when [flink]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-38846][mysql] Optimize LinkedList processing in handleChange method to reduce complexity [flink-cdc]
via GitHub
-
2026/02/02
[jira] [Resolved] (FLINK-38985) [Doc] Add document for VARIANT type and related functions
Yanquan Lv (Jira)
-
2026/02/02
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records [flink]
via GitHub
-
2026/02/02
[jira] [Assigned] (FLINK-38906) Polish YAML transform built-in functions
Yanquan Lv (Jira)
-
2026/02/02
[jira] [Closed] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional"
Yanquan Lv (Jira)
-
2026/02/02
[jira] [Resolved] (FLINK-38520) Postgres YAML CDC support array with null element
Yanquan Lv (Jira)
-
2026/02/02
[jira] [Updated] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions
ASF GitHub Bot (Jira)
-
2026/02/02
[jira] [Resolved] (FLINK-38906) Polish YAML transform built-in functions
Yanquan Lv (Jira)
-
2026/02/02
[PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records [flink]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-38846][mysql] Optimize LinkedList processing in handleChange method to reduce complexity [flink-cdc]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-39005][format] Users can choose to use the fast reader feature. [flink]
via GitHub
-
2026/02/02
Re: [PR] [FLINK-39004][flink-table] JUnit5 Migration: Migrate the remaining test classes related to junit4 of flink-table module to junit5 [flink]
via GitHub
-
2026/02/02
[jira] [Assigned] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions
Natea Eshetu Beshada (Jira)
-
2026/02/02
[jira] [Assigned] (FLINK-39010) YAML Pipeline supports item subscription of variant types
Xiqian Yu (Jira)
-
2026/02/02
Re: [PR] [FLINK-38261] add catalog connection resource [flink]
via GitHub
-
2026/02/02
[jira] [Updated] (FLINK-38261) Connection catalog object and manager changes
ASF GitHub Bot (Jira)
-
2026/02/02
[PR] [FLINK-38261] add catalog connection resource [flink]
via GitHub