dev  

Messages by Thread

• [jira] [Created] (FLINK-38708) Support LLM bulk APIs to the ML_Predict Rahul Battacharya (Jira)
• [jira] [Created] (FLINK-38707) Enable vector search for some table source Hao Li (Jira)
• [jira] [Created] (FLINK-38706) Add more builtin ModelProviders Hao Li (Jira)
• [jira] [Created] (FLINK-38705) Add sync openai provider Hao Li (Jira)
• [jira] [Created] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Mohsen Rezaei (Jira)
• Jdbc Connector Release for 2.0 Joao Boto
• [jira] [Created] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager when reporting metrics Zdenek Tison (Jira)
• [jira] [Created] (FLINK-38702) Make unparse in parser more reusable Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38701) TO_TIMESTAMP_LTZ should validate literal format Dawid Wysakowicz (Jira)
• [ANNOUNCE] New Apache Flink Committer - Hongshun Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink Committer - Hongshun Hang Ruan
  • RE: [ANNOUNCE] New Apache Flink Committer - Hongshun David Radley
  • RE: [ANNOUNCE] New Apache Flink Committer - Hongshun wenjin
• [jira] [Created] (FLINK-38700) "kubernetes pyflink application test" failed Dian Fu (Jira)
• [jira] [Created] (FLINK-38699) Order the WebUI's Completed Job List by end time order Liu (Jira)
• [jira] [Created] (FLINK-38698) TaskInformation blobs accumulate without cleanup causing storage exhaustion ari (Jira)
• [jira] [Created] (FLINK-38697) TaskInformation blobs accumulate without cleanup causing storage exhaustion ari (Jira)
• [jira] [Created] (FLINK-38696) Refactor KafkaSinkITCase to not rely on custom RateLimiter implementation Martijn Visser (Jira)
• [jira] [Created] (FLINK-38695) The metric about left cache request count in DeltaJoinCache is wrong Xuyang Zhong (Jira)
• [SUMMARY] Flink 2.2 Release Sync 11/19/2025 Hang Ruan
  • Re: [SUMMARY] Flink 2.2 Release Sync 11/19/2025 Hao Li
  • Re: [SUMMARY] Flink 2.2 Release Sync 11/19/2025 Hang Ruan
• [jira] [Created] (FLINK-38694) Update Flink Shaded dependencies Mate Czagany (Jira)
• [jira] [Created] (FLINK-38693) Changelog normalize shouldnt call CNF for marking program Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38692) CNF in ChangelogNormalizeRule might lead to OOM Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38691) Support for Transaction Boundary Events in Flink CDC Connector Tejansh Rana (Jira)
• [jira] [Created] (FLINK-38690) Support to specify log level for python job Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38689) Support Protobuf 4.x field name conflict resolution in dynamic codegen Khaled Hammouda (Jira)
• [jira] [Created] (FLINK-38688) JdbcIncrementalSource with StartupOptions.initial() fails, while StartupOptions.latest() and legacy PostgreSQLSource work (Flink CDC 3.5) martin1986 (Jira)
• [DISCUSS] Release flink-shaded 21.0 Mate Czagany
  • Re: [DISCUSS] Release flink-shaded 21.0 Martijn Visser
  • Re: [DISCUSS] Release flink-shaded 21.0 Mate Czagany
• Call for Volunteers: Cross-Team Testing Needed for FLIPs in Flink 2.2 Hang Ruan
• [jira] [Created] (FLINK-38687) Release Testing: Verify FLIP-370: Support Balanced Tasks Scheduling RocMarshal (Jira)
• Optional configuration parameters for better performance Rahul Teke
  • Re: Optional configuration parameters for better performance Rahul Teke
• ???????????? jason
  • ???????????? [email protected]
