dev  

Messages by Thread

• • 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
  • Re: [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 Leonard Xu
  • Re: [DISCUSS] FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Hao Li via dev
  • Re: [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 Hao Li via dev
  • Re: [DISCUSS] FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Gustavo de Morais
• [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
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #5 Xintong Song
  • Re: [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 abhi Gupta
• [jira] [Created] (FLINK-39005) AVRO Format Improvement xiaolong3817 (Jira)
• [jira] [Created] (FLINK-39004) [JUnit5 Migration] Migrate the remaining classes related to junit4 of flink-table module to junit5 Yuepeng Pan (Jira)
• [VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Xuannan Su
  • Re: [VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Xintong Song
  • Re: [VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Rui Fan
  • Re: [VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Robert Metzger
  • Re: [VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Weiqing Yang
  • Re: [VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Alan Zhang
  • Re: [VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Eugene
  • Re: [VOTE] Apache Flink Agents Release 0.2.0, release candidate #1 Xuannan Su
• [DISCUSS] Supports to pass the required privilege when catalog manager gets the table roryqi
  • Re:[DISCUSS] Supports to pass the required privilege when catalog manager gets the table Xuyang
  • Re: [DISCUSS] Supports to pass the required privilege when catalog manager gets the table roryqi
  • Re: [DISCUSS] Supports to pass the required privilege when catalog manager gets the table roryqi
  • Re:Re: [DISCUSS] Supports to pass the required privilege when catalog manager gets the table Xuyang
  • Re: Re: [DISCUSS] Supports to pass the required privilege when catalog manager gets the table roryqi
• [jira] [Created] (FLINK-39003) Inaccurate millisBehindLatest metric from the Kinesis source connector on failover Emre Kartoglu (Jira)
• [VOTE] Release flink-connector-aws v6.0.0, release candidate #4 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #4 Robert Metzger
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #4 Ferenc Csaky
• [jira] [Created] (FLINK-39002) Could not resolve ResourceManager because of NPE Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39001) [doc] Supplement the documentation regarding dynamic table addition Thorne (Jira)
• [jira] [Created] (FLINK-39000) Avoid redundant seeks during operator list state restore Ivan Torres (Jira)
• [jira] [Created] (FLINK-38999) License lineage files Efrat Levitan (Jira)
• [jira] [Created] (FLINK-38998) Cascaded event time Window Aggregate does not produce data when offset is specified Sergey Kononov (Jira)
• [jira] [Created] (FLINK-38997) Job can get stuck in state transition because unexpected error during ExecutionGraph creation Matthias Pohl (Jira)
• [jira] [Created] (FLINK-38996) Add origin transform sql expression into exception message Jia Fan (Jira)
• [jira] [Created] (FLINK-38995) Update the current Status of Disaggregated State & ForSt Yuan Mei (Jira)
• [jira] [Created] (FLINK-38994) Remove dependency log4j1 from flink-cdc-cli Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-38993) Move query change validation logic from converter to operation Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Bonnie Varghese (Jira)
• [jira] [Created] (FLINK-38991) MySQL CDC fails to detect online schema changes with custom gh-ost or pt-osc table naming Vishal P R (Jira)
• Re: [DISCUSS] Status of Statefun Project Martijn Visser
  • Re: [DISCUSS] Status of Statefun Project Martijn Visser
  • Re: [DISCUSS] Status of Statefun Project Galen Warren via dev
  • RE: [DISCUSS] Status of Statefun Project frans.king
  • Re: [DISCUSS] Status of Statefun Project Martijn Visser
• [jira] [Created] (FLINK-38990) Support configurable initial delay for first checkpoint trigger Liu (Jira)
• [jira] [Created] (FLINK-38989) Support resetting backlog status Shuai Xu (Jira)
• [jira] [Created] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion Liu (Jira)
• [jira] [Created] (FLINK-38987) Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem yunjiong zhao (Jira)
• [jira] [Created] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Swapna Marru (Jira)
• Proposal to release the HTTP connector version 1.0 and 2.0 David Radley
  • Re: Proposal to release the HTTP connector version 1.0 and 2.0 Ferenc Csaky
• [jira] [Created] (FLINK-38985) [Doc] Add document for VARIANT type and related functions Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38984) Python interpreter not found when using thread mode (pemja) raoraoxiong (Jira)
• [jira] [Created] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-38982) [JUnit5 Migration] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-38979) flink-tests-java17 skipped while java21 build Sergey Nuyanzin (Jira)
• [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 Rich Bowen
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 tjoch
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 Leonard Xu
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 Ferenc Csaky
  • RE: [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 abhi Gupta
• [ANNOUNCE] New Apache Flink Committer - David Radley Robert Metzger
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Rion Williams
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Shalini
  • RE: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Ferenc Csaky
  • RE: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Yuepeng Pan
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Jiangang Liu
  • Re:Re: [ANNOUNCE] New Apache Flink Committer - David Radley Xuyang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - David Radley Sergey Nuyanzin
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - David Radley Swapnal Varma
  • RE: Re: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • RE: Re: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • RE:Re: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Zhanghao Chen
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Weiqing Yang
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Mate Czagany

• Earlier messages
• Later messages