issues
Thread
Date
Earlier messages
Messages by Date
2026/05/05
Re: [PR] [hotfix][docs] Bump externalized connector docs refs to latest minor releases [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-38544] Allocate pre-filter source buffers from heap in filtering mode [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http]
via GitHub
2026/05/05
Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http]
via GitHub
2026/05/05
Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http]
via GitHub
2026/05/05
Re: [PR] [FLINK-39529][table] Add SQL-to-operator lifecycle and restructure planner AGENTS.md [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39540][Connectors/Kinesis][5.1] Addressed bugs for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/05/05
Re: [PR] [FLINK-39540][Connectors/Kinesis][5.1] Addressed bugs for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/05/05
Re: [PR] [FLINK-39540][Connectors/Kinesis][5.1] Addressed bugs for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/05/05
Re: [PR] [FLINK-39540][Connectors/Kinesis][5.1] Addressed bugs for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/05/05
Re: [PR] [FLINK-39540][Connectors/Kinesis][5.1] Addressed bugs for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
2026/05/05
Re: [PR] [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39106] Support ROW and ARRAY<ROW> data types in DynamoDB API / SQL sink [flink-connector-aws]
via GitHub
2026/05/05
Re: [PR] [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow [flink]
via GitHub
2026/05/05
Re: [PR] [hotfix][docs] Fix inaccurate description of slot sharing benefit [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink]
via GitHub
2026/05/05
[jira] [Updated] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses
ASF GitHub Bot (Jira)
2026/05/05
Re: [PR] [FLINK-39527][test] Migrate flink-end-to-end-tests to JUnit 5 [flink]
via GitHub
2026/05/05
[PR] [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow [flink]
via GitHub
2026/05/05
[jira] [Created] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses
Ramin Gharib (Jira)
2026/05/05
Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39036][formats] Honor microsecond Avro logical types in RowDataToAvroConverters [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39036][formats] Honor microsecond Avro logical types in RowDataToAvroConverters [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-14621][flink-table-planner] Do not generate watermark assigner operator if no time attribute operations on rowtime [flink]
via GitHub
2026/05/05
Re: [PR] [hotfix][ci] Ignore GHA build on non-code changes [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/05
Re: [PR] Add April 2026 Flink community update blog post [flink-web]
via GitHub
2026/05/05
Re: [PR] [FLINK-39577][table] Reuse Calcite's `COALESCE` to apply simplifications from `RexSimplify` [flink]
via GitHub
2026/05/05
Re: [PR] [hotfix][docs] Fix inaccurate description of slot sharing benefit [flink]
via GitHub
2026/05/05
[jira] [Commented] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI
Shekhar Prasad Rajak (Jira)
2026/05/05
Re: [PR] [hotfix] Fix flaky tests [flink]
via GitHub
2026/05/05
Re: [PR] [hotfix] Fix flaky tests [flink]
via GitHub
2026/05/05
Re: [PR] [hotfix] Fix flaky tests [flink]
via GitHub
2026/05/05
Re: [PR] [hotfix] Fix flaky tests [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-38579] [table-planner] Fix incorrect UB drop for filter on non-upsert key [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-39577][table] Reuse Calcite's `COALESCE` to apply simplifications from `RexSimplify` [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
2026/05/05
Re: [PR] [FLINK-38469][python] Bump Apache Beam to 2.72 [flink]
via GitHub
2026/05/05
Re: [PR] [FLINK-34466][LINEAGE] Support dataset type facet for Avro [flink-connector-kafka]
via GitHub
2026/05/05
Re: [PR] [FLINK-34466][LINEAGE] Support dataset type facet for Avro [flink-connector-kafka]
via GitHub
2026/05/04
Re: [PR] [FLINK-39113][s3] Fix s3.sse.kms.encryption-context config in native s3 connector [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/05/04
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/05/04
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/05/04
Re: [PR] [FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39491][runtime] move lineage Listener creation to Dispatcher [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39491][runtime] move lineage Listener creation to Dispatcher [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-39605) Implement Avro Variant Confluent format for dynamic schema deserialization
ASF GitHub Bot (Jira)
2026/05/04
[PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink]
via GitHub
2026/05/04
Re: [PR] [common] Add PatternCache to optimize regex compilation performance [flink-cdc]
via GitHub
2026/05/04
[jira] [Created] (FLINK-39605) Implement Avro Variant Confluent format for dynamic schema deserialization
Swapna Marru (Jira)
2026/05/04
Re: [PR] [FLINK-39585][runtime] Log execution graph creation failures at ERROR Level [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39604][table] Surface PTF metadata in DESCRIBE FUNCTION EXTENDED [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields
ASF GitHub Bot (Jira)
2026/05/04
[PR] [FLINK-39604][table] Surface PTF metadata in DESCRIBE FUNCTION EXTENDED [flink]
via GitHub
2026/05/04
[jira] [Commented] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state
Sophia Izokun (Jira)
2026/05/04
[jira] [Created] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields
Natea Eshetu Beshada (Jira)
2026/05/04
Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation
ASF GitHub Bot (Jira)
2026/05/04
[PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39113][s3] Fix s3.sse.kms.encryption-context config in native s3 connector [flink]
via GitHub
2026/05/04
Re: [PR] Update Dockerfiles for 1.20.4 release [flink-docker]
via GitHub
2026/05/04
Re: [PR] [FLINK-39603] Optimize NativeS3InputStream via seeks and reduce IOPS [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-39603) Optimize NativeS3InputStream via seeks and reduce IOPS
ASF GitHub Bot (Jira)
2026/05/04
Re: [PR] [FLINK-39603] Optimize NativeS3InputStream via seeks and reduce IOPS [flink]
via GitHub
2026/05/04
[PR] [FLINK-39603] Optimize NativeS3InputStream via seeks and reduce IOPS [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39170][Table/SQL] Add async batch lookup join optimization for temporal table joins [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39170][Table/SQL] Add async batch lookup join optimization for temporal table joins [flink]
via GitHub
2026/05/04
Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.25.0 to 2.25.3 [flink-connector-kafka]
via GitHub
2026/05/04
Re: [PR] Add GPG key for 1.20.4 release [flink-docker]
via GitHub
2026/05/04
Re: [PR] [FLINK-39089][SQL] Enhanced projection field alias display [flink]
via GitHub
2026/05/04
[jira] [Created] (FLINK-39603) Optimize NativeS3InputStream via seeks and reduce IOPS
Samrat Deb (Jira)
2026/05/04
Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/04
[jira] [Commented] (FLINK-39560) [PROPOSAL] Allow custom, pre-configured AWS S3 clients to be injected into new Native S3 filesystem
Samrat Deb (Jira)
2026/05/04
[PR] Update Dockerfiles for 1.20.4 release [flink-docker]
via GitHub
2026/05/04
[PR] Add GPG key for 1.20.4 release [flink-docker]
via GitHub
2026/05/04
Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-39602) Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions
ASF GitHub Bot (Jira)
2026/05/04
[PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-39601) Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API
ASF GitHub Bot (Jira)
2026/05/04
[PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39113][s3] Fix s3.sse.kms.encryption-context config in native s3 connector [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39113][s3] Fix s3.sse.kms.encryption-context config in native s3 connector [flink]
via GitHub
2026/05/04
[jira] [Created] (FLINK-39602) Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions
Gustavo de Morais (Jira)
2026/05/04
[jira] [Created] (FLINK-39601) Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API
Gustavo de Morais (Jira)
2026/05/04
[jira] [Created] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities
Gustavo de Morais (Jira)
2026/05/04
[jira] [Commented] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil
Khaled Hammouda (Jira)
2026/05/04
Re: [PR] [hotfix][docs] Fix inaccurate description of slot sharing benefit [flink]
via GitHub
2026/05/04
[jira] [Closed] (FLINK-39474) Release Testing Instructions: FLINK-37399: Watermark alignment can prevent backlogged jobs from using all available resources
Piotr Nowojski (Jira)
2026/05/04
[jira] [Commented] (FLINK-39474) Release Testing Instructions: FLINK-37399: Watermark alignment can prevent backlogged jobs from using all available resources
Piotr Nowojski (Jira)
2026/05/04
[PR] [hotfix][docs] Fix inaccurate description of slot sharing benefit [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-34620] Fix stack overflow in recursive protobuf message handling in `flink-protobuf` [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-39595) Use GHA cache per branch
Sergey Nuyanzin (Jira)
2026/05/04
[jira] [Commented] (FLINK-39595) Use GHA cache per branch
Sergey Nuyanzin (Jira)
2026/05/04
Re: [PR] [BP-1.20][FLINK-39595][ci] Use GHA cache per branch [flink]
via GitHub
2026/05/04
Re: [PR] [BP-1.20][FLINK-39595][ci] Use GHA cache per branch [flink]
via GitHub
2026/05/04
Re: [PR] Add Flink 1.20.4 release [flink-web]
via GitHub
2026/05/04
Re: [PR] Add Flink 1.20.4 release [flink-web]
via GitHub
2026/05/04
[PR] [FLINK-34620] Fix stack overflow in recursive protobuf message handling in `flink-protobuf` [flink]
via GitHub
2026/05/04
[jira] [Commented] (FLINK-39595) Use GHA cache per branch
Sergey Nuyanzin (Jira)
2026/05/04
Re: [PR] [BP-2.2][FLINK-39595][ci] Use GHA cache per branch [flink]
via GitHub
2026/05/04
Re: [PR] Add Flink 1.20.4 release [flink-web]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-20155) java.lang.OutOfMemoryError: Direct buffer memory
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-20154) Improve error messages when using CLI with wrong target
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-19895) Unify Life Cycle Management of ResultPartitionType Pipelined Family
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-19935) Supports configure heap memory of sql-client to avoid OOM
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-21408) Clarify which DataStream sources support Batch execution
Yuepeng Pan (Jira)
2026/05/04
Re: [PR] [BP-2.2][FLINK-39595][ci] Use GHA cache per branch [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39165] Prevent concurrent FlinkSessionJob / FlinkDeployment update [flink-kubernetes-operator]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-21409) Add Avro to DataTypes & Serialization docs
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18624) Document CREATE TEMPORARY TABLE
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft()
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18981) Support column comment for Hive tables
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved
Yuepeng Pan (Jira)
2026/05/04
Re: [PR] [FLINK-39113][s3] Fix s3.sse.kms.encryption-context config in native s3 connector [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-16323) Support to join a static table in streaming mode
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17539) Migrate the configuration options which do not follow the xyz.max/min pattern.
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-19254) Invalid UTF-8 start byte exception
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously
Yuepeng Pan (Jira)
2026/05/04
Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18627) Get unmatch filter method records to side output
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18567) Add Support for Azure Cognitive Search Table & SQL Connector
Yuepeng Pan (Jira)
2026/05/04
Re: [PR] [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-39595) Use GHA cache per branch
Sergey Nuyanzin (Jira)
2026/05/04
Re: [PR] [BP-2.3][FLINK-39595][ci] Use GHA cache per branch [flink]
via GitHub
2026/05/04
[jira] [Commented] (FLINK-39595) Use GHA cache per branch
Sergey Nuyanzin (Jira)
2026/05/04
Re: [PR] [FLINK-39113][s3] Fix s3.sse.kms.encryption-context config in native s3 connector [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39113][s3] Fix s3.sse.kms.encryption-context config in native s3 connector [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39113][s3] Fix s3.sse.kms.encryption-context config in native s3 connector [flink]
via GitHub
2026/05/04
Re: [PR] [BP-2.3][FLINK-39595][ci] Use GHA cache per branch [flink]
via GitHub
2026/05/04
[jira] [Resolved] (FLINK-39557) Invalid multi-release JAR for flink-shaded-jackson
Sergey Nuyanzin (Jira)
2026/05/04
[jira] [Updated] (FLINK-39557) Invalid multi-release JAR for flink-shaded-jackson
Sergey Nuyanzin (Jira)
2026/05/04
[jira] [Commented] (FLINK-39557) Invalid multi-release JAR for flink-shaded-jackson
Sergey Nuyanzin (Jira)
2026/05/04
Re: [PR] [FLINK-39557] Generate correct Multi-Release JAR files for Jackson and Swagger [flink-shaded]
via GitHub
2026/05/04
Re: [PR] [hotfix][ci] Ignore GHA build on non-code changes [flink]
via GitHub
2026/05/04
Re: [PR] [FLINK-39377][table] Add initial implementation of ProcessTableFunctionTestHarness [flink]
via GitHub
2026/05/04
[jira] [Updated] (FLINK-15859) Unify identifiers in the interface methods of CatalogManager
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-15860) Store temporary functions as CatalogFunctions in FunctionCatalog
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17826) Add missing custom query support on new jdbc connector
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17683) Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction, but not when it is a field of case class.
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17405) add test cases for cancel job in SQL client
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17535) Treat min/max as part of the hierarchy of config option
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator
Yuepeng Pan (Jira)
2026/05/04
[jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables
Yuepeng Pan (Jira)
Earlier messages