dev  

Messages by Thread

• [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
• [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
• [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
• [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
  • Re: [DISCUSS] FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Timo Walther
  • Re: [DISCUSS] FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Dawid Wysakowicz
• [jira] [Created] (FLINK-39043) UpgradeFailureException from SnapshotObserver blocks reconciliation of spec changes for FINISHED batch jobs Robert Metzger (Jira)
• [jira] [Created] (FLINK-39042) [webui] Make watermark timestamps timezone-aware and configurable featzhang (Jira)
• [jira] [Created] (FLINK-39041) Rebuild rest api docs pages to supplement the missing content. Yuepeng Pan (Jira)
• [ANNOUNCE] Apache flink-connector-aws 6.0.0 released Ferenc Csaky
• [jira] [Created] (FLINK-39040) allow additional json to be specified for the body request david radley (Jira)
• [jira] [Created] (FLINK-39039) Expose JOSDK cacheSyncTimeout as operator config junzhong qin (Jira)
• [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Samrat Deb
  • Re: [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Aleksandr Iushmanov
  • Re: [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Samrat Deb
  • Re: [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Samrat Deb
  • Re: [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Aleksandr Iushmanov
  • Re: [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Márton Balassi
  • Re: [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Ferenc Csaky
  • Re: [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Gabor Somogyi
  • Re: [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Piotr Nowojski
  • Re: [DISCUSS][FLIP-555] Introduce Native S3 FileSystem for Apache Flink Samrat Deb
• [ANNOUNCE] Apache Flink Agents 0.2.0 released Xuannan Su
• [jira] [Created] (FLINK-39038) GitHub flink-cdc repository actions clean-up Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39037) support query kafka cluster id as metadata in records of DynamicKafkaTableSource Bowen Li (Jira)
• [jira] [Created] (FLINK-39036) RowDataToAvroConverter ignores logical type when converting timestamps Grzegorz Liter (Jira)
• [jira] [Created] (FLINK-39035) Support Avro fast-read and column pruning in AvroDeserializationSchema via configuration xiaolong3817 (Jira)
• [jira] [Created] (FLINK-39034) fullWindowPartition + sortStream + STREAMING causes timestamps to be set to null Grzegorz Liter (Jira)
• [RESULT][VOTE] Release flink-connector-aws v6.0.0, release candidate #5 Ferenc Csaky
• [jira] [Created] (FLINK-39033) File Connector does not support WebHDFS protocol CHANHAE OH (Jira)
• [jira] [Created] (FLINK-39032) [webui] Add customizable timestamp formatting for watermarks Zuofeng Zhang (Jira)
• [jira] [Created] (FLINK-39031) [PyFlink] support Python 3.13 and 3.14 Honglei Jiang (Jira)
• [jira] [Created] (FLINK-39030) Support emit-only-on-update mode for CUMULATE window TVF to reduce unnecessary outputs Liu (Jira)
• [RESULT][VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Xuannan Su
• [jira] [Created] (FLINK-39029) Move catalog store factory builder from TableFactoryUtil to new class Hao Li (Jira)
• [VOTE] Release flink-connector-parent v2.0.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-parent v2.0.0, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Release flink-connector-parent v2.0.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Release flink-connector-parent v2.0.0, release candidate #1 Rich Bowen
  • Re: [VOTE] Release flink-connector-parent v2.0.0, release candidate #1 abhi Gupta
  • Re: [VOTE] Release flink-connector-parent v2.0.0, release candidate #1 Márton Balassi
  • Re: [VOTE] Release flink-connector-parent v2.0.0, release candidate #1 Ferenc Csaky
• [DISCUSS] FLINK-38825: Introduce AsyncBatchFunction for High-Throughput Inference Workloads featzhang
  • Re: [DISCUSS] FLINK-38825: Introduce AsyncBatchFunction for High-Throughput Inference Workloads Ryan van Huuksloot via dev
• [jira] [Created] (FLINK-39028) Use ByteBuffer API to reduce GC pressure in RocksDB state backend Natea Eshetu Beshada (Jira)
• [jira] [Created] (FLINK-39027) Support DDL for postgres pipeline connector Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-39026) Remove misleading TODO about getPartitionedState overhead Natea Eshetu Beshada (Jira)
• [jira] [Created] (FLINK-39025) Add HashMap index for InstanceID lookups in ResourceManager Natea Eshetu Beshada (Jira)
• [jira] [Created] (FLINK-39024) Support incremental snapshot connector supports predicate pushdown Thorne (Jira)
• [jira] [Created] (FLINK-39023) Implement Avro To Variant Type converter Swapna Marru (Jira)
• [DISCUSS] Redirect documentation for unsupported Flink versions to latest stable Martijn Visser
  • Re: [DISCUSS] Redirect documentation for unsupported Flink versions to latest stable Robin Moffatt via dev
• [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Attila Mészáros
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Rui Fan
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Robert Metzger
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Ryan van Huuksloot via dev
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 James Busche
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.14.0, release candidate #1 Samrat Deb
• [jira] [Created] (FLINK-39022) Update default cipher suite value in SecurityOptions Imre Balassa (Jira)
• [jira] [Created] (FLINK-39021) Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments Liu (Jira)
• [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
• [jira] [Created] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables suhwan (Jira)
• [jira] [Created] (FLINK-39018) Support checkpoint for LocalInputChannel Rui Fan (Jira)
• [jira] [Created] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression) Wei Zhong (Jira)
• [jira] [Created] (FLINK-39016) Add configurable TTL for ExecutionGraph cache independent of web refresh interval Liu (Jira)
• [jira] [Created] (FLINK-39015) Fix ro Dmitriy Linevich (Jira)
• [jira] [Created] (FLINK-39014) Fix the conversion to relational algebra issue in Batch Mode Archit Goyal (Jira)
• [DISCUSS] Review request for FLINK-37288: Add Google Cloud Spanner dialect and catalog Tomoyuki NAKAMURA
  • Re: [DISCUSS] Review request for FLINK-37288: Add Google Cloud Spanner dialect and catalog Yuepeng Pan
  • Re: [DISCUSS] Review request for FLINK-37288: Add Google Cloud Spanner dialect and catalog Tomoyuki NAKAMURA
• [jira] [Created] (FLINK-39013) add E2E test for DynamicKafkaTableSource Bowen Li (Jira)
• [jira] [Created] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source Xin Gao (Jira)
• [jira] [Created] (FLINK-39011) Cast does not support UnresolvedDataType Timo Walther (Jira)
• [jira] [Created] (FLINK-39010) YAML Pipeline supports item subscription of variant types Jia Fan (Jira)
• [jira] [Created] (FLINK-39009) flink postgres unnest insert way Gaurav Miglani (Jira)
• [VOTE] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
  • Re: [VOTE] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Arvid Heise
  • Re: [VOTE] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Gustavo de Morais
  • Re: [VOTE] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Timo Walther
  • Re: [VOTE] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Dawid Wysakowicz
  • Re:Re: [VOTE] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Xuyang
  • Re: Re: [VOTE] FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution Ramin Gharib
• [jira] [Created] (FLINK-39008) Support record types natively in DataTypeExtractor Timo Walther (Jira)
• [jira] [Created] (FLINK-39007) Run RAT license check automatically Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-39006) Flink Document correction lajith (Jira)
• [VOTE] Release flink-connector-aws v6.0.0, release candidate #5 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #5 Leonard Xu
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #5 abhi Gupta
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #5 Robert Metzger

• Earlier messages