commits  

Messages by Thread

• (flink-connector-kafka) branch main updated: [FLINK-38451] Stop logging interrupts as ERROR arvid
• (flink) branch master updated (6d738f4aa36 -> b4eaf3ce6fc) fanrui
  • (flink) 02/02: [FLINK-38415][checkpoint] Disable auto compaction to prevent Index OutOfBounds fanrui
  • (flink) 01/02: [FLINK-38415][refactor] Extract single state handle processing logic for testability fanrui
• (flink) branch master updated (01735fa853f -> 6d738f4aa36) snuyanzin
• (flink) branch master updated (538c24c8bf4 -> ba8312f05b4) twalthr
• (flink-kubernetes-operator) branch main updated: [FLINK-38448] Rework doc build and doc deployment (#1035) fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (4f2de985 -> 0221bab1) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (9a47f0b0 -> 4f2de985) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (a88fa372 -> 9a47f0b0) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (a81751d1 -> 66492152) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (2ff02cca -> 918ad608) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (4a5e46c2 -> 2ff02cca) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (d921d91b -> 119a5afa) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated: Fix git safe dir error fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (fcb4d447 -> 8171f59d) fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (c0161e1b -> fcb4d447) fcsaky
• (flink-agents) branch main updated: [Runtime] Simplify the vector store setup process (#231) xtsong
• Re: [I] flink1.18.1 + flink-cdc3.0.1 无法通过配置scanNewlyAddedTableEnabled=true实现无需重启作业能够识别符合tableList(正则表达式)的表采集数据 [flink-cdc] via GitHub
• (flink) branch release-2.1 updated: [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. weizhong
• (flink-cdc) branch master updated: [FLINK-38440][pipeline-connector][iceberg] fixed the problem of writing SMALLINT/TINYINT data to Iceberg. (#4146) kunni
• (flink) branch release-1.20 updated: [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. weizhong
• (flink) branch release-2.0 updated: [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. weizhong
• (flink-cdc) branch master updated: [FLINK-38232] [docs] Update the connector documentation to reflect the new features in Flink CDC 3.5.0 (#4102) kunni
• (flink-kubernetes-operator) annotated tag release-1.13.0-rc1 deleted (was 139a2ab7) fcsaky
• (flink-kubernetes-operator) branch main updated: [hotfix] Bump `rsync-deployments` version to fix doc CI fcsaky
• (flink-kubernetes-operator) annotated tag release-1.13.0 updated (b40c5539 -> 42dbde25) fcsaky
• (flink-kubernetes-operator) branch main updated: [release] Docs, CI and config updates after release cut fcsaky
• (flink-agents) branch main updated: [integration] Configure the model name uniformly in ChatModelSetup. (#224) xtsong
• (flink-shaded) branch master updated: [FLINK-38280][Build/Shaded] Update ASM to 9.8. snuyanzin
• (flink-agents) branch main updated (b23c57f -> 23ff0e1) xtsong
  • (flink-agents) 01/03: [hotfix] Rename BaseTool to Tool. xtsong
  • (flink-agents) 03/03: [api] Add function tool to represent a tool keeping method in api. xtsong
  • (flink-agents) 02/03: [api] Combine add methods to add_resource. xtsong
• (flink-agents) branch main updated (2a4d808 -> b23c57f) xtsong
  • (flink-agents) 01/04: [hotfix] Move test purpose example to e2e tests package in python. xtsong
  • (flink-agents) 04/04: [runtime][java] Auto create StreamTableEnvironment when need. xtsong
  • (flink-agents) 02/04: [hotfix] Move test purpose example to e2e test module in java. xtsong
  • (flink-agents) 03/04: [runtime][python] Fix npe when integrate agent from datastream to table. xtsong
• svn commit: r79615 - dev/flink/flink-kubernetes-operator-1.13.0-rc1 release/flink/flink-kubernetes-operator-1.13.0 gyfora
• (flink) branch master updated: [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. weizhong
• (flink-kubernetes-operator) branch main updated: [FLINK-38437] Bump Java Operator SDK version to 5.1.3 in Flink Kubernetes Operator (#1032) mxm
• svn commit: r79606 - in dev/flink: flink-cdc-3.5.0-rc1 flink-cdc-3.5.0-rc2 kunni
• svn commit: r79605 - dev/flink/flink-cdc-3.5.0-rc3 release/flink/flink-cdc-3.5.0 leonard
• (flink-web) branch asf-site updated: Add FlinkCDC v3.5.0. (#806) kunni
• (flink-cdc) annotated tag release-3.5.0 updated (d15c5de8a -> c7ba6808b) kunni
• svn commit: r79603 - in dev/flink: flink-cdc-3.5.0-rc1 flink-cdc-3.5.0-rc2 flink-cdc-3.5.0-rc3 kunni
• (flink) branch release-2.0 updated: [FLINK-37747][runtime] Use old subtask count for restored committable objects (#26518) fpaul
• (flink-agents) branch main updated (de10215 -> 82c275e) xtsong
  • (flink-agents) 03/03: [example] Add react agent quick start example and refactor workflow agent example. xtsong
  • (flink-agents) 01/03: [hotfix] Append input messages to prompt. xtsong
  • (flink-agents) 02/03: [api] Extract ResourceDescriptor abstraction. xtsong
• (flink-agents) branch main updated: [runtime] ActionExecutionOperator handle watermark properly (#186) sxnan
• (flink-agents) branch main updated: [runtime] Bump flink version to 1.20.3 (#218) sxnan
• (flink) branch master updated: [FLINK-38363][Runtime] WindowedStream.trigger supports trigger with async state (#27021) zakelly
• (flink-agents) branch main updated: [runtime] Only persist memory changes to flink state when action is finished (#219) sxnan
• (flink-docker) branch master updated: Update Dockerfiles for 1.20.3 release (#234) sxnan
• (flink-docker) branch dev-1.20 updated: Add GPG key for 1.20.3 release (#233) sxnan
• (flink-agents) branch main updated: [hotfix] Correct menu titles (#214) xtsong
• (flink) branch master updated (a70ca9c029b -> a1ec5027c07) lincoln
  • (flink) 02/02: [FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule lincoln
  • (flink) 01/02: [FLINK-38400][table] Pre-step of the fix: copy AggregateReduceFunctionsRule and format lincoln
• (flink-agents) branch main updated: [Improvement] Add inherited parameters to ChatModelSetup/EmbeddingModelSetup docstrings (#195) sxnan
• (flink-shaded) branch master updated: [hotfix] Bump Java setup action to version 5 snuyanzin
• (flink-agents) branch main updated: [hotfix] Fix the unsupported short type configuration option (#213) sxnan
• (flink) annotated tag release-1.20.3 updated (01e3a6d78d5 -> 77a6c515e88) sxnan
• (flink-agents) branch main updated: [docs] Add a FAQ section for common questions (#192) sxnan
• (flink-agents) branch main updated (8e8f650 -> 23bce98) xtsong
• (flink-agents) branch main updated: [Docs] Draft the barebones of project docs (#191) sxnan
• (flink-agents) branch main updated (4c0ea9a -> 96c2a9d) xtsong
  • (flink-agents) 02/03: [package] Support package flink-agents-dist jar in python wheel. xtsong
  • (flink-agents) 01/03: [package] Add flink-agents-dist module to assemble jars. xtsong
  • (flink-agents) 03/03: [runtime] Avoid manually adding the framework jars in user code. xtsong
• (flink) branch master updated (8a1e8f57492 -> 04e6437dd4d) twalthr
• (flink-cdc) branch master updated: [FLINK-37199][doc] Update configuration in quickstart. (#3880) kunni
• (flink) branch master updated: [FLINK-38412][table-planner] Adjust test to not rely on eventually expired records twalthr
• (flink) branch master updated (0dc3220b71a -> 61a8b11f2ef) pnowojski
  • (flink) 01/03: [FLINK-38353][spans] Add support for nested spans to metrics reporting. pnowojski
  • (flink) 03/03: [FLINK-38353][docs] Update docs for children spans pnowojski
  • (flink) 02/03: [FLINK-38353][spans] Report checkpoint sub spans pnowojski
• (flink-kubernetes-operator) branch main updated: [FLINK-38409] Showcase in Helm chart values.yaml that config.yaml can be used (#1022) mxm
• (flink) branch master updated: [FLINK-38410][table-planner] Add test id to assertion message twalthr
• (flink) branch master updated: [FLINK-38224][table-planner] Do not convert to delta join when the sink is a retract sink (#26907) xuyangzhong
• (flink-cdc) annotated tag release-3.5.0-rc3 updated (d15c5de8a -> 59af46074) kunni
• (flink-cdc) branch build-release deleted (was 9eede3d54) kunni
• (flink-cdc) branch build-release created (now 9eede3d54) kunni
  • (flink-cdc) 01/01: [build] Automate property replacement in pom.xml and exclude the release directory from license checks. kunni
• (flink) branch master updated (04f3047d614 -> ecd284da336) snuyanzin
• (flink-cdc) annotated tag release-3.5.0-rc2 updated (d6ceee8f5 -> b8d225094) kunni
• (flink-agents) branch main updated (88e886d -> 5f668c7) xtsong
  • (flink-agents) 04/04: [api] Support built-in ReAct Agent in java. xtsong
  • (flink-agents) 01/04: [hotifx] Relocate Action class. xtsong
  • (flink-agents) 02/04: [hotfix] Fix register resources in environment. xtsong
  • (flink-agents) 03/04: [plan] Add built-in chat model action and tool call action in java. xtsong
• (flink-agents) branch main updated: [Feature][API][python] Use Python property to simplify the getter in RunnerContext (#183) sxnan
• (flink-cdc) branch master updated: [FLINK-38398][pipeline-connector][postgres] fixed Date convert adapt connect (#4133) kunni
• svn commit: r79454 - dev/flink/flink-cdc-3.5.0-rc2 kunni
• (flink-cdc) branch release-3.5 updated: [FLINK-38398][pipeline-connector][postgresql] Improve PostgresSQL temporal field type supported with debezium.time.precision.mode=connect config (#4132) kunni
• (flink-connector-cassandra) branch main updated (cc478e2 -> 84c3fa0) echauchot
  • (flink-connector-cassandra) 05/08: [FLINK-37937] Make estimatedTableSize calculated during split preparation accessible to tests and not call estimate_size during tests. In refreshSizeEstimates wait until system.size_estimates has at least a row that has non-null mean_partition_size echauchot
  • (flink-connector-cassandra) 03/08: [FLINK-37937] change timeouts using cassandra.yaml instead of java options that are not interpreted by Cassandra cluster echauchot
  • (flink-connector-cassandra) 08/08: [FLINK-37937] Rebase on main and reference cassandraContainer1 instead of cassandraContainer echauchot
  • (flink-connector-cassandra) 07/08: [FLINK-37937] Deal with timeouts: put consistency level to ONE to be coherent between read and write request because CL=ANY in write requests could lead to hint writes that would be invisible to subsequent read requests. Raise write request timeout to the same timeout as read request. Put replication factor to 2 to deal with temporary down cassandra container. But back sequential start of the 2 containers. echauchot
  • (flink-connector-cassandra) 04/08: [FLINK-37937] upgrade to latest cassandra 4.x. reformat echauchot
  • (flink-connector-cassandra) 02/08: [FLINK-37937] Use nodetool refreshsizeestimates in addition to flush to update size estimates: flush updates the SSTables and refreshsizeestimates updates the size estimates based on them echauchot
  • (flink-connector-cassandra) 06/08: [FLINK-37937] Improve start/stop for the 2-container cluster. echauchot
  • (flink-connector-cassandra) 01/08: [FLINK-37937] Add a node to Cassandra testContainers cluster echauchot
• (flink) branch release-2.1 updated: [FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode (#27015) mxm
• (flink) branch release-1.19 updated: [FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode (#27016) mxm
• (flink-cdc) branch release-3.5 updated: [BP-3.5][FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules (#4130) kunni
• (flink-cdc) branch master updated: [FLINK-38398[pipeline-connector][postgresql] Improve PostgresSQL temporal field type supported with debezium.time.precision.mode=connect config(#4129) kunni
• (flink-agents) branch main updated: [hotfix] fix reasoning extraction from Tongyi model (#169) sxnan
• (flink-agents) branch main updated: [Feature] Remove the name field of Resource (#177) sxnan
• (flink-cdc) branch master updated: [FLINK-38393][runtime/transform] Loosen schema consistency check for unreachable rules (#4126) kunni
• (flink-agents) branch main updated: [Feature] [api] Introduce per action state consistency API (#138) xtsong
• (flink) branch master updated: [FLINK-38379][table] Adjust `visitMultiJoin` in `RelTimeIndicatorConverter` to use fields and not rows snuyanzin
• svn commit: r79429 - dev/flink/flink-1.20.3-rc1 sxnan
• (flink-connector-shared-utils) branch release_utils updated: Check for GNU tar to avoid MAC OS specific files arvid
• (flink-agents) branch main updated: [Feature] [integration][python] OpenAI embedding model integration (#176) xtsong
• (flink) annotated tag release-1.20.3-rc1 updated (01e3a6d78d5 -> 10ca325cc95) sxnan
• svn commit: r79428 - in dev/flink/flink-1.20.3-rc1: . python sxnan
• (flink-agents) branch main updated: [Feature] Support Chroma Cloud (#188) xtsong
• (flink) branch master updated (f3bd4a4962f -> 58c5066f7a6) twalthr
• (flink-agents) branch main updated (f0cb80a -> 1e2098c) xtsong
  • (flink-agents) 03/03: [api][java] Support pass additional config for action. xtsong
  • (flink-agents) 02/03: [api][java] Support add resources and actions to environment and agent. xtsong
  • (flink-agents) 01/03: [api] Add correspond annotation after sperate chat model abstraction. xtsong
• (flink) branch release-1.20 updated: [release-1.20][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode (#27013) mxm
• (flink) branch release-2.0 updated: [release-2.0][FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode (#27014) mxm
• (flink) branch master updated: [FLINK-38391][build] Bump maven-shade-plugin to 3.6.1 snuyanzin
• (flink) branch master updated: [FLINK-38385][build] Bump mockito to 5.19.0 and byte-buddy to 1.17.6 snuyanzin
• (flink) branch master updated: [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error snuyanzin
• (flink) branch release-1.20 updated: [FLINK-37747][runtime] Use old subtask count for restored committable objects. martijnvisser
• (flink) branch master updated: [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) twalthr
• (flink-kubernetes-operator) branch main updated: [FLINK-38381] Enumerate Kafka partitions across Kafka clusters (#1030) mxm
• (flink) branch master updated: [FLINK-38384][build] Bump lombok to 1.18.42 snuyanzin
• (flink-cdc) branch master updated: [build] Update version to 3.6-SNAPSHOT. (#4125) kunni
• (flink-cdc) annotated tag release-3.5.0-rc1 updated (7d449428e -> 8a7956526) kunni
• svn commit: r79402 - dev/flink/flink-cdc-3.5.0-rc1 kunni
• (flink) branch release-2.1 updated: [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expressions other than literal in PyFlink (#26987) dianfu
• (flink) branch release-2.0 updated: [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expressions other than literal in PyFlink (#26987) dianfu
• (flink) branch master updated: [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expressions other than literal in PyFlink (#26987) dianfu
• (flink-cdc) branch release-3.5 created (now 36a485d1ef) kunni
  • (flink-cdc) 01/01: [docs] Update docs for release-3.5. kunni
• (flink-cdc) branch master updated: [Flink-38277] [postgres] Drop slot when startup.mode=snapshot and skip backfill.(#4113) kunni
• svn commit: r79388 - dev/flink/flink-kubernetes-operator-1.13.0-rc1 fcsaky
• (flink-kubernetes-operator) annotated tag release-1.13.0-rc1 deleted (was 6bc852cf) fcsaky
• (flink-cdc) branch master updated: [minor] Fix potential sql connection statement issue. (#4123) kunni
• (flink) branch master updated (d08abb7b169 -> 335621e598c) mxm
• (flink-kubernetes-operator) branch main updated: Update Minikube version gyfora
• (flink-shaded) branch snuyanzin-patch-1 created (now e2cd540) snuyanzin
  • (flink-shaded) 01/01: [hotfix] Bump Java setup action to version 5 snuyanzin
• (flink-kubernetes-operator) branch release-1.13 created (now d26d69b2) fcsaky
  • (flink-kubernetes-operator) 01/01: [release] Docs, CI and config updates after release cut fcsaky
• (flink-kubernetes-operator) annotated tag release-1.13.0-rc1 updated (b40c5539 -> 139a2ab7) fcsaky
• (flink-agents) branch main updated: [docs] Update installation instructions for Flink Agents with PyPI and source build details (#170) sxnan
• (flink-kubernetes-operator) branch main updated: [release] Update version to 1.14-SNAPSHOT fcsaky
• (flink-kubernetes-operator) branch release-1.13 updated (d26d69b2 -> cdb6c464) fcsaky
  • (flink-kubernetes-operator) 02/02: Update Minikube version fcsaky
  • (flink-kubernetes-operator) 01/02: [FLINK-38293] Update Checkstyle version and related rules in Kubernetes Operator fcsaky
• (flink-kubernetes-operator) annotated tag release-1.13.0-rc1 updated (9f4dec91 -> 6bc852cf) fcsaky
• svn commit: r79385 - dev/flink/flink-kubernetes-operator-1.13.0-rc1 fcsaky
• (flink) branch master updated (80a95ef5a64 -> d08abb7b169) roman
  • (flink) 01/02: [FLINK-37955] Don't load all records into main memory to avoid OOM roman
  • (flink) 02/02: [FLINK-37955] Add test for duplicated results from StreamingJoinOperator roman
• (flink) branch release-2.1 updated: [FLINK-38332][python] Bump pemja to 0.5.5 (#26997) dianfu
• (flink-cdc) branch master updated: [FLINK-37065]: Fix the problem that MySQL cdc may lose/skip data during recovering from the checkpoint (#3845) kunni
• (flink) branch release-1.20 updated: [FLINK-38060][ci] Fix github action failed to build python wheel on linux sxnan
• (flink-kubernetes-operator) branch main updated: [FLINK-38124][docs] Add README for Autoscaling example (#1024) mxm
• (flink) branch release-1.20 updated: [FLINK-38332][python] Bump pemja to 0.5.5 (#26995) dianfu
• (flink-cdc) branch master updated: [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. (#3590) kunni
• (flink) branch release-1.20 updated: [FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager (#26971) zakelly
• (flink) branch master updated: [FLINK-32695] Migrated Common Test cases fpaul
• (flink-agents) branch main updated (e8e6cf7 -> 44e123f) xtsong
• (flink-agents) branch main updated (62ff960 -> 401b928) sxnan
• (flink-agents) branch main updated: [hotfix] fix the title of docs index (#184) xtsong
• (flink-cdc) branch master updated: [minor] Update flink-cdc.sh to handle all .jar files even inside subdirectories (#4071) kunni
• (flink-cdc) branch FLINK-38206 deleted (was 924df1c70) kunni
• (flink) branch master updated (551c3d7036f -> d6ce0d8c7d3) leonard
• (flink-kubernetes-operator) branch release-1.11 updated: version 2.0 update mxm
• (flink-kubernetes-operator) branch main updated: [FLINK-38293] Update Checkstyle version and related rules in Kubernetes Operator mxm
• svn commit: r79368 - release/flink xtsong
• (flink-agents) branch main updated (2a81e77 -> 62ff960) xtsong
  • (flink-agents) 02/04: [infra] Upgrade minimum python version from 3.9 to 3.10 and fix ruff error. xtsong
  • (flink-agents) 01/04: [hotfix] Fix code format xtsong
  • (flink-agents) 04/04: [api][python] Add built-in mcp support. xtsong
  • (flink-agents) 03/04: [hotfix] Refactor Prompt abstraction. xtsong
• (flink-agents) branch main updated: [hotfix] Adapt ollama integration after refactor chat model api. (#182) xtsong
• (flink) branch master updated: [FLINK-37295][doc] Add state ttl migration compatibility to docs gaborgsomogyi
• (flink) branch release-2.0 updated: [FLINK-38332][python] Bump pemja to 0.5.5 (#26996) dianfu
• (flink-cdc) branch master updated: [minor][pipeline-connector][maxcompute][e2e] Remove repeated dependency of maxcompute, and change the phase of "download-flink-release" to test in pipeline-e2e-test. (#3991) kunni
• (flink-cdc) branch master updated: [FLINK-38358][pipeline-connector][mysql] Ignore trailing spaces in table capturing rules. (#4119) kunni
• (flink-cdc) branch master updated: [FLINK-38359][pipeline-connector][paimon] Avoid exception when writing update event to Append only table. (#4120) kunni

• Earlier messages
• Later messages