dev  

Messages by Thread

• • Re: [DISCUSS] FLIP-XXX: Native Batch Inference Support in Flink SQL's ML_PREDICT Rahul Bhattacharya
  • Re: [DISCUSS] FLIP-XXX: Native Batch Inference Support in Flink SQL's ML_PREDICT Hao Li via dev
  • Re: [DISCUSS] FLIP-XXX: Native Batch Inference Support in Flink SQL's ML_PREDICT Rahul Bhattacharya
  • Re: [DISCUSS] FLIP-XXX: Native Batch Inference Support in Flink SQL's ML_PREDICT Rahul Bhattacharya
  • Re: [DISCUSS] FLIP-XXX: Native Batch Inference Support in Flink SQL's ML_PREDICT Biao Geng
  • Re: [DISCUSS] FLIP-XXX: Native Batch Inference Support in Flink SQL's ML_PREDICT Rahul Bhattacharya
  • Re: [DISCUSS] FLIP-XXX: Native Batch Inference Support in Flink SQL's ML_PREDICT Geng Biao
• [jira] [Created] (FLINK-38646) Connection runtime changes Hao Li (Jira)
• [jira] [Created] (FLINK-38645) Web UI may display incorrect SHIP policy names when the Adaptive Scheduler is enabled for a job RocMarshal (Jira)
• [VOTE] FLIP-553 Robust OTel gRPC metric exporter Aleksandr Iushmanov
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Rui Fan
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Piotr Nowojski
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Aleksandr Savonin
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Efrat Levitan
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Sergey Nuyanzin
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Kartikey Pant
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Samrat Deb
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Yuepeng Pan
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Li Wang
  • Re: [VOTE] FLIP-553 Robust OTel gRPC metric exporter Aleksandr Iushmanov
• [jira] [Created] (FLINK-38644) Reading tables with String type as the primary key may cause OutOfMemory Error Yanquan Lv (Jira)
• Flink 2.2 Test Failure Hang Ruan
  • Re: Flink 2.2 Test Failure Rui Fan
  • Re: Flink 2.2 Test Failure Hang Ruan
• [jira] [Created] (FLINK-38643) UnalignedCheckpointRescaleITCase stuck in test_ci tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38642) CheckpointCoordinatorTest stuck in test_cron_jdk11 core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38641) Trim surrounding double quotes from default values for BIGINT and SMALLINT types when parsing MySQL DDL JunboWang (Jira)
• [jira] [Created] (FLINK-38640) Fix NPE in DeltaJoinUtil#isFilterOnOneSetOfUpsertKeys Xuyang Zhong (Jira)
• Flink MongoDB Connector support for Flink 2.1.0 Rahul Teke
  • Re: Flink MongoDB Connector support for Flink 2.1.0 Rahul Teke
  • Re: Flink MongoDB Connector support for Flink 2.1.0 Leonard Xu
  • Re: Flink MongoDB Connector support for Flink 2.1.0 Rahul Teke
  • Re: Flink MongoDB Connector support for Flink 2.1.0 Rahul Teke
  • Re: Flink MongoDB Connector support for Flink 2.1.0 Rahul Teke
  • Re: Flink MongoDB Connector support for Flink 2.1.0 Leonard Xu
• [jira] [Created] (FLINK-38639) Add document for FLIP-551: Make FRESHNESS Optional for Materialized Tables Ruan Hang (Jira)
• [jira] [Created] (FLINK-38638) Refactor ExpressionConverter to extends ResolvedExpressionVisitor Hao Li (Jira)
• [jira] [Created] (FLINK-38637) explain() crashes when sort default limit is set Ahmad Humayun (Jira)
• [jira] [Created] (FLINK-38636) Add support to target the HTTP version david radley (Jira)
• [SUMMARY] Flink 2.2 Release Sync 11/05/2025 Hang Ruan
  • Re: [SUMMARY] Flink 2.2 Release Sync 11/05/2025 Hao Li
  • Re: [SUMMARY] Flink 2.2 Release Sync 11/05/2025 Hang Ruan
  • Re: [SUMMARY] Flink 2.2 Release Sync 11/05/2025 Hang Ruan
