dev  

Messages by Thread

• [jira] [Created] (FLINK-39177) Add Flink 2.2 to operator e2es and bump example flink versions Gyula Fora (Jira)
• [jira] [Created] (FLINK-39176) Introduce Node Health Management & Quarantine Framework for ResourceManager featzhang (Jira)
• [jira] [Created] (FLINK-39175) Support calc that contains non-deterministic after delta join Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-39174) Support lookup join after delta join Xuyang Zhong (Jira)
• [DISCUSS] Node Health Management and Quarantine Framework in Flink FeatZhang
• [jira] [Created] (FLINK-39173) Support application-level blob storage Yi Zhang (Jira)
• [jira] [Created] (FLINK-39172) Flink Bash Scripts don't support the new yaml 1.2 syntax when reading from config.yaml Ryan van Huuksloot (Jira)
• [jira] [Created] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns tianfy (Jira)
• [jira] [Created] (FLINK-39170) [Table/SQL] Add async batch lookup join optimization for temporal table joins featzhang (Jira)
• [DISCUSS] FLINK-17224: Fix time precision data loss when setting TIME(X) Ramin Gharib
• [jira] [Created] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots in clustered instances Luca Occhipinti (Jira)
• [jira] [Created] (FLINK-39168) improve mysql’s snapshot-split Thorne (Jira)
• [jira] [Created] (FLINK-39167) Initialize source output before emitting final watermark Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-39166) Add bucket level config parity Samrat Deb (Jira)
• [jira] [Created] (FLINK-39165) Concurrent FlinkDeployment and FlinkSessionJob upgrades lead to savepoint failure and state loss Ihor Mielientiev (Jira)
• [jira] [Created] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit Yi Zhang (Jira)
• [jira] [Created] (FLINK-39163) Support ML_PREDICT in Flink Python API Biao Geng (Jira)
• [jira] [Created] (FLINK-39162) The data of the custom partitioner is corrupted during unaligned checkpoint Rui Fan (Jira)
• [jira] [Created] (FLINK-39161) INTERVAL WEEK, QUARTER has wron math Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics Arun Lakshman (Jira)
• [SUMMARY] Flink 2.3 release sync 24-02-2026 David Anderson
• [jira] [Created] (FLINK-39159) Using KeyedProcessFunction in batch mode reads events out of order Grzegorz Liter (Jira)
• [jira] [Created] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39157) ColumnList has no hashCode/equals Timo Walther (Jira)
• [jira] [Created] (FLINK-39156) Document the changes Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-39155) Add a check watermarks are defined in source for ERROR/NOTHING Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-39154) [Table]Support Async Batch Lookup Join (with Calc) for Temporal Table Join featzhang (Jira)
• [jira] [Created] (FLINK-39153) Add comprehensive performance metrics for PyFlink Liu (Jira)
• [DISCUSS][Table/SQL] Align Built-in Aggregate Function Type Support with ANSI SQL Standard FeatZhang
• [jira] [Created] (FLINK-39152) The FlussConfig Utils class is not in the correct directory and does not have a private instance Thorne (Jira)
• [jira] [Created] (FLINK-39151) Hide warning about UnixOperatingSystemMXBean missing on Windows Piotr Przybylski (Jira)
• [jira] [Created] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Piotr Przybylski (Jira)
• [jira] [Created] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication Jia Fan (Jira)
• [jira] [Created] (FLINK-39148) Update flink-connector-kafka & flink-sql-connector-kafka to 4.0.1-2.0 Cameron (Jira)
• [jira] [Created] (FLINK-39147) Update Guava to 32.0.1 Cameron (Jira)
• [jira] [Created] (FLINK-39146) Update log4j to 2.25.3 Cameron (Jira)
• [jira] [Created] (FLINK-39145) UnalignedCheckpointITCase.execute fails - Could not acquire the minimum required resources. Efrat Levitan (Jira)
• [jira] [Created] (FLINK-39144) fix IOManager not close peiyu (Jira)
• [jira] [Created] (FLINK-39143) fluss‘s connection use connection pool be better Thorne (Jira)
• [jira] [Created] (FLINK-39142) Support AWS Glue Schema Registry Protobuf for Table API Francisco Morillo (Jira)
• [jira] [Created] (FLINK-39141) Support AWS Glue Schema Registry JSON for Table API Francisco Morillo (Jira)
• [jira] [Created] (FLINK-39140) Enhance Unaligned Checkpoint ITCases to perform checkpointing during recovery Rui Fan (Jira)
• [jira] [Created] (FLINK-39139) Update lz4-java to 1.10.3 Cameron (Jira)
• [jira] [Created] (FLINK-39138) Update Flink Connector Kafka to Flink Connector Parent POM 2.0 Thomas Cooper (Jira)
• [jira] [Created] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Andreas Bube (Jira)
• [jira] [Created] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Jon Chase (Jira)
• [jira] [Created] (FLINK-39135) Backport GSBlobStorageImpl precondition check to 1.20.4 Jon Chase (Jira)
• [jira] [Created] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky Martijn Visser (Jira)
• [DISCUSS] Support for multi-split multi-threaded readers in connector framework abhi Gupta
• [jira] [Created] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception Martijn Visser (Jira)
• [jira] [Created] (FLINK-39132) 'kubernetes Materialized Table test' failed because it could not not stop job Martijn Visser (Jira)
• [RESULT][VOTE] FLIP-555: Flink Native S3 FileSystem Samrat Deb
• [DISCUSS] flink 2.3 release: add or update features in release wiki Hao Li via dev
• [jira] [Created] (FLINK-39131) Multi-Input Processors Salva (Jira)
• [jira] [Created] (FLINK-39130) Allow native types to be used for MetricConfig Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-39129) Support native types in MetricConfig Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-39128) DynamoDB CDC source connector millisBehindLatest metric gets stuck after failover Emre Kartoglu (Jira)
• [jira] [Created] (FLINK-39126) Support exporting metrics through grpc in batches Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-39127) Support exported metrics attributes truncation rules Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-39125) Support injective casts from CHAR/VARCHAR to BINARY/VARBINARY for upsert key preservation Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39124) [JUnit5 Migration] Module: flink-tests Mate Czagany (Jira)
• [jira] [Created] (FLINK-39123) ValueLiteralExpression.asSerializableString has problems with TIMESTAMP_LTZ(3) Timo Walther (Jira)
• [jira] [Created] (FLINK-39122) Decimals with incorrect precision lead to null value in PTF Timo Walther (Jira)
• [jira] [Created] (FLINK-39121) kafka connector CI test timeout due to "/tmp/testcontainers_start.sh: Text file busy" Efrat Levitan (Jira)
• [jira] [Created] (FLINK-39120) Update to Kafka 4.2.0 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-39119) Add flink-s3-fs-native as part of flink dist in /opt Samrat Deb (Jira)
• [jira] [Created] (FLINK-39118) Add Documentation for native s3 fs Samrat Deb (Jira)
• [jira] [Created] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-39116) Improve batch wait time using threadpool Samrat Deb (Jira)
• [jira] [Created] (FLINK-39115) create URI Handling Utility Samrat Deb (Jira)
• [jira] [Created] (FLINK-39114) Add configurable timeout Samrat Deb (Jira)
• [jira] [Created] (FLINK-39113) Add Encryption context support Samrat Deb (Jira)
• [jira] [Created] (FLINK-39112) Support MultiPart Upload in NativeS3OutputStream Samrat Deb (Jira)
• [jira] [Created] (FLINK-39111) Alter NativeS3AccessHelper Interface to NativeS3ObjectOperations Samrat Deb (Jira)
• [jira] [Created] (FLINK-39109) [Phase 2] Native s3 Filesystem Samrat Deb (Jira)
• [jira] [Created] (FLINK-39110) Add CRT Support Samrat Deb (Jira)
• [jira] [Created] (FLINK-39108) CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is unstable on AZP Roman Khachatryan (Jira)
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.14.0 released Gyula Fóra
• [jira] [Created] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image Martijn Visser (Jira)
• [jira] [Created] (FLINK-39106) Support ROW and ARRAY<ROW> data types in DynamoDB Table API / SQL sink Jira
• [ANNOUNCE] Apache flink-connector-parent 2.0.0 released Ferenc Csaky
• [jira] [Created] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception Martijn Visser (Jira)
• [VOTE] FLIP-555: Flink Native S3 FileSystem Samrat Deb
  • Re: [VOTE] FLIP-555: Flink Native S3 FileSystem Piotr Nowojski
  • Re: [VOTE] FLIP-555: Flink Native S3 FileSystem Gabor Somogyi
  • Re: [VOTE] FLIP-555: Flink Native S3 FileSystem Ferenc Csaky
  • Re: [VOTE] FLIP-555: Flink Native S3 FileSystem Aleksandr Iushmanov
  • Re: [VOTE] FLIP-555: Flink Native S3 FileSystem Samrat Deb
