Messages by Thread
-
[jira] [Created] (FLINK-39693) Bump jackson, log4j, assertj to address CVEs
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-39692) Several catch blocks log the message but discard the captured exception
Pavel Zeger (Jira)
-
[jira] [Created] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules
Pavel Zeger (Jira)
-
[jira] [Created] (FLINK-39690) Use imgae from official hugo images
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39689) Standardize the place holders characters used in http-generic-json-url query creator to use {{ and }}
David Radley (Jira)
-
CVE-2026-35194: Apache Flink: Remote code execution via SQL injection in code generation
Martijn Visser
-
[DISCUSS] FLIP-579: LATERAL SNAPSHOT Join
Fabian Hueske
-
[ANNOUNCE] Apache Flink 2.2.1 released
Sergey Nuyanzin
-
[jira] [Created] (FLINK-39688) Share a single PluginManager across operator and webhook startup
Dennis-Mircea Ciupitu (Jira)
-
[NOTICE] Removal of Apache Flink 1.13.0-1.13.5 from PyPI
Sergey Nuyanzin
-
[jira] [Created] (FLINK-39686) URI used as URL in SessionContext causes ArrayStoreException
wangzhao (Jira)
-
[jira] [Created] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException
wangzhao (Jira)
-
[jira] [Created] (FLINK-39685) Redact sensitive options in SHOW CREATE and DESCRIBE CATALOG statements
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-39684) YAML PaimonWriter throws NullPointerException when handling REPLACE event
Xiqian Yu (Jira)
-
[jira] [Created] (FLINK-39683) Publish the flink-cdc-dist jar to the Maven repository
melin (Jira)
-
[jira] [Created] (FLINK-39682) Unable to invoke TO_DATE with TIMESTAMP types
Xiqian Yu (Jira)
-
[jira] [Created] (FLINK-39681) Bump flink to 2.2.1
Fan Deng (Jira)
-
[VOTE] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native)
Samrat Deb
-
[VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1
Ferenc Csaky
-
[jira] [Created] (FLINK-39680) Enable unaligned checkpoint for pointwise connection by FORCE_UNALIGNED
Gen Luo (Jira)
-
[jira] [Created] (FLINK-39679) Error with implicit casting
Alan Sheinberg (Jira)
-
[jira] [Created] (FLINK-39678) Connection factory discovery through SPI
Hao Li (Jira)
-
[jira] [Created] (FLINK-39677) ARRAY_SORT fails at runtime with "Comparison method violates its general contract!" on arrays with duplicate elements
Jim Hughes (Jira)
-
[jira] [Created] (FLINK-39676) Add documentation for specifying Query Creators
Nic Townsend (Jira)
-
[jira] [Created] (FLINK-39675) http-generic-json-url query param configuration not required.
David Radley (Jira)
-
[jira] [Created] (FLINK-39674) flink-avro-confluent-registry uses an obsolete schema registry client
Alex Rovner (Jira)
-
[DISCUSS] FLIP-578: In-place Table to Materialized Table conversion
Ramin Gharib
-
[jira] [Created] (FLINK-39673) SQL jobs may ignore user-configured claim mode with deprecated config key
Han Yin (Jira)
-
[SUMMARY] Release 2.3 SYNC: In Creating RC0 and Cross-team Testing
Yuepeng Pan
-
[jira] [Created] (FLINK-39672) Update doc about Java Records
Mingliang Liu (Jira)
-
[VOTE] Release flink-connector-kafka v5.0.0, release candidate #1
Ferenc Csaky
-
[jira] [Created] (FLINK-39671) Adopt jackson-bom in flink-model-triton for unified version management
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-39670) Bump Flink-controlled Java dependencies to resolve CVEs Part 2 (kafka-clients, okhttp, zookeeper, wiremock)
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-39669) BatchPhysicalCorrelateRule / StreamPhysicalCorrelateRule drop right-side projection when a Calc sits between Correlate and TableFunctionScan
Venkata krishnan Sowrirajan (Jira)
-
[DISCUSS] Status of the Azure CI → GitHub Actions migration (FLINK-33901)
Michele Guerriero
-
[jira] [Created] (FLINK-39668) Add get kafka offsets SQL table function
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-39667) NGINX Ingress Retirement
Dominik (Jira)
-
[jira] [Created] (FLINK-39666) Fix TO_TIMESTAMP_LTZ multiple edge-case bugs in precision handling
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39665) Support ALTER MATERIALIZED TABLE ... SET REFRESH_MODE = FULL | CONTINUOUS conversion
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39664) Support ALTER MATERIALIZED TABLE ... SET FRESHNESS = ... conversion
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39663) Support ALTER MATERIALIZED TABLE ... RESET ('k') conversion
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39662) Support ALTER MATERIALIZED TABLE ... SET ('k' = 'v') conversion
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39661) Support all converters for standalone ALTER MATERIALIZED TABLE statements
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39660) Kinesis Connector - Cascading failure in EFO subscription lifecycle
Chenyuan Lee (Jira)
-
[jira] [Created] (FLINK-39658) Upgrade flink-connector-hive from Flink 2.0-preview1 to Flink 2.0.x
Jayesh Lalwani (Jira)
-
[jira] [Created] (FLINK-39657) Migrate CatalogTable.of() to CatalogTable.newBuilder()
Jayesh Lalwani (Jira)
-
[jira] [Created] (FLINK-39659) Add JDK 17 test support with proper --add-opens documentation
Jayesh Lalwani (Jira)
-
[jira] [Created] (FLINK-39656) Remove legacy getTableFactory() override
Jayesh Lalwani (Jira)
-
[jira] [Created] (FLINK-39655) Remove deprecated CatalogLock and ManagedTable APIs (FLIP-346)
Jayesh Lalwani (Jira)
-
[RESULT][VOTE] Release 2.2.1, release candidate #3
Sergey Nuyanzin
-
[ANNOUNCE] Apache Flink 2.1.2 released
Sergey Nuyanzin
-
[jira] [Created] (FLINK-39654) Add JDK 25 CI test lane
Junqing Li (Jira)
-
[jira] [Created] (FLINK-39653) [Connectors/Opensearch] Move to Flink to 2.0.0 - Fix Violations of ArchUnit architecture rule enforced in Flink 2.x
Taranpreet Kaur (Jira)
-
[RESULT][VOTE] Release 2.1.2, release candidate #2
Sergey Nuyanzin
-
[ANNOUNCE] Apache Flink 2.0.2 released
Sergey Nuyanzin
-
[jira] [Created] (FLINK-39652) Improve documentation for regexp functions
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39651) REGEXP predicate does not validate literal regex patterns at plan time and logs errors on the hot path
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39650) REGEXP_REPLACE does not validate literal regex patterns at plan time, recompiles per record, and logs errors on the hot path
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39649) REGEXP_EXTRACT plan-time validation and hot-path log cleanup
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39648) Validate literal regex patterns at plan time and stop logging on the hot path for the regex function family
Ramin Gharib (Jira)
-
[DISSCUSS] FLIP-XXX: Async MongoDB Sink with Error Classification and Shared Connection Pool
FeatZhang
-
[jira] [Created] (FLINK-39647) Upgrade presto hive
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39646) Update flink-python-example to Flink 2.2
Aleksandr Savonin (Jira)
-
[jira] [Created] (FLINK-39645) HybridSourceReader.snapshotState() loses recovered splits when currentReader is null
Chen Zhang (Jira)
-
[jira] [Created] (FLINK-39644) Upgrade aws sdk version to 2.44.x to add enhanced S3 Transfer Manager performance
Samrat Deb (Jira)
-
[RESULT][VOTE] Release 2.0.2, release candidate #4
Sergey Nuyanzin
-
[jira] [Created] (FLINK-39643) [docs] Fix and improve MongoDB connector documentation
featzhang (Jira)
-
[jira] [Created] (FLINK-39642) Fix Illegal argument error message
Samrat Deb (Jira)
-
[DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer
zihao chen
-
[DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer
zihao chen
-
[jira] [Created] (FLINK-39641) Fix unstable position of the Rescales tab
Yuepeng Pan (Jira)
-
[jira] [Created] (FLINK-39640) Bump Flink 1.20.0 to 1.20.3 and upgrade maven-shade-plugin to 3.6.0
Jayesh Lalwani (Jira)
-
[jira] [Created] (FLINK-39639) Split assignment accepted after source finished reading leads to silent data loss
Piotr Nowojski (Jira)
-
Help Needed for Release2.3: Confirm Cross-Team Testing for FLINK-39464 & FLINK-39461
Yuepeng Pan
-
[jira] [Created] (FLINK-39638) Make codegen reuse result of JSON parse in JSON_VALUE, JSON_QUERY
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39637) Filter push-down for the savepoint table connector
Ilya Soin (Jira)
-
[jira] [Created] (FLINK-39636) Add "produces_full_deletes" parameter in TO_CHANGELOG
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39635) [security] Support comma-separated list in security.ssl.protocol
Imre Balassa (Jira)
-
[jira] [Created] (FLINK-39634) Savepoint Table API connector incorrectly infers map state key type
Ilya Soin (Jira)
-
[jira] [Created] (FLINK-39633) PostgreSQL CDC backfill throws NullPointerException when WAL stream carries records for other captured tables
Di Wu (Jira)
-
[jira] [Created] (FLINK-39632) Add fromChangelog() / toChangelog() convenience methods to PartitionedTable
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39631) Integrate GPU sidecar inference with Table/SQL and provide end-to-end example
featzhang (Jira)
-
[jira] [Created] (FLINK-39628) Implement asynchronous batched inference RPC in GPU sidecar
featzhang (Jira)
-
[jira] [Created] (FLINK-39625) Support GPU-based model inference via sidecar/actor pattern
featzhang (Jira)
-
[jira] [Created] (FLINK-39627) Introduce flink-gpu-sidecar module with service skeleton
featzhang (Jira)
-
[jira] [Created] (FLINK-39626) Extend ResourceProfile to declare GPU resources on TaskManager
featzhang (Jira)
-
[jira] [Created] (FLINK-39629) Add Async I/O operator that invokes GPU sidecar from DataStream API
featzhang (Jira)
-
[jira] [Created] (FLINK-39630) Schedule GPU-affinity operators via ResourceManager
featzhang (Jira)
-
[jira] [Created] (FLINK-39624) `TtlListState.asyncGet()` returns a non-null wrapper around a null inner iterator, causing NPE in `onNext`/`isEmpty` when the state is empty
Jira
-
[jira] [Created] (FLINK-39623) Strict UTF-8 validation in CAST(BYTES AS STRING)
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39622) [postgres] CustomPostgresSchema re-reads JDBC metadata for every split, causing O(N²) snapshot startup
Jira
-
[VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2
Gyula Fóra
-
[jira] [Created] (FLINK-39621) Incremental-snapshot based sources may get stuck in binlog-backfill stage
Xiqian Yu (Jira)
-
[jira] [Created] (FLINK-39620) Cumulative window re-emits old windows after recovery due to stale InternalTimerService.currentWatermark in GlobalAggCombiner
haiqingchen (Jira)
-
[jira] [Created] (FLINK-39619) Add release note for flink 2.3 release
Hao Li (Jira)
-
[jira] [Created] (FLINK-39618) FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Created] (FLINK-39617) Add batch REST endpoints for aggregated subtask metrics across multiple job vertices
Herbert Wang (Jira)
-
[FLINK-30514] Review request for HybridSourceReader bug fix
yun . er . run
-
[jira] [Created] (FLINK-39616) Add instructions on how to fix ordering with ORDER BY when using FROM_CHANGELOG
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39615) Translate documentation in changelog.md to chinese
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39614) Support TO_CHANGELOG: retract stream -> retract stream with set semantics
Gustavo de Morais (Jira)
-
[ANNOUNCE] New Apache Flink PMC Member – David Anderson
Timo Walther
-
[ANNOUNCE] Apache Flink 1.20.4 released
Sergey Nuyanzin
-
[jira] [Created] (FLINK-39613) Flink pipeline cdc primary-keys / partition-keys cannot resolve backtick-quoted identifiers that are used as projection aliases
Ran Tao (Jira)
-
[jira] [Created] (FLINK-39612) [Model] Add HTTP connection pool management for Triton inference
featzhang (Jira)
-
[jira] [Created] (FLINK-39611) [Model] Add sequence ID auto-increment support for Triton inference
featzhang (Jira)
-
[jira] [Created] (FLINK-39610) Mongo CDC connector supports specifying SSL context
Xiqian Yu (Jira)
-
[SUMMARY] Release 2.3 sync, blocked on cross-team testing
David Anderson
-
[jira] [Created] (FLINK-39609) update Dynamic Kafka Source doc with new python/sql examples and other improvement details
Bowen Li (Jira)
-
Hackathon at Community Over Code Glasgow — is Flink interested?
Rich Bowen
-
[jira] [Created] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage
Swapna Marru (Jira)
-
[jira] [Created] (FLINK-39607) Add right Nullable annotation and precondition for config
Samrat Deb (Jira)
-
[DISCUSS] Release flink-connector-pulsar for Flink 1.20
Ferenc Csaky
-
[DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native)
Samrat Deb
-
[jira] [Created] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses
Ramin Gharib (Jira)
-
[DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators
Soumitra Kumar
-
[jira] [Created] (FLINK-39605) Implement Avro Variant Confluent format for dynamic schema deserialization
Swapna Marru (Jira)
-
[DISCUSS] Request for help with publishing docker images
Sergey Nuyanzin
-
[jira] [Created] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields
Natea Eshetu Beshada (Jira)
-
[jira] [Created] (FLINK-39603) Optimize NativeS3InputStream via seeks and reduce IOPS
Samrat Deb (Jira)
-
[jira] [Created] (FLINK-39602) Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39601) Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities
Gustavo de Morais (Jira)
-
[DISCUSS] FLINK-25672: FileSource enumerator remembers paths of all already processed files
Sophia Izokun via dev
-
[VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool
Aleksandr Savonin
-
[RESULT] [VOTE] Release 1.20.4, release candidate #1
Sergey Nuyanzin
-
[VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1
Gyula Fóra
-
[jira] [Created] (FLINK-39599) Expose pendingRecords metrics in FLINK Kinesis Connector
David (Jira)
-
[jira] [Created] (FLINK-39598) Update jline to 3.30.9
Sergey Nuyanzin (Jira)
-
[VOTE] Release 2.1.2, release candidate #2
Sergey Nuyanzin