commits  

Messages by Thread

• (flink) branch release-2.1 updated: [FLINK-38642][checkpoint] Specify thread pool to avoid CheckpointCoordinatorTest hang fanrui
• (flink) branch master updated: [FLINK-38642][checkpoint] Specify thread pool to avoid CheckpointCoordinatorTest hang fanrui
• (flink) branch release-1.20 updated: [FLINK-38642][checkpoint] Specify thread pool to avoid CheckpointCoordinatorTest hang fanrui
• (flink) branch master updated (ac8bec9e572 -> 132492d2407) martijnvisser
• (flink) branch master updated: [FLINK-15973][python] Optimize the execution plan where the same Python UDF is referred in multiple places (#27203) dianfu
• (flink) branch release-1.20 updated: [FLINK-38590][python] Upgrade setuptools to >=75.3 (#27173) dianfu
• (flink) branch release-2.1 updated: [FLINK-38586][table-runtime] Fix ClassCastException when using Delta Join with lookup cache (#27193) xuyangzhong
• (flink) branch master updated: [FLINK-38268][core] Fix incorrect serialization of VARIANT type FLOAT twalthr
• (flink) branch master updated: [FLINK-38547] [flink-protobuf] Upgrade protobuf to 4.32.1 (#27137) fpaul
• (flink-cdc) branch master updated: [FLINK-38620][pipeline-connector][iceberg] fixed NullPointerException while reporting metrics of Iceberg committer. (#4168) kunni
• (flink) branch master updated (583ce7140c6 -> 0ffacdcf7db) zakelly
• (flink) branch master updated: [FLINK-38488][tests] Use 'throws Exception' instead of try-catch-fail in tests in flink-tests (#27092) ruanhang1993
• (flink) branch master updated: [FLINK-38532][table] Make `FRESHNESS` Optional for Materialized Tables snuyanzin
• (flink-agents) branch main updated: [hotfix] Remove onnxruntime version specification on osx. (#309) xtsong
• (flink) branch master updated: [hotfix] Suppress log for reusing sst files (#27197) zakelly
• (flink) branch master updated: [FLINK-38591][python] Add Python AsyncFunction example (#27198) dianfu
• (flink) branch master updated (cedb558bba5 -> a60063f20a1) kunni
• (flink-docker) branch dev-master updated: Change base image from jre-jammy to jre-noble for security improvements mbalassi
• (flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc-sqlserver/com.microsoft.sqlserver-mssql-jdbc-10.2.4.jre8 deleted (was e652c209) github-bot
• (flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc-sqlserver/com.microsoft.sqlserver-mssql-jdbc-11.1.0.jre8-preview created (now 12ee79b8) github-bot
• (flink-docker) branch master updated: Add docker build workflow mbalassi
• (flink) branch master updated: [FLINK-37308] Support pauseOrResumeSplits in HybridSource (#26483) xccui
• (flink-docker) branch master updated: Make only 2.1.1 as latest mbalassi
• (flink-agents) branch release-0.1 updated: [bugfix][test]parsing log path error on windows (#308) xtsong
• (flink-agents) branch main updated: [bugfix][test]parsing log path error on windows (#308) xtsong
• (flink) branch master updated: [FLINK-38563][python][docs] Update documentation of Python AsyncFunction (#27195) dianfu
• (flink) branch master updated: [FLINK-38567][state/forst] Adapt ForStFileSystem to dummy mkdir() implementation (#27185) zakelly
• (flink) branch release-1.20 updated: [FLINK-37266][python] Fix the issue that Python dependencies options doesn't work for PythonDriver dianfu
• (flink) branch release-2.1 updated: [FLINK-37266][python] Fix the issue that Python dependencies options doesn't work for PythonDriver dianfu
• (flink) branch release-2.0 updated: [FLINK-37266][python] Fix the issue that Python dependencies options doesn't work for PythonDriver dianfu
• (flink) branch master updated: [FLINK-37266][python] Fix the issue that Python dependencies options doesn't work for PythonDriver dianfu
• (flink-agents) branch release-0.1 updated: [hotfix] Rename mcp test module to avoid name conflict. xtsong
• (flink-agents) branch main updated (b1c993a -> 770315f) xtsong
  • (flink-agents) 02/02: [api] ReAct agent supports error handling strategy. xtsong
  • (flink-agents) 01/02: [hotfix] Rename mcp test module to avoid name conflict. xtsong
• (flink-agents) branch release-0.1 updated: [runtime] Move PythonActionExecutor to PythonRunnerContextImpl (#301) sxnan
• (flink-agents) branch main updated: [runtime] Move PythonActionExecutor to PythonRunnerContextImpl (#301) sxnan
• (flink-agents) branch main updated (d8f2eea -> 1e581a1) xtsong
  • (flink-agents) 02/02: [hotfix] Adapt ollama example after supporting explicit tool call handling in OllamaChatModel. xtsong
  • (flink-agents) 01/02: [hotfix] Increase request timeout in ollama test to avoid read timeout exception. xtsong
• (flink-agents) branch release-0.1 updated: [api] Support loading Flink legacy yaml config file (#298) sxnan
• (flink-agents) branch main updated: [Feature][integration] Add Azure chat model integration in java (#290) xtsong
• (flink-agents) branch main updated: [api] Support loading Flink legacy yaml config file (#298) sxnan
• (flink) branch master updated (fd273a5a3c3 -> 8688dce69d8) dianfu
• (flink) branch master updated (d9e5778d595 -> fd273a5a3c3) snuyanzin
• (flink-agents) branch main updated (90cd7c6 -> a64601d) xtsong
• (flink-agents) branch main updated (da299d9 -> 90cd7c6) xtsong
  • (flink-agents) 03/03: [Feature] Support ollama embedding models in java. xtsong
  • (flink-agents) 01/03: [hotfix] Fix CI failure due to latest version of the onnxruntime dependency not supporting macos xtsong
  • (flink-agents) 02/03: [hotfix] Improve e2e test robustness xtsong
• (flink-kubernetes-operator) branch main updated: [FLINK-38521] Update Kubernetes Operator to Java Operator SDK v5.1.4 gyfora
• (flink-kubernetes-operator) branch main updated: [FLINK-38552] Fix FlinkStateSnapshot when operator's namespace not in watchNamespaces gyfora
• (flink-kubernetes-operator) branch main updated: [FLINK-38479] Problems after upgrading the operator from 1.12.1 to 1.13.0 gyfora
• (flink-kubernetes-operator) branch main updated: [FLINK-38548] Rename only the name of child deployment for blue/green deployments gyfora
• (flink-kubernetes-operator) branch main updated: [FLINK-38517] Fixed equal check to happen after inplace modifications diffResult gyfora
• (flink) branch master updated: [FLINK-38608][table] Drop abandoned plans without related tests snuyanzin
• (flink) branch master updated (b7acd9fe93f -> c72d7637865) kunni
• (flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc-sqlserver/com.microsoft.sqlserver-mssql-jdbc-10.2.4.jre8 created (now e652c209) github-bot
• (flink-kubernetes-operator) branch main updated: [FLINK-35397] Translate controller-flow documents into Chinese (#934) fanrui
• (flink) branch master updated: [FLINK-38404][test] Fix JobMasterTest by making it scheduler-type aware (#27091) ruanhang1993
• (flink-kubernetes-operator) branch main updated: [FLINK-37126] Add Validator for Autoscaler gyfora
• (flink) branch master updated (77b21e1c033 -> c3bf06141bc) sxnan
  • (flink) 03/03: [FLINK-38581][model] Support surfacing error message sxnan
  • (flink) 01/03: [hotfix][model] Support automatic document generation sxnan
  • (flink) 02/03: [FLINK-38581][model] Model Function supports error handling strategy sxnan
• (flink) branch master updated (5e5f988cfcb -> 77b21e1c033) xuyangzhong
• (flink) branch master updated: [FLINK-38369][runtime] Fix flaky RestClientTest (#27065) ruanhang1993
• (flink) branch master updated: [FLINK-38607][table] Do not store plans with same name twice in plan test files snuyanzin
• (flink) branch master updated: [FLINK-38602][python] Correct misuse of typehint (#27179) ruanhang1993
• (flink) branch master updated: [FLINK-38558] Require copy when use heap timer (#27160) zakelly
• (flink) branch master updated (9b21a9716cc -> 4783610b1f7) ruanhang1993
• (flink) branch master updated (3ab320c3c04 -> 9b21a9716cc) zakelly
• (flink) branch master updated (4931d08d7b2 -> 3ab320c3c04) shengkai
• (flink-agents) branch main updated: [hotfix] toolCallContext not updated in ChatModelAction, causing data loss (#289) sxnan
• (flink-cdc) branch master updated: [FLINK-38478][pipeline-connector][paimon] Generate a random commit user and store it in state. (#4149) kunni
• (flink) branch master updated: [FLINK-38229][runtime-web] Enhanced Job History Retention Policies for HistoryServer (#26902) weizhong
• (flink-docker) branch master updated: Update Dockerfiles for 2.1.1 release (#238) gaborgsomogyi
• (flink-docker) branch dev-2.1 updated: Add GPG key for 2.1.1 release (#237) gaborgsomogyi
• (flink-docker) branch dev-2.0 updated: Add GPG key for 2.0.1 release (#235) zakelly
• (flink-docker) branch master updated: Update Dockerfiles for 2.0.1 release (#236) zakelly
• (flink) branch master updated: [FLINK-38497][connector] FLIP-535: Introduce RateLimiter to Source. leonard
• (flink) branch release-2.0 updated (56814494cac -> bc1563d8454) dianfu
• (flink) branch master updated: [FLINK-38564][connector] FLIP-537: Enumerator maintains global splits distribution for reassignment leonard
• (flink-cdc) branch master updated: [FLINK-38593][test][sqlserver] Fix unstable sqlserver e2e tests via adding more time to wait SqlserverAgent Ready leonard
• (flink) annotated tag release-2.1.1 updated (074f8c5f9ac -> 215ed2cae18) gaborgsomogyi
• svn commit: r80391 - dev/flink/flink-2.1.1-rc1 release/flink/flink-2.1.1 gyfora
• (flink) annotated tag release-2.0.1 updated (1192b3ecd5e -> 86f9c043e68) zakelly
• svn commit: r80389 - dev/flink/flink-2.0.1-rc1 release/flink/flink-2.0.1 zakelly
• (flink) branch master updated: [FLINK-38560][python] Support ordered mode for async function in Python DataStream API dianfu
• (flink) branch release-2.1 updated: [FLINK-38588][python] Fix test case StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory dianfu
• (flink) branch release-2.0 updated: [FLINK-38588][python] Fix test case StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory dianfu
• (flink) branch master updated: [FLINK-38588][python] Fix test case StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory dianfu
• svn commit: r80383 - dev/flink/flink-2.0.1-rc1/python zakelly
• (flink) branch master updated: [FLINK-38561][python] Add retry support for async function in Python DataStream API dianfu
• (flink) branch master updated (f843c121065 -> 5b61b1cda99) xuyangzhong
• (flink) branch master updated: [FLINK-33391][runtime] Support tasks balancing at TM level for Adaptive Scheduler. weizhong
• (flink) branch master updated (eaa1cedb7f4 -> 3fb23beb872) dianfu
• (flink) branch master updated (ed0ae9d54be -> eaa1cedb7f4) snuyanzin
• (flink) branch master updated: [hotfix][docs] Fixed a typo in `state_backends.md` snuyanzin
• (flink) branch master updated: [FLINK-33390][runtime] Support slot balancing at TM level for Adaptive Scheduler weizhong
• (flink-cdc) branch master updated: [FLINK-38550][connect/mongodb] Allow recovery from more change stream expiration scenarios (#4161) yux
• (flink-cdc) branch master updated: [FLINK-34735][docs] Translate "Developer Guide - Understanding Flink CDC API" Page to Chinese leonard
• (flink) branch master updated (e7639297bec -> ca20e1d8a18) weizhong
  • (flink) 02/04: [FLINK-33389][refactor] Extract the assignment logic of task to slot as SlotSharingResolver then refactor the implementation of the default resover. weizhong
  • (flink) 04/04: [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler weizhong
  • (flink) 01/04: [FLINK-33389][refactor] Make TaskBalancedExecutionSlotSharingGroupBuilder as a separated class. weizhong
  • (flink) 03/04: [FLINK-33389][runtime] Add the co-location related methods for related abstractions of adaptive scheduler. weizhong
• (flink) branch master updated: [FLINK-38572][model] Support controlling randomness and format of Chat Model Function (#27155) sxnan
• (flink-connector-pulsar) branch main updated: [FLINK-38545] Update to Flink 1.20.3 and Pulsar 3.0.5 fcsaky
• (flink) branch master updated: [FLINK-38487][build] bump vmImage version to ubuntu-24.04 in GHA snuyanzin
• (flink) branch master updated: [FLINK-38565][table] Reduce `TRY_CAST` chain if source and target types are same snuyanzin
• (flink) branch master updated: [FLINK-38511][table] Join that consumes cdc source without delete may be converted to delta join (#27111) xuyangzhong
• (flink) branch master updated: [FLINK-38430][table] Support runtime config for VECTOR_SEARCH (#27129) shengkai
• (flink) branch release-2.0 updated: [hotfix][docs] Add `avro.` prefix for `timestamp_mapping.legacy` format option key fcsaky
• (flink) branch release-2.1 updated: [hotfix][docs] Add `avro.` prefix for `timestamp_mapping.legacy` format option key fcsaky
• (flink) branch master updated: [hotfix][docs] Add `avro.` prefix for `timestamp_mapping.legacy` format option key fcsaky
• (flink) branch master updated: [FLINK-38554][table] Fix rowCount cost for FlinkLogicalMultiJoin dwysakowicz
• (flink) branch release-1.19 updated (4ee1a82388c -> 9ecbcad6d37) roman
  • (flink) 01/02: [FLINK-35556] Fix constant in RocksDBSharedResourcesFactory roman
  • (flink) 02/02: [FLINK-35556] Harden RocksDBSharedResourcesFactoryTest roman
• (flink) branch release-1.20 updated (87f898ec800 -> ecc05305f2b) roman
  • (flink) 02/02: [FLINK-35556] Harden RocksDBSharedResourcesFactoryTest roman
  • (flink) 01/02: [FLINK-35556] Fix constant in RocksDBSharedResourcesFactory roman
• (flink) branch release-2.0 updated (2a5ad332ca9 -> e3adc2694fe) roman
  • (flink) 01/02: [FLINK-35556] Fix constant in RocksDBSharedResourcesFactory roman
  • (flink) 02/02: [FLINK-35556] Harden RocksDBSharedResourcesFactoryTest roman
• (flink) branch release-2.1 updated (39d20cf1991 -> 173edf679c1) roman
  • (flink) 02/02: [FLINK-35556] Harden RocksDBSharedResourcesFactoryTest roman
  • (flink) 01/02: [FLINK-35556] Fix constant in RocksDBSharedResourcesFactory roman
• (flink-connector-http) branch main updated: [hotfix] Move docs content to the correct location fcsaky
• (flink) branch master updated (5b9e453d7fd -> 31b44d2c050) roman
• (flink-connector-http) branch main updated: [FLINK-38494] Add Chinese docs folder fcsaky
• (flink) branch release-2.1 updated: [FLINK-38399][table-planner] Convert join to delta join if join key contains one of the indexes in the source xuyangzhong
• (flink) branch master updated (5e4ae60590d -> 5b9e453d7fd) sxnan
• (flink) branch master updated: [FLINK-38553][table-planner] CastRuleProvider should treat identity casts with highest precedence twalthr
• (flink) branch master updated (64ce0c28363 -> 076e3e9a2e5) xuyangzhong
• (flink-cdc) branch master updated: [FLINK-38546][cdc/mysql] Improve error message for table discovery failure due to MySQL permission (#4158) kunni
• (flink) branch master updated: [FLINK-38427][table] Support to serde VECTOR_SEARCH exec node (#27127) shengkai
• (flink) branch master updated: [FLINK-38428][table] Support to run vector search with constant value input (#27130) shengkai
• (flink-agents) branch release-0.1 updated (226164d -> c95b718) sxnan
  • (flink-agents) 02/02: [hotfix] Always include assistant message after prompt applied sxnan
  • (flink-agents) 01/02: [hotfix] Fix tool conversion in openai_chat_model sxnan
• (flink-agents) branch main updated (d1a419b -> 7325f45) sxnan
  • (flink-agents) 01/02: [hotfix] Fix tool conversion in openai_chat_model sxnan
  • (flink-agents) 02/02: [hotfix] Always include assistant message after prompt applied sxnan
• (flink) branch master updated: [FLINK-38537][runtime] Fix the bug that can't compare correctly Double.NaN related attributes in StatsSummaryDto#equals method fanrui
• (flink-connector-http) branch main updated: [FLINK-38465] Add ability to continue on error, and support metadata column fcsaky
• (flink) branch master updated: [FLINK-38528][table] Introduce async vector search operator (#27126) shengkai
• (flink) branch master updated: [FLINK-38495][table-runtime] Introduce cache in delta join operator (#27099) xuyangzhong
• (flink-cdc) branch master updated: [FLINK-38540] Fix unintended object reuse in `TransformExpressionKey` (#4157) kunni
• (flink-agents) branch main updated: [Feature][Integrations][Java] Support explicit tool call handling in OllamaChatModel (#279) xtsong
• (flink-connector-pulsar) branch main updated (6f51a0a -> f3e9959) fcsaky
  • (flink-connector-pulsar) 01/01: [hotfix] Apply spotless formatting fcsaky
• (flink-connector-pulsar) branch main updated: [hotfix] Adapt javadoc to checkstyle rules fcsaky
• (flink-connector-pulsar) branch main updated: [hotfix] Standardize CI and update it to Flink 1.20 fcsaky
• (flink-connector-pulsar) branch main updated: [FLINK-35477] Make initial cursor position configurable fcsaky
• (flink-connector-pulsar) branch main updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch fcsaky
• (flink) branch master updated (e24149ba9a4 -> 1a7c0f1bcdc) roman
  • (flink) 03/03: [FLINK-38461] Introduce SinkUpsertMaterializerV2 roman
  • (flink) 02/03: [hotfix] Introduce ProjectedRowData.isNullAtNonProjected roman
  • (flink) 01/03: [hotfix] Move RowTypeUtils to flink-table-common roman
• (flink-connector-pulsar) branch main updated: [FLINK-35468][docs] Simplify `isEnableAutoAcknowledgeMessage` config comment fcsaky
• (flink-connector-pulsar) branch v4.1 updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch fcsaky
• (flink) branch master updated (7b783591192 -> e24149ba9a4) shengkai
• (flink) branch release-2.1 updated: [FLINK-38499][runtime] Limit max sleep time in Curator for Zookeeper HA xtsong
• (flink) branch release-2.0 updated: [FLINK-38499][runtime] Limit max sleep time in Curator for Zookeeper HA xtsong
• (flink) branch master updated (0e4e6d7082e -> 7b783591192) xtsong
• (flink-agents) branch release-0.1 updated: [runtime] Execute action within user code class loader context. (#277) xtsong
• (flink-agents) branch main updated: [runtime] Execute action within user code class loader context. (#277) xtsong
• (flink) branch master updated: [FLINK-38425][table] Add rule to convert correlate node to vector search physical node (#27121) shengkai
• (flink) branch master updated (e44d6387dba -> 11a68b694c4) weizhong
• (flink-web) branch asf-site updated (fa3cebade -> a09ae1c72) xtsong
  • (flink-web) 02/02: Rebuild website xtsong
  • (flink-web) 01/02: [hotfix] update slack invite url xtsong
• (flink) branch release-2.0 updated (e410b24d545 -> 4bb815a753a) fanrui
  • (flink) 01/02: [FLINK-38415][refactor] Extract single state handle processing logic for testability fanrui
  • (flink) 02/02: [FLINK-38415][checkpoint] Disable auto compaction to prevent Index OutOfBounds fanrui
• (flink) branch master updated: [FLINK-38474][build] Add java25-target profile snuyanzin
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated: print java ver fcsaky
• (flink) branch release-2.1 updated: [FLINK-38408][checkpoint] Complete the checkpoint CompletableFuture after updating statistics to ensures semantic correctness and prevent test failure fanrui
• (flink) branch master updated: [FLINK-38386][build] Fix attaching type annotations for jdk23+ snuyanzin
• (flink-connector-kafka) branch main updated: [FLINK-38453] Add full splits to KafkaSourceEnumState arvid
• svn commit: r79532 - dev/flink/flink-1.20.3-rc1 release/flink/flink-1.20.3 xtsong
• [I] StreamPhysicalWindowAggregate doesn't support consuming update and delete changes [flink-cdc] via GitHub
  • Re: [I] StreamPhysicalWindowAggregate doesn't support consuming update and delete changes [flink-cdc] via GitHub
  • Re: [I] StreamPhysicalWindowAggregate doesn't support consuming update and delete changes [flink-cdc] via GitHub
  • Re: [I] StreamPhysicalWindowAggregate doesn't support consuming update and delete changes [flink-cdc] via GitHub
  • Re: [I] StreamPhysicalWindowAggregate doesn't support consuming update and delete changes [flink-cdc] via GitHub
• (flink-shaded) branch master updated: [FLINK-38320] Upgrade Netty version to 4.2.4.Final (#150) rmetzger
• (flink-agents) branch release-0.1 updated: [doc] Reorganize installation guide and simplify quickstart preparation sections (#271) xtsong
• (flink) branch master updated: [FLINK-38390][table] Compiliation of flink-core and flink-table-planner fails because of annotation processors snuyanzin
• (flink-shaded) branch release-17.0 created (now d18d236) rmetzger
• (flink-agents) branch main updated (bd2f2f6 -> b23644d) xtsong
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (66492152 -> a88fa372) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-cdc) branch master updated: [FLINK-38452] Fix unable to read incremental data from MongoDB collections with dots (`.`) (#4148) yux
• (flink) branch release-2.1 updated: [FLINK-38272][runtime] Fix unstable BatchJobRecoveryTest zhuzh
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (eb629482 -> 6f2d645c) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-agents) branch main updated: [hotfix] Correcting improper uses of the Pemja (#275) sxnan

• Earlier messages
• Later messages