• [jira] [Created] (FLINK-39104) Allow enabling gzip compression for OTel gRPC/HTTP exporters Aleksandr Iushmanov (Jira)
• PR builds failing David Radley
  • Re: PR builds failing Ferenc Csaky
  • RE: PR builds failing David Radley
  • Re: PR builds failing Martijn Visser
• [jira] [Created] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-39102) All E2E Kubernetes tests fail on Azure CI Martijn Visser (Jira)
• [jira] [Created] (FLINK-39101) Rationalize the pom file versions and exclusions David Radley (Jira)
• [jira] [Created] (FLINK-39100) DynamoDB source connector fails to renew AWS IAM credentials Emre Kartoglu (Jira)
• [jira] [Created] (FLINK-39099) Update testcontainers to 1.21.4 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-39098) Fix connector CI failures caused by testcontainers using too old Docker API Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-39097) [e2e-Test]Run kubernetes SQL application test failure Samrat Deb (Jira)
• [DISCUSS] FLIP-565: Improve ProcessTableFunctions for late data handling and state access Timo Walther
• [jira] [Created] (FLINK-39096) [SQL]Enhance EXPLAIN output to display detailed estimated rowcount and cost information featzhang (Jira)
• [jira] [Created] (FLINK-39095) [SQL] Display ChangelogMode in Execution Plan for Streaming Queries featzhang (Jira)
• [jira] [Created] (FLINK-39094) Avoid creating duplicate function instances in code generation dylanhz (Jira)
• [jira] [Created] (FLINK-39093) [SQL] Display ChangelogMode in Execution Plan for Streaming Queries featzhang (Jira)
• [jira] [Created] (FLINK-39092) [SQL] Enhance EXPLAIN plan to display watermark specification featzhang (Jira)
• [jira] [Created] (FLINK-39091) [SQL] Enhance structured filter condition display of Explain output featzhang (Jira)
• [jira] [Created] (FLINK-39090) [SQL] Enhanced join condition structured display featzhang (Jira)
• [jira] [Created] (FLINK-39089) [Table] Enhanced projection field alias display featzhang (Jira)
• [jira] [Created] (FLINK-39088) Preserve upsert keys for explicit (injective) CAST calls to avoid unnecessary SinkUpsertMaterializer Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39087) Upgrade wiremock in the HTTP connector David Radley (Jira)
• [jira] [Created] (FLINK-39086) BlobServer returns unresolvable pod hostname in Kubernetes HA mode, breaking job submission (Regression from 1.20) Sebastien Pereira (Jira)
• [DISCUSS] FLIP-566: Introduce a new NO UPDATE column constraint Xuyang
  • Re: [DISCUSS] FLIP-566: Introduce a new NO UPDATE column constraint Gustavo de Morais
  • Re:Re: [DISCUSS] FLIP-566: Introduce a new NO UPDATE column constraint Xuyang
  • Re: Re: [DISCUSS] FLIP-566: Introduce a new NO UPDATE column constraint Gustavo de Morais
  • Re:Re: Re: [DISCUSS] FLIP-566: Introduce a new NO UPDATE column constraint Xuyang
