commits  

Messages by Thread

• (flink-agents) branch main updated: [api][integration][java] Enrich interface for vector store and implement these for elasticsearch. (#416) xtsong
• (flink) branch release-1.20 updated: [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner mapohl
• (flink) branch release-2.1 updated: [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner mapohl
• (flink) branch release-2.2 updated: [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner mapohl
• (flink-agents) branch main updated (8c7ae45 -> 1fb13d7) xtsong
• (flink-agents) branch main updated: [Feature][runtime] Support the use of Python EembeddingModel in Java (#417) xtsong
• (flink-connector-kafka) branch main updated: [FLINK-38862] Configurable partition discovery interval in upsert mode fpaul
• (flink-agents) branch main updated: [api][integration] Move mcp module from api to integration. (#415) xtsong
• (flink-agents) branch main updated: [Feature] Improve Python Async Execution API (#409) xtsong
• (flink) branch master updated (d481fb32219 -> fec9336e7d9) zhuzh
• (flink-agents) branch main updated (6066182 -> 4012835) xtsong
  • (flink-agents) 01/05: [test] Revise the question and tool description to improve test stability xtsong
  • (flink-agents) 02/05: [api] Move agent api to agents module. xtsong
  • (flink-agents) 03/05: [plan] Use sensory memory for tool call context. xtsong
  • (flink-agents) 04/05: [plan] Refactor built-in chat action. xtsong
  • (flink-agents) 05/05: [plan] Support error handling strategy for chat action. xtsong
• (flink-cdc) branch master updated: [FLINK-38840][postgres] Postgres YAML connector supports emitting complete Table ID (#4209) yux
• (flink-connector-aws) branch v5.1 updated: [FLINK-38868] Bump Flink version to 1.20.3 fcsaky
• (flink-connector-aws) branch v5.1 updated: [hotfix] Fix Python CI fcsaky
• (flink) branch master updated: [hotfix][NOTICE] Update copyright NOTICE year to 2026 (#27380) panyuepeng
• (flink) branch master updated (452479b6368 -> e02393ee8a9) shengkai
• (flink) branch master updated: [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner mapohl
• (flink) branch master updated (94c65494b20 -> 76337add10b) snuyanzin
• (flink) branch master updated: [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures (#27060) panyuepeng
• (flink) branch master updated: [FLINK-38748][runtime] Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. (#27286) panyuepeng
• (flink) branch master updated: [FLINK-38225] Sets proper precondition to ensure that GCS operations are retryable (#27101) xtsong
• (flink-kubernetes-operator) branch main updated: [FLINK-38860] Remove flink shaded guava usage gyfora
• (flink-kubernetes-operator) branch main updated (90edc9c6 -> e480eb72) gyfora
• (flink-kubernetes-operator) branch main updated: [FLINK-38859] Do not apply minimum job vertex parallelism for whole job in native mode gyfora
• (flink-agents) branch main updated (9429239 -> 6066182) xtsong
• (flink-agents) branch main updated: [infra] Add doc-including label to indicate docs are included in the PR (#407) xtsong
• (flink-cdc) branch master updated: [FLINK-37676][common] Add caching mechanism to Table ID Selectors for better performance (#3994) yux
• (flink-benchmarks) branch master updated (6810df8 -> 9ac3569) panyuepeng
  • (flink-benchmarks) 02/02: [FLINK-38801][benchmark] Add Spotless and checkstyle plugins with Google AOSP style for flink benchmark repository panyuepeng
  • (flink-benchmarks) 01/02: [FLINK-38801][benchmark] Adjust code lines format and corresponding namings to follow Google AOSP style. panyuepeng
• (flink-cdc) branch master updated: [FLINK-38847][postgres] Update PostgresConnectionPoolFactory#getPoolId method to use username correctly. (#4204) kunni
• (flink) branch master updated: [FLINK-38855] Upgrade jackson to 2.20.1 snuyanzin
• (flink-agents) branch main updated (6bc5f58 -> 57f968a) xtsong
  • (flink-agents) 01/05: [build] Use Unified Jackson in Flink Agents xtsong
  • (flink-agents) 02/05: [build] Update default flink to 2.2.0 xtsong
  • (flink-agents) 03/05: [build] Support Multi-Version Flink in Java xtsong
  • (flink-agents) 05/05: [ci] Enable testing for all Flink versions in CI xtsong
  • (flink-agents) 04/05: [build] Support Multi-Version Flink in Python xtsong
• (flink) branch master updated: [FLINK-34596][table] Migrate RemoveRedundantLocalHashAggRule to java snuyanzin
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/node-forge-1.3.2 deleted (was b759cd14010) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/node-forge-1.3.3 created (now 9b7662f0735) github-bot
• (flink) branch master updated: [FLINK-34895][table] Migrate FlinkRewriteSubQueryRule to java snuyanzin
• (flink) branch master updated (02106293bb8 -> fc8b531c6b6) snuyanzin
• Re: [I] [Bug] Flink-CDC-MySQL，任务正常运行一段时间后，就无法继续获取新Binlog数据，程序保持运行，无任何报错。 [flink-cdc] via GitHub
  • Re: [I] [Bug] Flink-CDC-MySQL，任务正常运行一段时间后，就无法继续获取新Binlog数据，程序保持运行，无任何报错。 [flink-cdc] via GitHub
  • Re: [I] [Bug] Flink-CDC-MySQL，任务正常运行一段时间后，就无法继续获取新Binlog数据，程序保持运行，无任何报错。 [flink-cdc] via GitHub
• (flink) branch master updated: [FLINK-38717][runtime] Display the assigned task numbers for TaskManagers on the UI fcsaky
• (flink) branch master updated (e287f22140d -> 2c9bbebc231) zhuzh
• (flink-cdc) branch master updated (db1caee89 -> 44fb79fa5) yux
• (flink) branch master updated: [FLINK-38740][table] Introduce Welford's online algorithm for variance related functions to avoid catastrophic cancellation in naive algorithm lincoln
• (flink-connector-http) branch main updated: [FLINK-38803] Add HTTP response deserialize failed completion state fcsaky
• svn commit: r81536 - dev/flink/flink-shaded-21.0-rc2 martijnvisser
• (flink-shaded) annotated tag release-21.0-rc2 updated (8f9e83c -> 6b1b2f4) martijnvisser
• svn commit: r81534 - release/flink martijnvisser
• (flink-cdc) branch master updated: [FLINK-38837][docs][pipeline-connector/hudi] Add documentation for Hudi connector and improve the configuration leonard
• (flink-cdc) branch master updated: [FLINK-38730][build] Bump default JDK version from 8 to 11 and support optional JDK17 leonard
• (flink) branch master updated: [FLINK-38759][runtime] Refactor application mode with PackagedProgramApplication zhuzh
• (flink-agents) branch main updated: [metrics] Implement token usage metrics tracking for chat models (#394) sxnan
• (flink-cdc) branch master updated: [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector (#4198) kunni
• (flink-cdc) branch master updated: [FLINK-38818][pipeline-connector][posgtresql]Build createTableEventCache using TableSchemas from split (#4194) kunni
• (flink-web) branch asf-site updated (4ab0ef441 -> cfbf10f99) xtsong
  • (flink-web) 01/02: Fix broken image links in the dynamic iceberg sink blogpost xtsong
  • (flink-web) 02/02: Rebuild website xtsong
• Re: [I] [Bug] [tidb cdc]a error:java.lang.IllegalArgumentException: Invalid range: [+INF..{xxx}) at org.apache.flink.shaded.guava30.com.google.common.collect.Range.<init>(Range.java:358) [flink-cdc] via GitHub
• (flink-agents) branch main updated: [runtime] Avoid create new runner context each time execute action. (#392) xtsong
• (flink) branch release-2.2 updated: [FLINK-38824][table] Fix incorrect default values for primitive types lincoln
• (flink-shaded) annotated tag release-21.0-rc1 updated (8f9e83c -> 91b9905) martijnvisser
• svn commit: r81519 - dev/flink/flink-shaded-21.0-rc1 martijnvisser
• (flink) branch release-1.20 updated: [FLINK-38824][table] Fix incorrect default values for primitive types lincoln
• (flink-agents) branch main updated (ba703da -> 35ab4f2) xtsong
  • (flink-agents) 02/02: [api][runtime] Support use long-term memory in action and async compaction. xtsong
  • (flink-agents) 01/02: [api][runtime] Add return value for add and improve summarization prompt. xtsong
• svn commit: r81510 - release/flink martijnvisser
• (flink-shaded) branch master updated: Revert "[hotfix] Add Maven wrapper" martijnvisser
• (flink-shaded) branch master updated: [hotfix] Add Maven wrapper martijnvisser
• (flink-shaded) branch master updated: [hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35 martijnvisser
• (flink-shaded) branch master updated (8e38d2e -> 013a3af) martijnvisser
  • (flink-shaded) 05/07: [FLINK-38694][Build/Shaded] Update Swagger to 2.2.41 martijnvisser
  • (flink-shaded) 04/07: [FLINK-38694][Build/Shaded] Update Jackson to 2.20.1 martijnvisser
  • (flink-shaded) 07/07: [FLINK-38694][Build/Shaded] Update Guava to 33.5.0-jre martijnvisser
  • (flink-shaded) 02/07: [FLINK-38694][Build/Shaded] Update Zookeeper to 3.8.5 martijnvisser
  • (flink-shaded) 01/07: [FLINK-38694][Build/Shaded] Update Curator to 5.9.0 martijnvisser
  • (flink-shaded) 03/07: [FLINK-38694][Build/Shaded] Update json-path to 2.10.0 martijnvisser
  • (flink-shaded) 06/07: [FLINK-38694][Build/Shaded] Update ASM to 9.9.1 martijnvisser
• Re: [I] 一个单节点群集中flink cdc任务超过20个后出错，请问如何调整 [flink-cdc] via GitHub
  • Re: [I] 一个单节点群集中flink cdc任务超过20个后出错，请问如何调整 [flink-cdc] via GitHub
• (flink-cdc) branch master updated (e2b8076ec -> 2293651e9) kunni
• (flink-cdc) branch master updated: [FLINK-38813][mysql] Support for emitting heartbeat events (#4193) kunni
• (flink) branch master updated (e3456e35855 -> ffad337fd15) panyuepeng
• (flink) branch master updated: [FLINK-38824][table] Fix incorrect default values for primitive types lincoln
• (flink-connector-kafka) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now 8b784fdd) github-bot
• (flink-connector-opensearch) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now cbb086b) github-bot
• (flink-connector-kudu) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now 1d011c9) github-bot
• (flink-connector-gcp-pubsub) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now ebd0a5f) github-bot
• (flink-connector-mongodb) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now f6e3981) github-bot
• (flink-connector-rabbitmq) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now a071d25) github-bot
• (flink-connector-jdbc) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now 9268ae7d) github-bot
• (flink-connector-cassandra) branch dependabot/maven/flink-connector-cassandra/org.apache.logging.log4j-log4j-core-2.25.3 created (now ecda1ba) github-bot
• (flink) branch master updated: [FLINK-38738][table] Expose more context in table connectors to correct UID twalthr
• (flink-agents) branch main updated: Refactor the resource cross-language test to a cross-language test in CI. (#386) xtsong
• (flink) branch master updated (883e33b08b9 -> 4cb44c02699) zhuzh
  • (flink) 01/02: [FLINK-38758][runtime] Use JobStatus instead of ApplicationStatus in JobResult zhuzh
  • (flink) 02/02: [FLINK-38758][runtime] Introduce PackagedProgramApplication zhuzh
• (flink-agents) branch main updated (1ac8583 -> 2d0a8a5) xtsong
• (flink) branch master updated: [hotfix][table] Fix incorrect error message of `RootArgumentTypeStrategy` snuyanzin
• (flink-agents) branch main updated: [Feature][runtime] Support the use of Java ChatModel in Python (#373) xtsong
• (flink-agents) branch main updated (8d14972 -> 8825795) xtsong
• (flink) branch master updated: [FLINK-38811][docs] Translate async function doc to Chinese (#27346) shengkai
• (flink-agents) branch release-0.1 updated: [runtime] Remove userCodeClassLoader field for ActionTask to fix can't be serialized to state. (#379) xtsong
• (flink-agents) branch main updated: [runtime] Remove userCodeClassLoader field for ActionTask to fix can't be serialized to state. (#379) xtsong
• (flink) branch release-2.1 updated: [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed (#27157) roman
• (flink) branch release-1.19 updated: [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed (#27157) roman
• (flink) branch release-2.0 updated: [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed (#27157) roman
• (flink) branch master updated: [FLINK-38802][table] DDL with duplicated keys in table options should not fail snuyanzin
• (flink-cdc) branch master updated: [FLINK-38806] Fix post-transform converters ineffective without projection or filter rules (#4191) kunni
• (flink) branch master updated: [FLINK-38757][runtime] Introduce the base class for application zhuzh
• (flink) branch master updated: [FLINK-38776][table] Fix incorrect auxiliary group field names snuyanzin
• (flink) branch release-2.1 updated: [FLINK-38486] Harden shutdown of system UDFs roman
• (flink) branch release-2.0 updated: [FLINK-38486] Harden shutdown of system UDFs roman
• (flink) branch master updated (a56134df9d0 -> c02879020fc) dwysakowicz
  • (flink) 01/02: [FLINK-38765] Fix persisted metadata handling in sink dwysakowicz
  • (flink) 02/02: [hotfix] Pull legacyUidsEnabled as an abstract method to CommonExecTableSourceScan dwysakowicz
• (flink) branch release-1.20 updated: [FLINK-36026][table] Options from `OPTIONS` hint should be present in compiled plan mxm
• (flink-connector-aws) branch v5.1 updated: [FLINK-37627] Fix restart from checkpoint/savepoint at shard split can cause data loss fcsaky
• (flink-connector-aws) branch main updated: [FLINK-37627] Fix restart from checkpoint/savepoint at shard split can cause data loss fcsaky
• (flink) branch release-1.20 updated: [FLINK-38797][python] Fixed CsvSchemaBuilder.set_null_value to return self dianfu
• (flink) branch release-2.1 updated: [FLINK-38797][python] Fixed CsvSchemaBuilder.set_null_value to return self dianfu
• (flink) branch release-2.2 updated: [FLINK-38797][python] Fixed CsvSchemaBuilder.set_null_value to return self dianfu
• (flink) branch master updated (7ba97419d20 -> a56134df9d0) dianfu
• (flink) branch release-1.19 updated: [FLINK-38486] Harden shutdown of system UDFs roman
• (flink-agents) branch main updated: [Feature][runtime] Support the use of Python ChatModel in Java (#314) xtsong
• (flink-connector-http) branch main updated: [FLINK-38781] Pass format options to response using JSON format fcsaky
• (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-lang3-3.18.0 updated (52796937 -> 0c36072d) fanrui
• (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-lang3-3.18.0 updated (78e29f8e -> 52796937) fanrui
• (flink-agents) branch main updated: [ci] Add java 17 pipeline for java ut and it. (#380) xtsong
• (flink-connector-aws) branch main updated (373be6f -> 68acdbd) fcsaky
• (flink) branch master updated: [FLINK-38754][runtime] Avoid reverse DNS lookups when connecting to BlobServer zhuzh
• (flink-cdc) branch master updated: [FLINK-38531][cdc-connector-mysql]Fix data loss when restoring from a checkpoint positioned in the middle of a bulk DML operation. (#4165) kunni
• (flink-agents) annotated tag release-0.1.1 updated (23ebac6 -> ced7fa6) sxnan
• (flink-agents) branch release-0.1 updated: [doc] Update doc version to 0.1.1 (#378) xtsong
• (flink) branch master updated: [FLINK-38796][table] `UnresolvedMetadataColumn` misses type during serializing to string snuyanzin
• (flink-web) branch asf-site updated (f13e4c658 -> 4ab0ef441) sxnan
  • (flink-web) 01/02: Announce Flink Agents 0.1.1 sxnan
• (flink-cdc) branch FLINK-38730-copy updated (dff4d6ef3 -> 5e0acee36) kunni
  • (flink-cdc) 01/06: [FLINK-38730][build] Update jdk version of nightly to 17. kunni
  • (flink-cdc) 04/06: Address comment. kunni
  • (flink-cdc) 05/06: Address comment. kunni
  • (flink-cdc) 06/06: Address comment. kunni
  • (flink-cdc) 02/06: Address comment. kunni
  • (flink-cdc) 03/06: Address comment. kunni
• (flink-shaded) branch master updated: [hotfix] Fix maven-shade-plugin not printing included artifacts (#154) martijnvisser
• (flink-agents) branch main updated: [hotfix] Fix the type loss issue in agent plan deserialization (#343) sxnan
• svn commit: r81239 - dev/flink/flink-agents-0.1.1-rc1 release/flink/flink-agents-0.1.1 xtsong
• (flink-agents) branch main updated: [integration] Remove unnecessary dependency flink-agents-plan for chat model integration. (#375) xtsong
• (flink-agents) branch main updated: [Feature][Java] Add Anthropic chat model integration (#369) xtsong
• (flink-cdc) branch FLINK-38730-copy updated: Address comment. kunni
  • (flink-cdc) branch FLINK-38730-copy updated: Address comment. kunni
• (flink-cdc) branch FLINK-38730-copy created (now 521bd1053) kunni
  • (flink-cdc) 01/01: Address comment. kunni
• (flink) branch release-2.2 updated (ad477178625 -> 8de272c7d96) shengkai
  • (flink) 03/03: [FLINK-38773][table] Fix batch vector search excnode context (#27311) shengkai
  • (flink) 02/03: [FLINK-38767][table] Fix vector search execnode transform name (#27304) shengkai
  • (flink) 01/03: [FLINK-38084][doc] Add download doc for model providers (#27296) shengkai
• (flink) branch master updated: [hotfix][release] Update japicmp configuration for 2.2.0 (#27312) ruanhang1993
• (flink) branch master updated: [FLINK-38771][table] Allow scalar args for multi-table PTFs twalthr
• (flink-cdc) branch master updated: [FLINK-38737][common] Fix potential backwards incompatibility with fallback keys (#4185) yux
• (flink-cdc) branch master updated: [hotfix] Bump Doris flink connector version to 25.1.0 (#4188) kunni
• (flink) branch master updated: [FLINK-38772][table] `CliClientITCase` is broken in IDE snuyanzin
• (flink) branch master updated (c4d6344ab8e -> 11f61d23b80) snuyanzin
  • (flink) 02/02: [FLINK-38766][table] Migrate `TableEnvironmentTest` to assertJ snuyanzin
• (flink) branch master updated: [FLINK-38403][tests] Fix the unexpected test that the second job does not restore from checkpoint (#27254) fanrui
• (flink-connector-http) branch main updated: [FLINK-38481] Make HTTP request/response logging configurable fcsaky
• (flink) branch master updated: [FLINK-38773][table] Fix batch vector search excnode context (#27311) shengkai
• (flink-agents) branch main updated (db9bad9 -> 82b040f) sxnan
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-5a727f26e2 created (now 22712b20b50) github-bot
• (flink) branch master updated: [hotfix][release] Build 2.2 docs in GitHub Action and mark 2.2 as stable in docs (#27315) ruanhang1993
• (flink) branch master updated: [FLINK-38661][docs] Add 2.2.0 release note (#27235) ruanhang1993
• (flink-web) branch asf-site updated (fdcecfc9d -> f13e4c658) ruanhang1993
  • (flink-web) 01/02: Add Flink 2.2.0 release ruanhang1993
• (flink) branch master updated: [FLINK-38767][table] Fix vector search execnode transform name (#27304) shengkai
• (flink) branch master updated (a451e39c6e7 -> 644f4614589) fanrui
  • (flink) 02/02: [FLINK-38746][table-runtime] Fix StackOverflowError in RecordsWindowBuffer.addElement fanrui
  • (flink) 01/02: [hotfix] WindowBuffer implements AutoCloseable to avoid declare close explicitly fanrui
• Re: [I] flink-cdc实时同步表时考虑过滤归档删除问题 [flink-cdc] via GitHub
• (flink-connector-http) branch main updated: [hotfix] Remove options from docs that do not exist in the code fcsaky
• (flink-docker) branch master updated: Add Flink 2.2.0 release to .github/workflows/docker_push.yml (#246) ruanhang1993
• (flink) branch master updated: [FLINK-38768][table] Materialized table fails with validation exception in case of `LATERAL TABLE` snuyanzin
• (flink-agents) annotated tag release-0.1.1-rc1 updated (23ebac6 -> 5be52f6) sxnan
• (flink-docker) branch dev-master updated: Add GPG key for 2.2.0 release (#244) ruanhang1993
• (flink) branch release-1.20 updated: [FLINK-37813][runtime] Pass numberSlots via WorkerRegistration instead of SlotReport (#27100) huweihua
• svn commit: r81167 - dev/flink/flink-2.2.0-rc2 release/flink/flink-2.2.0 leonard
• (flink) annotated tag release-2.2.0 updated (5a336892424 -> 0cc95fcc145) ruanhang1993
• (flink) branch master updated: [FLINK-37813][runtime] Pass numberSlots via WorkerRegistration instead of SlotReport (#27100) huweihua
• (flink) branch master updated: [FLINK-38084][doc] Add download doc for model providers (#27296) shengkai
• (flink) branch release-2.2 updated: [FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow` snuyanzin

• Earlier messages
• Later messages