dev  

Messages by Thread

• • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Leonard Xu
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Leonard Xu
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • RE: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Leonard Xu
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Leonard Xu
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
• 2025/07/17 CHI Eastern time zone workgroup meeting minutes David Radley
• [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Ahmed Hamdy
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API David Radley
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Ahmed Hamdy
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Poorvank Bhatia
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Ahmed Hamdy
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Chesnay Schepler
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Ahmed Hamdy
• [jira] [Created] (FLINK-38120) FLIP-536 Add latest checkpoint details endpoint Ahmed Hamdy (Jira)
• Looking for reviewers and voters for flink-connector-aws v5.1.0 release Daren Wong
• [jira] [Created] (FLINK-38119) [Unstable test]IcebergWriterTest.testWriteWithAllSupportedTypes:344 Yanquan Lv (Jira)
• [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Leonard Xu
  • RE: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Shengkai Fang
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Jiangang Liu
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Jiangang Liu
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Arvid Heise
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source 魏宪党
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Leonard Xu
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source 魏宪党
  • RE: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
• [jira] [Created] (FLINK-38118) The execution.attached=true parameter does not take effect in application mode shilei-ly (Jira)
• [jira] [Created] (FLINK-38117) Add anonymous ContextResolvedModel Hao Li (Jira)
• [jira] [Created] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error David Ballano (Jira)
• [jira] [Created] (FLINK-38115) Synchronous the Python JDBC connector with the Java implementation Dian Fu (Jira)
• [jira] [Created] (FLINK-38114) Allow offloading of task restore Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-38113) Rethrow fatal or OOM errors from Execution.deploy Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-38112) Change default of yarn.application-attempt-failures-validity-interval to -1 yude (Jira)
• [jira] [Created] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service yuan (Jira)
• [jira] [Created] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters haiqingchen (Jira)
• [jira] [Created] (FLINK-38109) BlobServer isn't associated with the correct bind-host Rosa Seohwa Kang (Jira)
• RE: Re: Flink Kubenetes Operator client version Nic Townsend
• [jira] [Created] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL dylanhz (Jira)
• [SUMMARY] Flink 2.1 Release Sync 07/16/2025 Ron Liu
• [jira] [Created] (FLINK-38107) JobMasterTest#testJobFailureWhenGracefulTaskExecutorTermination azure ci failed dalongliu (Jira)
• [jira] [Created] (FLINK-38106) Job gets indefinitely stuck with "Job Not Found" events Rasmus Bilgram (Jira)
• 2025/07/10 CHI Western time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-38105) AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators' Dian Fu (Jira)
• [jira] [Created] (FLINK-38104) FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Hao Li (Jira)
• [jira] [Created] (FLINK-38103) DataTypeFactory cannot restore inline structured types Timo Walther (Jira)
• [jira] [Created] (FLINK-38102) RestApiMetricsCollectorTest is unstable Robert Metzger (Jira)
• [jira] [Created] (FLINK-38101) Support SI Format for CPU resources Santwana Verma (Jira)
• [jira] [Created] (FLINK-38100) Add BigQuery catalog support for iceberg pipeline sink connector Luca Occhipinti (Jira)
• [jira] [Created] (FLINK-38099) Greenplum: Distribution column updates in Greenplum upsert zm999999 (Jira)
• [jira] [Created] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed shilei (Jira)
• [jira] [Created] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator Kumar Mallikarjuna (Jira)
• [jira] [Created] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy Jira
• [jira] [Created] (FLINK-38095) Error in Session Job autoscaler when realizing parallelism overrides Jean-Benoit Hamard (Jira)
• [jira] [Created] (FLINK-38094) Introduce pyflink.__version__ Yun Tang (Jira)
• [jira] [Created] (FLINK-38093) Update version of Fabric8 to 7.3.1 Mate Czagany (Jira)
• [jira] [Created] (FLINK-38091) Update japicmp configuration post 1.20.2 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38092) Update japicmp configuration post 1.19.3 Ferenc Csaky (Jira)
• [ANNOUNCE] Apache Flink 1.20.2 released Ferenc Csaky
  • Re: [ANNOUNCE] Apache Flink 1.20.2 released Sergey Nuyanzin