• [jira] [Created] (FLINK-39085) Potential task duplication in the same TM slot after JM failover Yi Zhang (Jira)
• [jira] [Created] (FLINK-39084) Variant Field accesor helper methods Swapna Marru (Jira)
• [jira] [Created] (FLINK-39083) Support field-level error tolerance for CSV format deserialization Liu (Jira)
• [jira] [Created] (FLINK-39082) Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor (Jira)
• [jira] [Created] (FLINK-39081) FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor (Jira)
• [RESULT][VOTE] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor
• [jira] [Created] (FLINK-39080) Missing license undetected by connector CI Efrat Levitan (Jira)
• [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Gyula Fóra
• [jira] [Created] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
• [DISCUSS] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility Sebastien Pereira
  • Re: [DISCUSS] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility Gabor Somogyi
• [jira] [Created] (FLINK-39078) Disallow ON CONFLICT for non upsert sinks Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39076) [web ui] Display slot sharing group in operator nodes in Flink Web UI featzhang (Jira)
• [jira] [Created] (FLINK-39075) fn_execution test collection fails in test_flink_fn_execution_pb2.py Samrat Deb (Jira)
• [jira] [Created] (FLINK-39074) Add built-in AI model inference capability to PyFlink with automatic lifecycle management featzhang (Jira)
• [DISCUSS] FLIP-562: Improve ProcessTableFunctions for late data handling and state access Timo Walther
  • Re: [DISCUSS] FLIP-562: Improve ProcessTableFunctions for late data handling and state access Timo Walther