• [jira] [Created] (FLINK-38686) ml_predict table function documentation Hao Li (Jira)
• [jira] [Created] (FLINK-38685) Flink Postgres CDC connector logs the database password Tejansh Rana (Jira)
• [jira] [Created] (FLINK-38684) Release Testing: Verify FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Hao Li (Jira)
• [jira] [Created] (FLINK-38683) Add schema to SHOW CREATE MATERIALIZED TABLE output Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38682) Cannot validate SQL if a dynamic parameter points to a RAW typed field Ferenc Csaky (Jira)
• [SUMMARY] Flink 2.2 Release Sync 11/12/2025 Hang Ruan
• [jira] [Created] (FLINK-38681) Fix threading model of KafkaEnumerator Arvid Heise (Jira)
• [jira] [Created] (FLINK-38680) Bump Flink 1.19, 1.20 patch versions in Flink CDC yuanfenghu (Jira)
• [jira] [Created] (FLINK-38679) Flink HA doesn't update the savepoint restorePath in the SubmittedJobGraph file lileiming (Jira)
• [jira] [Created] (FLINK-38678) Release Testing Instructions: Validate FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38677) Add test coverage for SHOW CREATE MATERIALIZED TABLE with optional FRESHNESS Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38676) Refactor DefaultSlotAssigner#getSlotsPerTaskExecutor calling for reducing redundant lines RocMarshal (Jira)
• [jira] [Created] (FLINK-38675) Add document for FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Ruan Hang (Jira)
• [jira] [Created] (FLINK-38674) Support schema definition for Materialized tables while CREATE Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38673) FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin (Jira)
• [RESULT][VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
• Proposal to add a new David Radley
  • Proposal to add a new discovery plugin to the k8s operator David Radley
  • Re: Proposal to add a new discovery plugin to the k8s operator gyula . fora
  • RE: Proposal to add a new discovery plugin to the k8s operator David Radley
  • RE: Proposal to add a new discovery plugin to the k8s operator David Radley
  • RE: Proposal to add a new discovery plugin to the k8s operator David Radley
  • RE: Proposal to add a new discovery plugin to the k8s operator David Radley
  • FW: RE: Proposal to add a new discovery plugin to the k8s operator David Radley
• [NOTICE] Remove old bugfix releases Zakelly Lan
• [ANNOUNCE] Apache Flink 2.0.1 released Zakelly Lan
• [ANNOUNCE] Apache Flink 2.1.1 released Gabor Somogyi
• [jira] [Created] (FLINK-38672) Update japicmp configuration post 2.1.1 Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-38671) Update japicmp configuration post 2.0.1 Zakelly Lan (Jira)
• [jira] [Created] (FLINK-38670) Release Testing Instructions: Ruan Hang (Jira)
• [jira] [Created] (FLINK-38669) Release Testing Instructions: Ruan Hang (Jira)
• [jira] [Created] (FLINK-38664) Release Testing Instructions: Ruan Hang (Jira)
• [jira] [Created] (FLINK-38668) Release Testing Instructions: Ruan Hang (Jira)
• [jira] [Created] (FLINK-38665) Release Testing Instructions: Ruan Hang (Jira)
• [jira] [Created] (FLINK-38667) Release Testing Instructions: Ruan Hang (Jira)
• [jira] [Created] (FLINK-38666) Release Testing Instructions: Ruan Hang (Jira)
• [jira] [Created] (FLINK-38663) Release Testing Instructions: FLIP-544: SinkUpsertMaterializer V2 Ruan Hang (Jira)
• Flink 2.2 Release Branch Cut Hang Ruan
• [jira] [Created] (FLINK-38662) [release-2.2] Review Release Notest in JIRA Ruan Hang (Jira)
• [jira] [Created] (FLINK-38661) [Release-2.2] Add release note for release 2.2 Ruan Hang (Jira)
• [jira] [Created] (FLINK-38660) [release-2.2] Verify that no exclusions were erroneously added to the japicmp plugin Ruan Hang (Jira)
• [jira] [Created] (FLINK-38657) [release-2.2] Cross team testing Ruan Hang (Jira)
• [jira] [Created] (FLINK-38659) [release-2.2] Review and update documentation Ruan Hang (Jira)
• [jira] [Created] (FLINK-38656) [release-2.2] Review Release Notes in JIRA Ruan Hang (Jira)
• [jira] [Created] (FLINK-38655) [release-2.2] Prepare RC0 release Ruan Hang (Jira)
• [jira] [Created] (FLINK-38658) [release-2.2] Triage release-blocking issues in JIRA Ruan Hang (Jira)
• [jira] [Created] (FLINK-38653) [release-2.2] Select executing Release Manager Ruan Hang (Jira)
• [jira] [Created] (FLINK-38654) [release-2.2] Create a release branch Ruan Hang (Jira)
• [jira] [Created] (FLINK-38652) [Release-2.2] Create a new version in JIRA Ruan Hang (Jira)
• [jira] [Created] (FLINK-38651) Prepare Flink 2.2 Release Ruan Hang (Jira)
• [jira] [Created] (FLINK-38650) Release Testing Instructions: FLIP-542: Make materialized table DDL consistent with regular tables Ruan Hang (Jira)
• [jira] [Created] (FLINK-38649) Release Testing Instructions: FLIP-540: Support VECTOR_SEARCH in Flink SQL Ruan Hang (Jira)
• [jira] [Created] (FLINK-38648) [Umbrella] Test Flink Release 2.2 Ruan Hang (Jira)
• [jira] [Created] (FLINK-38647) NullPointerException in Postgres CDC pipeline when update data in table Yang Guo (Jira)
• [DISCUSS] Batch LLM Calls in Flink SQL ML_PREDICT for Cost and Performance Rahul Bhattacharya
  • Re: [DISCUSS] Batch LLM Calls in Flink SQL ML_PREDICT for Cost and Performance Rahul Bhattacharya
  • [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 Shengkai Fang
  • RE: [DISCUSS] FLIP-XXX: Native Batch Inference Support in Flink SQL's ML_PREDICT David Radley
  • 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 Asimansu Bera
  • Re: [DISCUSS] FLIP-XXX: Native Batch Inference Support in Flink SQL's ML_PREDICT Hao Li
  • 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 Shengkai Fang
  • 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
  • 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
• [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)

• Earlier messages