Messages by Date
-
2026/08/28
[jira] [Assigned] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR
Gustavo de Morais (Jira)
-
2026/08/28
[jira] [Created] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR
Gustavo de Morais (Jira)
-
2026/08/28
[jira] [Created] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE ignores query column position, silently producing a schema whose column order disagrees with the query (ALTER ... AS is correct)
Arvid Heise (Jira)
-
2026/08/28
[jira] [Resolved] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x
Martijn Visser (Jira)
-
2026/08/28
[jira] [Updated] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x
Martijn Visser (Jira)
-
2026/08/28
Re: [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink]
via GitHub
-
2026/08/28
Re: [PR] [FLINK-39780] Make TABLE keyword optional in LATERAL context [flink]
via GitHub
-
2026/08/28
[jira] [Resolved] (FLINK-39780) Make TABLE keyword optional in LATERAL context
Fabian Hueske (Jira)
-
2026/08/28
Re: [PR] [hotfix][docs] Fix OPTIONS hint key in time attributes docs [flink]
via GitHub
-
2026/08/28
Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink]
via GitHub
-
2026/08/28
Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink]
via GitHub
-
2026/08/28
Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink]
via GitHub
-
2026/08/28
[jira] [Updated] (FLINK-40422) Add slicing APIs to DataFrame API
ASF GitHub Bot (Jira)
-
2026/08/28
Re: [PR] [FLINK-40422][python] Add slicing APIs to DataFrame API [flink]
via GitHub
-
2026/08/28
[PR] [FLINK-40422][python] Add slicing APIs to DataFrame API [flink]
via GitHub
-
2026/08/28
Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink]
via GitHub
-
2026/08/28
Re: [PR] [ci][integrations] Consolidate vector store tests [flink-agents]
via GitHub
-
2026/08/28
Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents]
via GitHub
-
2026/08/28
Re: [I] [Feature] Multimodal content blocks in ChatMessage [flink-agents]
via GitHub
-
2026/08/28
Re: [PR] [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation [flink]
via GitHub
-
2026/08/27
[PR] Multimodal content blocks [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink]
via GitHub
-
2026/08/27
[PR] [ci][integrations] Consolidate vector store tests [flink-agents]
via GitHub
-
2026/08/27
Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents]
via GitHub
-
2026/08/27
[I] [Feature] Multimodal content blocks in ChatMessage [flink-agents]
via GitHub
-
2026/08/27
[jira] [Commented] (FLINK-40422) Add slicing APIs to DataFrame API
Dian Fu (Jira)
-
2026/08/27
[jira] [Commented] (FLINK-40422) Add slicing APIs to DataFrame API
Dian Fu (Jira)
-
2026/08/27
[jira] [Assigned] (FLINK-40422) Add slicing APIs to DataFrame API
Dian Fu (Jira)
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents]
via GitHub
-
2026/08/27
Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents]
via GitHub
-
2026/08/27
[jira] [Commented] (FLINK-39986) Support Common Sub-Expression Elimination (CSE) for Python UDFs
Dian Fu (Jira)
-
2026/08/27
Re: [PR] [hotfix][runtime][python] Close every component when an earlier close fails [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing [flink-cdc]
via GitHub
-
2026/08/27
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/08/27
[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/08/27
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/08/27
Re: [PR] [FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector [flink-cdc]
via GitHub
-
2026/08/27
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/08/27
Re: [PR] [FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector [flink-cdc]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing [flink-cdc]
via GitHub
-
2026/08/27
[jira] [Assigned] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER()
Dian Fu (Jira)
-
2026/08/27
[jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics
Dian Fu (Jira)
-
2026/08/27
Re: [PR] [hotfix][runtime][python] Close every component when an earlier close fails [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc]
via GitHub
-
2026/08/27
[jira] [Resolved] (FLINK-39889) Convert table sqlnode to operation
Hao Li (Jira)
-
2026/08/27
[jira] [Assigned] (FLINK-39889) Convert table sqlnode to operation
Hao Li (Jira)
-
2026/08/27
[jira] [Commented] (FLINK-39889) Convert table sqlnode to operation
Hao Li (Jira)
-
2026/08/27
[jira] [Commented] (FLINK-38411) Array index overflow in enumerator with continuous file source
Li Guo (Jira)
-
2026/08/27
[jira] [Created] (FLINK-40495) Limit concurrent shared-state disposal to prevent JobManager I/O starvation
Tianji Li (Jira)
-
2026/08/27
Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40232][table-runtime] Handle null rowtime in OutputConversionOperator [flink]
via GitHub
-
2026/08/27
[jira] [Created] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler
Rui Fan (Jira)
-
2026/08/27
Re: [PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink]
via GitHub
-
2026/08/27
[jira] [Created] (FLINK-40489) Add UUID_V4() & UUID_V7() functions
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Updated] (FLINK-40486) Introduce the UUID logical type
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Resolved] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler
Rui Fan (Jira)
-
2026/08/27
[jira] [Created] (FLINK-40486) Introduce the UUID logical type
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-20
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Created] (FLINK-40491) Decode/accessor support in BinaryVariant for codes 17-20
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Created] (FLINK-40485) FLIP 604: Complete VARIANT primitive coverage with UUID and timestamps
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Created] (FLINK-40488) Comparison and ordering for UUID
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Created] (FLINK-40493) VARIANT CAST for UUID (code 20)
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Created] (FLINK-40494) Document UUID and extended VARIANT type
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Created] (FLINK-40492) VARIANT CAST for TIME and nanosecond timestamps (17-19)
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-20
Ramin Gharib (Jira)
-
2026/08/27
Re: [PR] [hotfix][runtime][python] Close every component when an earlier close fails [flink-agents]
via GitHub
-
2026/08/27
[jira] [Created] (FLINK-40490) Runtime serialization and codegen for UUID
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Updated] (FLINK-40487) CAST between UUID and STRING / BINARY(16)
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Updated] (FLINK-40487) CAST between UUID and STRING / BINARY(16)
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Created] (FLINK-40487) CAST between UUID and STRING / BINARY(16)
Ramin Gharib (Jira)
-
2026/08/27
Re: [PR] [FLINK-40484][tests] Run UnalignedCheckpointTestBase with the DefaultScheduler instead of skipping it under AdaptiveScheduler [flink]
via GitHub
-
2026/08/27
[jira] [Assigned] (FLINK-40485) FLIP 604: Complete VARIANT primitive coverage with UUID and timestamps
Ramin Gharib (Jira)
-
2026/08/27
[jira] [Resolved] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished
Rui Fan (Jira)
-
2026/08/27
[PR] Fix Derby upgrade for Java 17 [flink-connector-jdbc]
via GitHub
-
2026/08/27
Re: [PR] Fix Derby upgrade for Java 17 [flink-connector-jdbc]
via GitHub
-
2026/08/27
[jira] [Commented] (FLINK-38411) Array index overflow in enumerator with continuous file source
Simon Frei (Jira)
-
2026/08/27
[PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
-
2026/08/27
Re: [PR] [DO_NOT_MERGE][FLINK-38544] Checkpointing during recovery enabled [flink]
via GitHub
-
2026/08/27
Re: [PR] [DO_NOT_MERGE][FLINK-38544] Checkpointing during recovery disabled [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-38544][checkpoint] Support spilling for checkpointing during recovery [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40484][tests] Run UnalignedCheckpointTestBase with the DefaultScheduler instead of skipping it under AdaptiveScheduler [flink]
via GitHub
-
2026/08/27
[jira] [Updated] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler
ASF GitHub Bot (Jira)
-
2026/08/27
[PR] [FLINK-40484][tests] Run UnalignedCheckpointTestBase with the DefaultScheduler instead of skipping it under AdaptiveScheduler [flink]
via GitHub
-
2026/08/27
[jira] [Updated] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler
Rui Fan (Jira)
-
2026/08/27
Re: [PR] [released] Add Flink-Shaded 22.0 [flink-web]
via GitHub
-
2026/08/27
[jira] [Comment Edited] (FLINK-26755) Cleanup inprogressfileRecoverable for FileSink on restoring
Li Guo (Jira)
-
2026/08/27
[jira] [Commented] (FLINK-26755) Cleanup inprogressfileRecoverable for FileSink on restoring
Li Guo (Jira)
-
2026/08/27
Re: [PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink]
via GitHub
-
2026/08/27
Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-36434][Connectors/Kafka] Create the KafkaConsumer lazily on the split fetcher thread [flink-connector-kafka]
via GitHub
-
2026/08/27
Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents]
via GitHub
-
2026/08/27
Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
[jira] [Commented] (FLINK-40454) java.lang.NoSuchMethodError: '...Configuration.getInteger(..)' in FlinkConfigManager
Dennis-Mircea Ciupitu (Jira)
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka]
via GitHub
-
2026/08/27
Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
-
2026/08/27
[jira] [Created] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER()
Timo Theusner (Jira)
-
2026/08/27
Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink]
via GitHub
-
2026/08/27
[jira] [Updated] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished
ASF GitHub Bot (Jira)
-
2026/08/27
[PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
[jira] [Created] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished
Rui Fan (Jira)
-
2026/08/27
Re: [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink]
via GitHub
-
2026/08/27
[jira] [Updated] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished
Rui Fan (Jira)
-
2026/08/27
Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink]
via GitHub
-
2026/08/27
[jira] [Updated] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past
ASF GitHub Bot (Jira)
-
2026/08/27
[PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink]
via GitHub
-
2026/08/27
[jira] [Created] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past
Arvid Heise (Jira)
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
[jira] [Comment Edited] (FLINK-40197) Add sql bindings to DataFrame API
Dian Fu (Jira)
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
[jira] [Comment Edited] (FLINK-40197) Add sql bindings to DataFrame API
Dian Fu (Jira)
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
[jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API
Dian Fu (Jira)
-
2026/08/27
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
-
2026/08/27
[jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics
Bettle (Jira)
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs [flink-kubernetes-operator]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40194][python] Add drop_duplicates to the PyFlink DataFrame API [flink]
via GitHub
-
2026/08/27
[jira] [Closed] (FLINK-40194) Add drop_duplicates to DataFrame API
Dian Fu (Jira)
-
2026/08/27
Re: [PR] [FLINK-40194][python] Add drop_duplicates to the PyFlink DataFrame API [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40194][python] Add drop_duplicates to the PyFlink DataFrame API [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39780] Make TABLE keyword optional in LATERAL context [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs [flink-kubernetes-operator]
via GitHub
-
2026/08/27
[I] [Draft] [Bug] Python resource bridges do not consistently release Pemja references [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs [flink-kubernetes-operator]
via GitHub
-
2026/08/27
[PR] [runtime][python] Manage Pemja references across resource bridges [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40263][format/avro] Validate enum symbols when serializing CHAR/VARCHAR [flink]
via GitHub
-
2026/08/27
[jira] [Closed] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator
Gyula Fora (Jira)
-
2026/08/27
Re: [PR] [FLINK-40465] Add version-independent classes to parse job config [flink-kubernetes-operator]
via GitHub
-
2026/08/27
[jira] (FLINK-23758) PyFlink __invert__ has wrong semantics
Bettle (Jira)
-
2026/08/27
[jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics
Bettle (Jira)
-
2026/08/27
Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink]
via GitHub
-
2026/08/27
[jira] [Created] (FLINK-40480) [doc] CDC Yaml supports fluss source.
Hongshun Wang (Jira)
-
2026/08/27
[jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics
Dian Fu (Jira)
-
2026/08/27
[jira] [Assigned] (FLINK-23758) PyFlink __invert__ has wrong semantics
Dian Fu (Jira)
-
2026/08/27
[jira] [Closed] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated
Gyula Fora (Jira)
-
2026/08/27
Re: [PR] [FLINK-38290][operator] Keep terminal job state when job is not found [flink-kubernetes-operator]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39539][table] Document changelog processing in AGENTS.md [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39539][table] Document changelog processing in AGENTS.md [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-37441] Rename `factoryHierarchy` to `typeHierarchy` for `TypeExtractor` [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink]
via GitHub
-
2026/08/27
Re: [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-38539][table] Fix integer overflow in AbstractBytesMultiMap wh… [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-38539][table] Fix integer overflow in AbstractBytesMultiMap wh… [flink]
via GitHub
-
2026/08/27
Re: [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-37441] Rename `factoryHierarchy` to `typeHierarchy` for `TypeExtractor` [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs [flink-kubernetes-operator]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40416][runtime] Add built-in text AI functions [flink-cdc]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs [flink-kubernetes-operator]
via GitHub
-
2026/08/27
Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs [flink-kubernetes-operator]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs [flink-kubernetes-operator]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs [flink-kubernetes-operator]
via GitHub
-
2026/08/27
[jira] [Comment Edited] (FLINK-40381) Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close
Wenjin Xie (Jira)
-
2026/08/27
[jira] [Resolved] (FLINK-40381) Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close
Wenjin Xie (Jira)
-
2026/08/27
Re: [PR] [FLINK-40445] Autoscaler: integration test for Kafka/Pulsar source partition-metric detection [flink-kubernetes-operator]
via GitHub
-
2026/08/27
[jira] [Updated] (FLINK-40445) Autoscaler: integration test for Kafka/Pulsar source partition-metric detection
ASF GitHub Bot (Jira)
-
2026/08/27
[jira] [Updated] (FLINK-40381) Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close
Wenjin Xie (Jira)
-
2026/08/27
Re: [PR] [FLINK-40381] Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close [flink-connector-elasticsearch]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40381] Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close [flink-connector-elasticsearch]
via GitHub
-
2026/08/27
Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents]
via GitHub
-
2026/08/27
Re: [PR] [FLINK-40465] Add version-independent classes to parse job config [flink-kubernetes-operator]
via GitHub
-
2026/08/27
[jira] [Commented] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty
Efrat Levitan (Jira)
-
2026/08/27
[jira] [Commented] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x
Martijn Visser (Jira)
-
2026/08/27
[jira] [Updated] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x
Martijn Visser (Jira)
-
2026/08/27
[jira] [Commented] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy
Josh Keegan (Jira)