• [ANNOUNCE] Apache Flink 1.19.3 released Ferenc Csaky
  • Re: [ANNOUNCE] Apache Flink 1.19.3 released Sergey Nuyanzin
• [jira] [Created] (FLINK-38090) TableResult.collect() returns incorrect SQL inline structured types Timo Walther (Jira)
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.12.1 released Gyula Fóra
• Flink HTTP connector health proposal going forward. David Radley
  • Re: Flink HTTP connector health proposal going forward. Martijn Visser
  • RE: Flink HTTP connector health proposal going forward. David Radley
• [jira] [Created] (FLINK-38089) Avoid pushing down non-deterministic filter in agg, join and union Qilong Wang (Jira)
• [jira] [Created] (FLINK-38088) If source config "scan.startup.mode:snapshot",not create replicatedconnect. ouyangwulin (Jira)
• [jira] [Created] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage Mingliang Liu (Jira)
• [jira] [Created] (FLINK-38086) Make ChangelogNormalize reusable if possible Sergey Nuyanzin (Jira)
• [RESULT][VOTE] FLIP-523 - Handle TLS Certificate Renewal Alex Nitavsky
• [jira] [Created] (FLINK-38085) Use buildx for Docker image creation Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38084) Update model provider download doc Hao Li (Jira)
• [jira] [Created] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38082) User's async function timeout call may result in unexpected retries lincoln lee (Jira)
• [jira] [Created] (FLINK-38081) FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38080) Avoid pushing down non-deterministic relNodes by mistake Qilong Wang (Jira)
• [jira] [Created] (FLINK-38079) Add Pipeline support for DateType and TimeType wuzexian (Jira)
• [jira] [Created] (FLINK-38078) DataStream API Execution Configuration doc contains deleted API usage Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing Gyula Fora (Jira)
• [jira] [Created] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 fallenup (Jira)
• [jira] [Created] (FLINK-38075) [Window]Data loss when using ltz time. kaitian (Jira)
• [jira] [Created] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng (Jira)
• [jira] [Created] (FLINK-38073) Add documentation for the MultiJoin Operator Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38072) EventTimeWindowCheckpointingITCase#testSlidingTimeWindow test failed in cron ci dalongliu (Jira)
• [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry HONGGEUN JI
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry Lincoln Lee
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry HONGGEUN JI
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry Lincoln Lee
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry HONGGEUN JI
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry HONGGEUN JI
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry Lincoln Lee
• [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gyula Fóra
• Flink Connector Kafka Releases Tom Cooper
  • Re: Flink Connector Kafka Releases Tom Cooper
  • Re: Flink Connector Kafka Releases Fabian Paul
  • Re: Flink Connector Kafka Releases Tom Cooper
  • Re: Flink Connector Kafka Releases Fabian Paul
  • Re: Flink Connector Kafka Releases Tom Cooper
  • Re: Flink Connector Kafka Releases Weiqing Yang
  • Re: Flink Connector Kafka Releases Fabian Paul
  • Re: Flink Connector Kafka Releases Weiqing Yang
  • Re: Flink Connector Kafka Releases Tom Cooper
  • RE: Flink Connector Kafka Releases David Radley
  • RE: Flink Connector Kafka Releases Tom Cooper
  • RE: Flink Connector Kafka Releases David Radley
  • RE: Flink Connector Kafka Releases Tom Cooper
• Re: [Discuss] Non-retriable (partial) errors in Elasticsearch 8 connector Mingliang Liu
• [ANNOUNCE] Release 2.1.0, release candidate #0 Ron Liu
• [jira] [Created] (FLINK-38071) FLIP-485: Add UDF Metrics Weiqing Yang (Jira)
• [DISCUSS] Add UDF Metrics Weiqing Yang
  • Re: [DISCUSS] Add UDF Metrics Shengkai Fang
  • Re: [DISCUSS] Add UDF Metrics Alan Sheinberg
  • Re: [DISCUSS] Add UDF Metrics Weiqing Yang
  • Re:Re: [DISCUSS] Add UDF Metrics Xuyang
  • Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
  • Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
  • Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
  • Re: Re: [DISCUSS] Add UDF Metrics Shengkai Fang
  • Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
  • Re: Re: [DISCUSS] Add UDF Metrics Shengkai Fang
  • Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
  • Re: Re: [DISCUSS] Add UDF Metrics Zakelly Lan
  • Re: [DISCUSS] Add UDF Metrics Weiqing Yang
• [jira] [Created] (FLINK-38070) Release Testing: Verify FLIP-507 : Add Model DDL methods in TABLE API Yash Anand (Jira)
• [jira] [Created] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL Dylan He (Jira)
• [jira] [Created] (FLINK-38068) Fix distribution Hao Li (Jira)
• [jira] [Created] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li (Jira)
• [jira] [Created] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL Hao Li (Jira)
• [jira] [Created] (FLINK-38065) Mismatching bracket in PostgresOffset#toString Sergei Morozov (Jira)
• [jira] [Created] (FLINK-38064) Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1 Siddharth R (Jira)
• Flink Kubenetes Operator client version David Radley
  • Re: Flink Kubenetes Operator client version Gyula Fóra
  • RE: Flink Kubenetes Operator client version David Radley
  • Re: Flink Kubenetes Operator client version Tom Cooper
• [jira] [Created] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project Thomas Cooper (Jira)
• [jira] [Created] (FLINK-38062) ENCODE behaves wrong Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint potterhe (Jira)
• [jira] [Created] (FLINK-38060) Github action build python wheel on linux failed dalongliu (Jira)
• Re: [Discuss] FLIP-485: Flink UDF metrics Weiqing Yang
• [jira] [Created] (FLINK-38059) [docs] Add fluss pipeline connector documentation Leonard Xu (Jira)
• [jira] [Created] (FLINK-38058) Add e2e test for fluss pipeline connector Leonard Xu (Jira)
• [jira] [Created] (FLINK-38057) Connector emit time lag may be a wrong value Ruan Hang (Jira)
• [jira] [Created] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-38055) The internalTimerService must initialize watermark before processing data Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38054) Kryo Deserialization Error in ElasticSearch 8 Sink 3.1.0 With Flink 1.20.0 Andrey Starostin (Jira)
• [jira] [Created] (FLINK-38053) Release Testing: Verify FLIP-521: Integrating Variant Type into Flink dalongliu (Jira)
• [jira] [Created] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator dalongliu (Jira)
• [jira] [Created] (FLINK-38051) Fix flaky test JobAutoScalerImplTest Mate Czagany (Jira)
• 2025/07/02 CHI Eastern time zone workgroup meeting minutes David Radley
• Request for PMC to get PyPI access Ferenc Csaky
  • Re: Request for PMC to get PyPI access Dian Fu
• [jira] [Created] (FLINK-38050) Flink UI has fixed dropdown width and truncates metric names Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38049) UpgradeMode falls back to last-state mode on HA resubmission even for stateless Lucas Borges (Jira)
• [jira] [Created] (FLINK-38048) flink-connector-parent java version should be set to 11 Etienne Chauchot (Jira)
• [jira] [Created] (FLINK-38047) Bump cert-manager in the Kubernetes Operator Kumar Mallikarjuna (Jira)
• [jira] [Created] (FLINK-38046) Solve the issue of missing one piece of data jingzi (Jira)
• [jira] [Created] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache wuzexian (Jira)
• [jira] [Created] (FLINK-38044) [UI] upgrade runtime web Angular framework and related deps to lastest version Ao Yuchen (Jira)
• [jira] [Created] (FLINK-38043) Support joining without join keys Gustavo de Morais (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Mate Czagany
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Weiqing Yang
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Robert Metzger
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gyula Fóra

• Earlier messages
• Later messages