• [jira] [Created] (FLINK-38635) Distinguish scan source and lookup source when pushing filter down into source Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38634) The filter on the dim table will not be pushed down Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38633) Add document for FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ Ruan Hang (Jira)
• [jira] [Created] (FLINK-38632) Add document for FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. Ruan Hang (Jira)
• [jira] [Created] (FLINK-38631) Add document for FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. Ruan Hang (Jira)
• [jira] [Created] (FLINK-38630) Add document for FLIP-535: Introduce RateLimiter to Source Ruan Hang (Jira)
• [jira] [Created] (FLINK-38629) Add document for FLIP-544: SinkUpsertMaterializer V2 Ruan Hang (Jira)
• [jira] [Created] (FLINK-38628) Add document for FLIP-542: Make materialized table DDL consistent with regular tables Ruan Hang (Jira)
• [jira] [Created] (FLINK-38627) Add document for FLIP-540: Support VECTOR_SEARCH in Flink SQL Ruan Hang (Jira)
• [jira] [Created] (FLINK-38626) Flink 2.2.0 documents Ruan Hang (Jira)
• [jira] [Created] (FLINK-38625) The anchor links in the table options of the Performance Tuning page are currently all broken Xuyang Zhong (Jira)
• [NOTICE] flink-table-planner updates for plan verification tests (XML) Sergey Nuyanzin
• [jira] [Created] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) EMERSON WANG (Jira)
• [jira] [Created] (FLINK-38623) Reduce excluded methods in test_table_environment_completeness.py Hao Li (Jira)
• [jira] [Created] (FLINK-38622) Enhance the requests and slots balanced allocation logic in DefaultScheduler RocMarshal (Jira)
• [jira] [Created] (FLINK-38621) AsyncKeyedProcessOperator fails to restore with a java.io.FileNotFoundException: No such file or directory exception in ForSt Francis (Jira)
• [jira] [Created] (FLINK-38620) iceberg report metrics error ChaoFang (Jira)
• [jira] [Created] (FLINK-38619) Use heap sort to avoid array copy ChaomingZhang (Jira)
• [jira] [Created] (FLINK-38618) StreamSplitAssigner reassign stream split when scan start mode is latest-offset and taskmanager failover Xin Gong (Jira)
• [jira] [Created] (FLINK-38617) Kafka consumer do not commit offset when stop-with-savepoint Baozhu Zhao (Jira)
• [jira] [Created] (FLINK-38616) Jdbc Catalog supports jdbc properties. Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38615) Optimize the Python AsyncFunction interface to make it more Pythonic Dian Fu (Jira)
• [jira] [Created] (FLINK-38614) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling failed in test_cron_adaptive_scheduler tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38612) Flink 1.20.2 use sql-client.sh and Flink CDC 3.5.0 Invalid lambda expression for submitting task report apcahephoenix (Jira)
• [jira] [Created] (FLINK-38611) Add doc for delta join in 2.2 Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38610) Flink : State backends : Changelog failed Ruan Hang (Jira)
• [jira] [Created] (FLINK-38609) Make generation of xml plans deterministic Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38608) Drop abandoned plans without related tests Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38607) Do not store plans with same name twice in plan test files Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38606) Support Flink Mongodb connector on latest version of Flink 2.1.0 Rahul Teke (Jira)
• [jira] [Created] (FLINK-38605) Feature: Stateless Ordered Wait Zach (Jira)
• [jira] [Created] (FLINK-38604) AutoRescalingITCase.testCheckpointRescalingInKeyedState failed in test_cron_azure tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38603) FLIP-553 [Metrics] Robust OTel gRPC metric exporter Aleksandr Iushmanov (Jira)
• [ANNOUNCE] Flink 2.2 feature freeze Hang Ruan
• [jira] [Created] (FLINK-38602) test_cron_adaptive_scheduler python failed Ruan Hang (Jira)
• [Discuss] Flink CDC 3.6 Kick Off Yanquan Lv
  • Re: [Discuss] Flink CDC 3.6 Kick Off Leonard Xu
  • Re: [Discuss] Flink CDC 3.6 Kick Off Xiqian YU
  • Re: [Discuss] Flink CDC 3.6 Kick Off ConradJam
  • Re: [Discuss] Flink CDC 3.6 Kick Off Gunnar Morling
  • Re: [Discuss] Flink CDC 3.6 Kick Off Leonard Xu
  • Re: [Discuss] Flink CDC 3.6 Kick Off Xiqian YU
