commits  

Messages by Thread

• (flink-connector-http) branch main updated (0c46b8e -> 645c950) fcsaky
• (flink) branch release-2.0 updated: [FLINK-38513][python]Fix pandas 2.3+ cp39 issue gaborgsomogyi
• (flink-connector-http) branch main updated (645c950 -> 330d0b4) fcsaky
• (flink-agents) branch release-0.1 updated: [readme] Add user slack channel. (#260) xtsong
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (f1abea3c -> fd1a2863) fcsaky
  • (flink-kubernetes-operator) 01/01: Rework doc build to not use shell script and Docker img fcsaky
• (flink) branch release-1.20 updated: [FLINK-38487][build] bump vmImage version to ubuntu-24.04 gaborgsomogyi
• (flink) branch master updated: [FLINK-38424][planner] Support to parse VECTOR_SEARCH function (#27039) shengkai
• (flink) branch release-2.0 updated: [FLINK-38060][ci] Fix github action failed to build python wheel on linux (#27120) zakelly
• (flink) branch release-1.20 updated: [FLINK-38513][python]Fix pandas 2.3+ cp39 issue gaborgsomogyi
• (flink) branch release-2.1 updated: [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend (#27109) zakelly
• (flink) branch master updated: [FLINK-38423][table-api] Add VECTOR_SEARCH connector API (#27037) shengkai
• (flink) branch master updated (1b01b521153 -> 78f6e779137) zakelly
• svn commit: r80018 - dev/flink/flink-agents-0.1.0-rc1 release/flink/flink-agents-0.1.0 xtsong
• (flink-connector-cassandra) branch main updated (84c3fa0 -> bbc8019) echauchot
  • (flink-connector-cassandra) 02/02: [FLINK-38485] Make setup and teardown (test environment start/stop, tables creation, test data insertion) global for the whole test case instead of once per test to avoid too long test run. echauchot
  • (flink-connector-cassandra) 01/02: [FLINK-38485] Upgrade testContainers to v1.20.2 which is compiled with a commons-compress version closer to the one flink uses and keep commons-compress transitive dep exclusion to favor flink's. echauchot
• (flink) branch master updated: [FLINK-38339][runtime] Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history. (#26982) weizhong
• (flink) branch master updated: [FLINK-37541][table-planner] Deprecate getTargetColumns in DynamicTableSink.Context (#26381) xuyangzhong
• (flink) branch release-2.0 updated: [FLINK-38483][checkpoint] Fix the bug that Job cannot be recovered from unaligned checkpoint due to `Cannot get old subtasks from a descriptor that represents no state.` exception fanrui
• (flink) branch release-2.1 updated (2a4f1f2ee7f -> 1c3b53d5311) 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-agents) branch release-0.1 updated: [doc] Add Consistency Guarantee section in deployment documentation. (#269) sxnan
• (flink) branch release-2.1 updated: [FLINK-38487][build] bump vmImage version to ubuntu-24.04 fanrui
• (flink) branch master updated: [FLINK-38493][table] Port Calcite's fix for `LATERAL` is lost while validation snuyanzin
• (flink) branch release-2.1 updated: [FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule lincoln
• Re: [I] [Bug] [mongodb] pull big collection (>20 billion records) lead to checkpoint hang or OOM [flink-cdc] via GitHub
• (flink-agents) branch main updated: [readme] Add user slack channel. (#260) xtsong
• (flink-agents) branch main updated: [readme] add documentation link xtsong
• (flink-agents) branch release-0.1 updated: [doc] Add instructions for java in Prompt, Tool and ChatModel doc. (#263) xtsong
• (flink-agents) branch main updated: [doc] Add instructions for java in workflow agent and react agent doc. (#258) xtsong
• (flink) branch release-1.20 updated: [FLINK-38490][release] Update japicmp configuration for 1.20.3 (#27094) sxnan
• (flink-agents) branch release-0.1 updated: [doc] Update the index page. (#262) xtsong
• (flink-agents) branch main updated: [doc] Update the index page. (#262) xtsong
• (flink-agents) branch main updated: [docs][release] Build 0.1 docs in GitHub Action (#259) xtsong
• (flink-agents) branch main updated (0fd0600 -> 53d29e6) xtsong
  • (flink-agents) 02/02: [ci] Add release scripts xtsong
  • (flink-agents) 01/02: [hotfix] Fix option test xtsong
• (flink) branch master updated (3478ddf08bc -> 1f34a075627) zhuzh
• (flink-agents) branch release-0.1 updated: [hotfix] Update NOTICE and linceses. (#255) sxnan
• (flink-agents) branch main updated: [hotfix] Update NOTICE and linceses. (#255) sxnan
• (flink-agents) annotated tag release-0.1.0-rc1 updated (3da6b44 -> 2abe6d9) sxnan
• svn commit: r79861 - in dev/flink/flink-agents-0.1.0-rc1: . python sxnan
• (flink-agents) branch main updated: [docs] Update the configuration introduction for Flink agents (#232) xtsong
• (flink) branch master updated: [FLINK-38216][checkpoint][refactor] Split EndOfChannelStateEvent into EndOfInputChannelStateEvent and EndOfOutputChannelStateEvent fanrui
• (flink-cdc) branch master updated: [FLINK-36631][source-connector][oracle] Add oracle read data by specific offset (#3675) kunni
• (flink) branch master updated (d567a9dee4d -> 45c47ba1b5f) dwysakowicz
  • (flink) 01/06: [FLINK-38211][table] Update explain for MultiJoin node dwysakowicz
  • (flink) 06/06: [FLINK-38211][table] Regenerate description restore tests dwysakowicz
  • (flink) 02/06: [FLINK-38211][table] Update test plans and restore tests dwysakowicz
  • (flink) 05/06: [FLINK-38211][table] Skip pos 0 for joinTypes and joinConditions dwysakowicz
  • (flink) 04/06: [FLINK-38211][table] Move testMultiSinkOnMultiJoinedView to MJ tests dwysakowicz
  • (flink) 03/06: [FLINK-38211][table] Remove joinFilter and remame rowType dwysakowicz
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (16c828af -> a92006f2) fcsaky
  • (flink-kubernetes-operator) 01/01: print java ver fcsaky
• (flink-agents) branch main updated: [docs] Update workflow agent development doc. (#233) xtsong
• (flink) branch release-2.1 updated: [FLINK-16686][State] Set classloader for compaction filters (#27075) zakelly
• (flink) branch release-2.0 updated: [FLINK-16686][State] Set classloader for compaction filters (#27074) zakelly
• (flink) branch release-1.20 updated: [FLINK-16686][State] Set classloader for compaction filters (#27073) zakelly
• (flink) branch master updated: [FLINK-38454][core] Fix inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus twalthr
• (flink-cdc) branch master updated: [minor][hotfix][docs] Fix some error in postgres yaml document. (#4140) kunni
• (flink) branch master updated (a644a8243a5 -> 4c6defbe529) dwysakowicz
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated: dev fcsaky
• (flink) branch master updated: [FLINK-38462] Introduce state backend type identifier roman
• (flink) branch master updated: [FLINK-38470][table] Make `CreateMaterializedTableOperation` return `ResolvedCatalogMaterializedTable` snuyanzin
• (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

• Earlier messages
• Later messages