commits  

Messages by Thread

• (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
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (119a5afa -> 4a5e46c2) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• svn commit: r79862 - dev/flink/flink-agents-0.1.0-rc1 sxnan
• (flink-agents) branch main updated: [docs] Update the monitoring introduction for Flink agents (#249) xtsong
• (flink-agents) branch main updated: [docs] Update integrate with flink doc. (#241) xtsong
• (flink-connector-http) branch main updated: [hotfix] Fix version string in weekly CI, also bump to latest patch version fcsaky
• (flink-kubernetes-operator) branch release-1.12 updated: [FLINK-38448] Rework doc build and doc deployment (#1035) fcsaky
• (flink-agents) branch main updated (53d29e6 -> 33f0bdf) xtsong
  • (flink-agents) 02/02: Update version to 0.2-SNAPSHOT xtsong
  • (flink-agents) 01/02: [ci] Introduce update_branch_version script xtsong
• (flink) branch release-1.20 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 master updated (48aed8418d6 -> d319c9c147f) snuyanzin
• (flink-agents) branch main updated: [docs] Update installation section. (#226) xtsong
• (flink-agents) branch main updated (b23644d -> d6a38c4) xtsong
• (flink) branch release-1.20 updated: [FLINK-38408][checkpoint] Complete the checkpoint CompletableFuture after updating statistics to ensures semantic correctness and prevent test failure fanrui
• svn commit: r80073 - in dev/flink/flink-2.1.1-rc1: . python gaborgsomogyi
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated: deploy action fix fcsaky
• (flink) annotated tag release-2.0.1-rc1 updated (1192b3ecd5e -> d67cfbec1ca) zakelly
• svn commit: r79466 - dev/flink/flink-cdc-3.5.0-rc3 kunni
• (flink-connector-http) branch main updated (52a1c35 -> effa28b) fcsaky
  • (flink-connector-http) 01/01: [hotfix] Fix version string in weekly CI fcsaky
• (flink-agents) annotated tag release-0.1.0-rc1 deleted (was 2abe6d9) sxnan
• (flink-cdc) branch master updated: [FLINK-38496][docs] Icerberg YAML sink requires extra Hadoop jar to run (#4153) yux
• (flink-agents) branch release-0.1 updated (3b2dc55 -> 1af01f6) xtsong
  • (flink-agents) 02/02: [doc] Add instructions for java in quickstart doc. xtsong
  • (flink-agents) 01/02: [hotfix] Support read input data from jar. xtsong
• (flink-agents) branch main updated: [doc] Add instructions for java in Prompt, Tool and ChatModel doc. (#263) xtsong
• (flink) branch master updated: [FLINK-31499][table] Move `SqlCreateTable` conversion logic to `SqlCreateTableConverter` and make it more generic snuyanzin
• (flink-agents) branch release-0.1 created (now 53d29e6) sxnan
• (flink-agents) branch main updated: [Feature] Introduce built-in CONTEXT_RETRIEVAL_ACTION to enable context retrieval (#228) xtsong
• (flink-agents) branch release-0.1 updated: [hotfix] Add 0.1 to Previous Docs (#261) xtsong
• (flink) branch master updated: [FLINK-38435][table] Refactor codegen and runner for MLPredict and LookupJoin (#27041) shengkai
• (flink) branch master updated: [FLINK-38364][streaming-java] Implement async state version of ProcessingTimeoutTrigger (#27027) zakelly
• (flink) branch release-2.0 updated: [FLINK-38408][checkpoint] Complete the checkpoint CompletableFuture after updating statistics to ensures semantic correctness and prevent test failure fanrui
• (flink-cdc) branch master updated: [build] Automate property replacement in pom.xml and exclude the release directory from license checks. (#4134) kunni
• (flink) branch master updated: [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable snuyanzin
• (flink-cdc) branch release-3.5 updated: [hotfix][docs] Update overview pages for connector version leonard
• (flink) branch master updated: [FLINK-38486] Harden shutdown of system UDFs arvid
• (flink-agents) branch main updated: [Doc] Reorganize installation guide and simplify quickstart preparation sections (#266) xtsong
• (flink-cdc) branch release-3.5 updated: [FLINK-38496][docs] Iceberg yaml sink needs extra Hadoop jar (#4154) yux
• (flink) branch release-2.0 updated: [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend (#27110) zakelly
• svn commit: r80066 - release/flink zakelly
• (flink) branch release-2.1 updated: [FLINK-38513][python]Fix pandas 2.3+ cp39 issue gaborgsomogyi
• svn commit: r79864 - in dev/flink/flink-agents-0.1.0-rc1: . python sxnan
• (flink-agents) branch main updated: [doc] Add Consistency Guarantee section in deployment documentation. (#269) sxnan
• (flink) branch master updated: [FLINK-38403][tests] Stabilize UnalignedCheckpoint ITs arvid
• (flink-agents) branch main updated: [docs] Update react agent development doc. (#236) xtsong
• (flink-agents) branch main updated: [example][java] Add multiple agent integration example (#239) xtsong
• (flink-agents) branch release-0.1 updated: [doc] Simplify building step in README. (#270) xtsong
• (flink-agents) branch main updated: [doc] Add instructions for java in integration and operations docs. (#265) xtsong
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (a92006f2 -> a81751d1) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink) branch master updated: [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one (#27040) zakelly
• (flink-agents) branch main updated: [hotfix] Fix the inconsistency of the MemoryObject get method in Local and Flink mode (#235) xtsong
• (flink-web) branch asf-site updated (b349dcf54 -> 041632093) xtsong
  • (flink-web) 01/02: [docs] Add links to Flink Agents quickstart and documentation xtsong
• (flink-agents) branch main updated: [docs] Update flink agents overview doc. (#243) sxnan
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (0c532ff6 -> d921d91b) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink) branch release-2.0 updated: [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one (#27063) zakelly
• (flink) branch master updated: [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage shengkai
• (flink-agents) branch main updated: [hotfix] Refactor codes with latest API changes (#238) xtsong
• (flink-agents) branch main updated: [docs] Add docs for chat models and prompts (#245) xtsong
• (flink-agents) branch main updated (d6a38c4 -> f7481aa) xtsong
• (flink-cdc) branch release-3.5 updated: [minor][hotfix][docs] Fix some error in postgres yaml document. (#4140) (#4143) kunni
• (flink-agents) branch main updated: [docs] Update the deployment introduction for Flink agents (#237) xtsong
• (flink) annotated tag release-2.1.1-rc1 updated (074f8c5f9ac -> 1f267525808) gaborgsomogyi
• (flink-kubernetes-operator) branch docs-ci-rsync-dev deleted (was 55af16d8) fcsaky
• svn commit: r79604 - in dev/flink: flink-cdc-3.5.0-rc1 flink-cdc-3.5.0-rc2 flink-cdc-3.5.0-rc3 kunni
• Re: [I] Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.doris.flink.cfg.DorisOptions to field org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.dorisOptions of type org.apache.doris.flink.cfg.DorisOptions in instance of org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier [flink-cdc] via GitHub
• (flink-agents) branch release-0.1 updated: [doc] Add instructions for java in integration and operations docs. (#265) xtsong
• (flink) branch master updated: [FLINK-38513][python]Fix pandas 2.3+ cp39 issue gaborgsomogyi
• (flink-agents) branch main updated (7aa5a46 -> c4a4b30) xtsong
  • (flink-agents) 02/02: [docs] Update react agent quickstart section. xtsong
  • (flink-agents) 01/02: [hotfix] Fix react agent quickstart example doc strings. xtsong
• (flink) branch master 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 master updated: [FLINK-38473][build] Upgrade ArchUnit to 1.4.1 snuyanzin
• (flink-agents) branch main updated: [doc] Simplify building step in README. (#270) xtsong
• (flink-cdc) branch master updated: [hotfix][ci] Run MongoDB tests with supported 7.0.x and 8.0.x images (#4147) yux
• (flink) branch master updated (820a0ad5d96 -> 83db8f73f79) roman
  • (flink) 02/02: [FLINK-38464] Introduce OrderedMultiSetState roman
  • (flink) 01/02: [hotfix] Make CompositeSerializer factory methods public roman
• (flink-kubernetes-operator) branch docs-ci-rsync-dev created (now c0161e1b) fcsaky
• (flink-connector-kafka) branch main updated: [FLINK-38471] Add kafka sql connector as explicit dependency to kafka e2e common fpaul
• (flink) branch release-2.0 updated: [FLINK-38487][build] bump vmImage version to ubuntu-24.04 fanrui
• (flink) branch release-2.1 updated: [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one (#27064) zakelly
• (flink-cdc) branch master updated: [hotfix][docs] Update overview pages for connector version leonard
• (flink) branch master updated: [FLINK-38487][build] bump vmImage version to ubuntu-24.04 (#27095) ruanhang1993
• (flink-agents) branch main updated: [Bug] Add missing close function in MCPServer (#247) xtsong
• (flink-cdc) branch master updated: [minor][hotfix][docs] Fluss use STRING rather than VARCHAR. (#4144) kunni
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (6f2d645c -> f1abea3c) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink-agents) branch main updated: [docs] Update workflow agent quickstart with overview and code walkthrough (#244) xtsong
• (flink-agents) branch main updated: [hotfix ] add homepage link (#234) xtsong
• (flink-agents) branch main updated (dc88a0f -> afbde33) xtsong
  • (flink-agents) 01/02: [hotfix] Support read input data from jar. xtsong
  • (flink-agents) 02/02: [doc] Add instructions for java in quickstart doc. xtsong
• Re: [I] 请问出现这个错误(io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4{timestamp=1627541881000,)是什么原因? [flink-cdc] via GitHub
• (flink-web) branch asf-site updated (074be8993 -> 21446f90b) fcsaky
  • (flink-web) 01/02: Add Kubernetes Operator 1.13.0 release fcsaky
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (7385a9d2 -> ec785003) fcsaky
  • (flink-kubernetes-operator) 01/01: dev fcsaky
• (flink) branch release-2.1 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
• [I] [Mysql] Job not get more data after restart when running snapshot [flink-cdc] via GitHub
  • Re: [I] [Mysql] Job not get more data after restart when running snapshot [flink-cdc] via GitHub
  • Re: [I] [Mysql] Job not get more data after restart when running snapshot [flink-cdc] via GitHub
  • Re: [I] [Mysql] Job not get more data after restart when running snapshot [flink-cdc] via GitHub
  • Re: [I] [Mysql] Job not get more data after restart when running snapshot [flink-cdc] via GitHub
• (flink-cdc) branch master updated: [FLINK-37217][mysql] Fix `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly (#3892) kunni
• (flink-agents) annotated tag release-0.1.0-rc1 updated (aa0ba80 -> e37c893) sxnan
• (flink) branch master updated: [FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils snuyanzin
• (flink-kubernetes-operator) branch release-1.13 updated: [FLINK-38448] Rework doc build and doc deployment (#1035) fcsaky
• (flink) branch master updated: [FLINK-38484][ci] Avoid long command line error in community review script fcsaky
• (flink-agents) annotated tag release-0.1.0 updated (aa0ba80 -> 2c26cae) sxnan
• (flink-kubernetes-operator) branch docs-ci-rsync-dev updated (0221bab1 -> eb629482) fcsaky
  • (flink-kubernetes-operator) 01/01: Fix mvn build in `docs.sh` and use proper JDK17 img fcsaky
• (flink) branch master updated: [FLINK-38508][python] Allow string type specifications in Python UDF (#27106) shengkai
• (flink-agents) branch release-0.1 updated: [docs][release] Mark 0.1 as latest in docs (#257) xtsong
• (flink-agents) branch release-0.1 updated: [hotfix] improve build.sh script (#272) xtsong
• (flink-agents) branch main updated: [Feature][docs] add docs for introducing embedding models and vector stores (#221) xtsong
• (flink-agents) branch release-0.1 updated: [doc] Add instructions for java in workflow agent and react agent doc. (#258) xtsong
• (flink-agents) branch main updated: [hotfix] improve build.sh script (#272) xtsong
• (flink-web) branch asf-site updated: Add Flink 1.20.3 release (#807) sxnan
• (flink) branch master updated (58035ea658e -> 4d1a611850b) roman
  • (flink) 05/09: [FLINK-38460] Add SinkUpsertMaterializer state growth test roman
  • (flink) 02/09: [hotfix] Introduce SinkUpsertMaterializer factory method roman
  • (flink) 08/09: [FLINK-38460] Add SinkUpsertMaterializerMigrationTest roman
  • (flink) 09/09: [FLINK-38460] Add SinkUpsertMaterializerRescalingTest roman
  • (flink) 04/09: [FLINK-38460] Add SinkUpsertMaterializer recovery test roman
  • (flink) 06/09: [FLINK-38460] Add SinkUpsertMaterializer retraction tests roman
  • (flink) 07/09: [FLINK-38460] Add SinkUpsertMaterializer serializer and equalizer tests roman
  • (flink) 03/09: [hotfix] Refactor SinkUpsertMaterializer tests roman
  • (flink) 01/09: [hotfix] Introduce OperatorSnapshotFinalizer factory method roman
• (flink-connector-pulsar) branch main updated: [FLINK-37299] Stateless startup cannot continue consuming from current consumer group location fcsaky
• (flink-web) branch asf-site updated: Announce Flink Agents 0.1.0 (#809) sxnan
• svn commit: r80119 - in dev/flink/flink-2.0.1-rc1: . python zakelly
• (flink-agents) branch release-0.1 updated: [readme] add documentation link xtsong
• (flink) branch master updated (c7d683c9bf6 -> e44d6387dba) fanrui
• (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

• Earlier messages
• Later messages