• [jira] [Created] (FLINK-39073) Idle source splits are picked by watermark alignment Efrat Levitan (Jira)
• [jira] [Created] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter Natea Eshetu Beshada (Jira)
• [jira] [Created] (FLINK-39071) Select fileds rathert * to read snapshot data incase schema changes. Hongshun Wang (Jira)
• [jira] [Created] (FLINK-39070) Update Kafka parent connector David Radley (Jira)
• [jira] [Created] (FLINK-39069) [SQL Client] Support saving and exporting SQL execution history featzhang (Jira)
• [jira] [Created] (FLINK-39068) [SQL Client] Support saving and exporting SQL execution history featzhang (Jira)
• [Discussion] Syncing Connector Release Cycles with Flink 2.x Joao Boto
  • Re: [Discussion] Syncing Connector Release Cycles with Flink 2.x Ferenc Csaky
  • Re: [Discussion] Syncing Connector Release Cycles with Flink 2.x Martijn Visser
  • Re: [Discussion] Syncing Connector Release Cycles with Flink 2.x Ferenc Csaky
  • Re: [Discussion] Syncing Connector Release Cycles with Flink 2.x João Boto
• [jira] [Created] (FLINK-39067) Move Python docs to PyDocs Martijn Visser (Jira)
• [jira] [Created] (FLINK-39066) fix fluss conector 's FlussHistogram always return null Thorne (Jira)
• [jira] [Created] (FLINK-39065) Support additional CsvParser.Feature options for CSV format deserialization Liu (Jira)
• [jira] [Created] (FLINK-39064) Add built-in REGEXP_SPLIT function to split string by regular expression pattern Liu (Jira)
• [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Timo Walther
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Lincoln Lee
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Gyula Fóra
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Timo Walther
• [jira] [Created] (FLINK-39063) FIx some spelling mistake in fluss connector Thorne (Jira)
• [jira] [Created] (FLINK-39062) Support Watermark Definition in SQL Views featzhang (Jira)
• [jira] [Created] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility and version upgrade workflow Sebastien Pereira (Jira)
• [jira] [Created] (FLINK-39060) Bump Java depencies to resolve CVEs Cameron (Jira)
• [RESULT][VOTE] Release flink-connector-parent v2.0.0, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-39059) Add unified metrics support to AsyncPredictFunction and PredictFunction featzhang (Jira)
• Re: Follow-up on JIRA Account Request for Apache Flink Leonard Xu
• [jira] [Created] (FLINK-39058) Use Preconditions#checkArgument to replace raw condition validation in model-triton module Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39057) [JUnit5 Migration] Migrate assertion lines to assertj for flink-model-triton module Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39056) Duplicate Data Issue in Iceberg Sink During Two-Phase Commit ChaoFang (Jira)
• [DISCUSS] FLINK-37908: Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts Jonathan Du via dev
• [jira] [Created] (FLINK-39055) [iceberg] Support default column values in Iceberg sink connector suhwan (Jira)
• [jira] [Created] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers Bowen Li (Jira)
• [Discuss] ​​FLIP-XXX: Language Server Protocol Support for Flink SQL Gateway Ryan van Huuksloot via dev
  • Re: [Discuss] ​​FLIP-XXX: Language Server Protocol Support for Flink SQL Gateway Őrhidi Mátyás