• [jira] [Created] (FLINK-38601) MongoDB CDC silently stops consuming from unbounded streams when Throwable errors occur and never recovers Ciprian Anton (Jira)
• [jira] [Created] (FLINK-38600) Pulsar connector fails with 'Exclusive consumer is already connected' due to a race condition Victor Babenko (Jira)
• [jira] [Created] (FLINK-38599) Add documentation to explain how Source re-assign splits once recovery Leonard Xu (Jira)
• [jira] [Created] (FLINK-38598) stringWrite.4.chinese(Java21) performance regression Ruan Hang (Jira)
• [jira] [Created] (FLINK-38597) Add request audit logging with pluggable sinks (GCS support) Rosa Seohwa Kang (Jira)
• [jira] [Created] (FLINK-38596) The comment of the created MaxCompute table is incorrect Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38595) Extend MultiJoin tests for further validation Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38594) CI error ./pyflink/table/tests/test_udf.py:23:1: F401 'pytz' imported but unused david radley (Jira)
• [jira] [Created] (FLINK-38593) Flink CDC Source E2E Tests / test failed in CI Leonard Xu (Jira)
• [jira] [Created] (FLINK-38592) Native Flink S3 FileSystem Samrat Deb (Jira)
• Help Needed: flinkbot in Community CI is Currently Unavailable Hang Ruan
• [jira] [Created] (FLINK-38591) Add async function examples of Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38590) Pypi does not support source distribution with underscore naming Zakelly Lan (Jira)
• [jira] [Created] (FLINK-38589) Add documentation for FLIP-535:Introduce RateLimiter to Source Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38588) StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory is failing Dian Fu (Jira)
• [jira] [Created] (FLINK-38587) docker entrypoint script cannot handle FLINK_PROPERTIES that include spaces Jacob Jona Fahlenkamp (Jira)
• [SUMMARY] Flink 2.2 Release Sync 10/29/2025 Hang Ruan
  • Re: [SUMMARY] Flink 2.2 Release Sync 10/29/2025 David Radley
• [jira] [Created] (FLINK-38586) ClassCastException when using Delta Join with lookup cache Stepan Stepanishchev (Jira)
• FLIP-555: SQL-like Domain Specific Language for Flink CEP 柳尘
• [jira] [Created] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env Biao Geng (Jira)
• [jira] [Created] (FLINK-38584) Support checkpoint external path as Prometheus info-style metric sohurdc (Jira)
• Flink Connector OpenSearch release Joao Boto
  • Re: Flink Connector OpenSearch release Andriy Redko
  • Re: Flink Connector OpenSearch release Ferenc Csaky
  • Re: Flink Connector OpenSearch release Andriy Redko
• [jira] [Created] (FLINK-38583) Flink job does not restart when environment variable changes. Manish Jain (Jira)
• [jira] [Created] (FLINK-38582) DeltaGlobalCommitter stopped commit to delta log Eric Nascimento (Jira)
• [jira] [Created] (FLINK-38581) Model Function supports error handling strategy Yunfeng Zhou (Jira)
• Flink HA doesn't update the savepoint restorePath in the SubmittedJobGraph file Qian, Gangling (LNG-CON)
• [jira] [Created] (FLINK-38580) Inconsistent data between Table API and DataStream API when using datagen connector lajith (Jira)
• [RESULT][VOTE] Release 2.0.1, release candidate #1 Zakelly Lan
• [jira] [Created] (FLINK-38579) NonEquivCond in join and Filters pushed down in source should also affect the upstream changelog just like Filter in Calc Xuyang Zhong (Jira)
• [DISCUSSION] FlinkBlueGreenDeployment Kubernetes Networking Daniel Rossos
  • Re: [DISCUSSION] FlinkBlueGreenDeployment Kubernetes Networking Daniel Rossos
  • Re: [DISCUSSION] FlinkBlueGreenDeployment Kubernetes Networking Daniel Rossos via dev
  • Re: [DISCUSSION] FlinkBlueGreenDeployment Kubernetes Networking Sergio Chong Loo
• [jira] [Created] (FLINK-38578) Invalid KinesisStreamsSource AWS_CREDENTIALS_PROVIDER_OPTION conversion Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-38577) linkBlueGreenDeployment Kubernetes Networking Update / Ingress not Stable Daniel Rossos (Jira)
• [RESULT][VOTE] Release 2.1.1, release candidate #1 Gabor Somogyi
• [jira] [Created] (FLINK-38576) Align commonJoinKey in MultiJoin for logical and physical rules Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38575) Checkpoint Race Condition in KuduSourceEnumerator Marton Greber (Jira)
• [jira] [Created] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Zakelly Lan (Jira)
• Permission to add FLIP document 柳尘
  • Re: Permission to add FLIP document Ferenc Csaky
  • Re: Permission to add FLIP document 柳尘
  • Re: Permission to add FLIP document Ferenc Csaky
  • Re: Permission to add FLIP document Ferenc Csaky
• [jira] [Created] (FLINK-38573) Add support for array datatype Marton Greber (Jira)
• [jira] [Created] (FLINK-38572) Support controlling randomness and format of Chat Model Function Yunfeng Zhou (Jira)
• [jira] [Created] (FLINK-38571) Index is lost in CTAS and RTAS Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38570) FLIP-554: Pipeline Testing Framework for Flink Poorvank Bhatia (Jira)
• [jira] [Created] (FLINK-38569) ReadingMetadataSpec should not be created if there are no metadataKeys to be read Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38568) Performance bottleneck in BinlogSplitReader with large number of snapshot splits yuanfenghu (Jira)
• [jira] [Created] (FLINK-38567) ForSt state backend error with GROUP BY and async state execution Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-38566) Support CEP DSL xingyuan cheng (Jira)
• [jira] [Created] (FLINK-38565) Reduce chain of TRY_CAST if source and target types are same Sergey Nuyanzin (Jira)
• [RESULT] [VOTE] FLIP-554: Pipeline Testing Framework For Flink Poorvank Bhatia
• [jira] [Created] (FLINK-38564) FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38563) Add documentation for async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38562) Support thread mode of async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38561) Add retry support for async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38560) Support ordered mode of async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38559) Support unorder mode of async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer Yangze Guo (Jira)
• [jira] [Created] (FLINK-38557) Upgrade Presto to resolve multiple vulnerabilities Avi Sanwal (Jira)
• [jira] [Created] (FLINK-38556) Filter & Project can exists between source and deltajoin Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38555) Optimize performance of `RecordUtils.compareObjects()` method by avoiding unnecessary `toString()` calls for temporal types (LocalDateTime, LocalDate, Instant, etc.). yuanfenghu (Jira)
• [jira] [Created] (FLINK-38554) Adjust FlinkMultiJoin self cost to be more accurate Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38553) Identity casts of ROW types are not detected Timo Walther (Jira)
• [jira] [Created] (FLINK-38552) FlinkStateSnapshot does not work if operator's namespace not in watchNamespaces Maksim Aniskov (Jira)
• [jira] [Created] (FLINK-38551) Extend MultiJoin tests based on current join tests Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38550) Flink CDC source connector for mongodb repeatedly failing in streaming mode with error code 286 Sachin Mittal (Jira)
• [jira] [Created] (FLINK-38549) Support limiting context window size for Model Functions Yunfeng Zhou (Jira)
• [RESULT][VOTE] FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. Hongshun Wang
• [jira] [Created] (FLINK-38548) Blue/Green Deployments Prem Santosh (Jira)
• [jira] [Created] (FLINK-38547) Upgrade protobuf-java from 3.x to 4.32.1 with compatibility patch for parquet-protobuf Khaled Hammouda (Jira)
• FW: Releasing the Flink HTTP connector David Radley
• Open ai very old dependancy David Radley
  • FW: Open ai very old dependancy David Radley
  • Re: FW: Open ai very old dependancy Shengkai Fang
  • Re: FW: Open ai very old dependancy Shengkai Fang
• [SUMMARY] Flink 2.2 Release Sync 10/22/2025 Hang Ruan
• [jira] [Created] (FLINK-38546) Improve error message for table discovery failure due to MySQL permission JunboWang (Jira)
• [jira] [Created] (FLINK-38545) Update Pulsar connector to Flink 1.20 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38544) Filtering record before processing with spilling strategy Rui Fan (Jira)
• [jira] [Created] (FLINK-38543) Change the overall UC restore process, JM and task initialization Rui Fan (Jira)
• [jira] [Created] (FLINK-38542) Recover output buffers of upstream task on downstream task side directly Rui Fan (Jira)
• [jira] [Created] (FLINK-38541) Introducing config option: execution.checkpointing.unaligned.allow-on-recovery Rui Fan (Jira)
• [jira] [Created] (FLINK-38540) Fix potential CME error in TransformExpressionCompiler Xiqian Yu (Jira)
• [RESULT][VOTE] FLIP-549: Support Application Management Yi Zhang
• [jira] [Created] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor Robert Metzger (Jira)
• [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Poorvank Bhatia
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Samrat Deb
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink ctrlaltdilj
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Gyula Fora
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Ferenc Csaky
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Őrhidi Mátyás
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Gabor Somogyi
  • RE: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink ctrlaltdilj
  • RE: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink ctrlaltdilj
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Poorvank Bhatia
• [jira] [Created] (FLINK-38538) Flink Autoscaler: Need Option to Autoscale Based Primarily (or Solely) on Busy Metric, Not Output Ratio Varun (Jira)
• [jira] [Created] (FLINK-38537) Fix the bug in StatsSummaryDto#equals method RocMarshal (Jira)
• [jira] [Created] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38535) CheckpointIntervalDuringBacklogITCase failed in test_cron_adaptive_scheduler tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup Ruan Hang (Jira)
• [jira] [Created] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38531) MySQL CDC BinlogOffset compareTo method cannot work correctly when gtidSet is same sherhomhuang (Jira)
• [jira] [Created] (FLINK-38460) Improve test coverage for SinkUpsertMaterializer Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544) Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38466) Bump derby version to 10.17.1.0 Siddharth R (Jira)
• [jira] [Created] (FLINK-38490) Update japicmp configuration post 1.20.2 Xuannan Su (Jira)

• Earlier messages
• Later messages