• [VOTE] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Mika Naylor
  • Re: [VOTE] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Zander Matheson
  • Re: [VOTE] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Martijn Visser
  • Re: [VOTE] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Yuepeng Pan
  • Re: [VOTE] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Timo Walther
  • Re: [VOTE] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Natea Eshetu Beshada via dev
  • Re: [VOTE] FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Sergey Nuyanzin
• [DISCUSS] FLIP-XXX: Supports to pass the required privilege when catalog manager gets the table roryqi
  • Re:[DISCUSS] FLIP-XXX: Supports to pass the required privilege when catalog manager gets the table Xuyang
  • Re: [DISCUSS] FLIP-XXX: Supports to pass the required privilege when catalog manager gets the table roryqi
  • Re: [DISCUSS] FLIP-XXX: Supports to pass the required privilege when catalog manager gets the table Leonard Xu
  • Re: [DISCUSS] FLIP-XXX: Supports to pass the required privilege when catalog manager gets the table roryqi
  • Re: [DISCUSS] FLIP-XXX: Supports to pass the required privilege when catalog manager gets the table Leonard Xu
  • Re: [DISCUSS] FLIP-XXX: Supports to pass the required privilege when catalog manager gets the table roryqi
• [jira] [Created] (FLINK-39053) AvroTypeException when writing Flink VARCHAR to Avro ENUM in Kafka avro-confluent format Jira
• [DISCUSS] Dependency Updates Cameron Scholes
  • Re: [DISCUSS] Dependency Updates Ferenc Csaky
  • RE: Re: [DISCUSS] Dependency Updates Cameron Scholes
  • [DISCUSS] Dependency Updates Cameron Scholes
• [jira] [Created] (FLINK-39052) ModuleNotFoundError: No module named 'pkg_resources' Dian Fu (Jira)
• [jira] [Created] (FLINK-39051) Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF Liu (Jira)
• [jira] [Created] (FLINK-39050) Support configurable handling strategy for null rowtime field in watermark generation Liu (Jira)
• [jira] [Created] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant Jinkun Liu (Jira)
• [jira] [Created] (FLINK-39048) [iceberg] Upgrade iceberg-flink-runtime from 1.19 to 1.20 to align with Flink 1.20.x suhwan (Jira)
• [jira] [Created] (FLINK-39047) Translate the Chinese documentation related to Transform Jia Fan (Jira)
• [jira] [Created] (FLINK-39046) [docs] Incorrect Hugo ref syntax in Kinesis documentation featzhang (Jira)
• [jira] [Created] (FLINK-39045) [docs] Add automatic fix for Hugo ref syntax errors in connector docs featzhang (Jira)
• [jira] [Created] (FLINK-39044) Optimize BinaryStringData.copy() to return this for immutable strings Natea Eshetu Beshada (Jira)
• [DISCUSS] FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Gustavo de Morais

• Earlier messages