commits  

Messages by Thread

• (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
• (flink-agents) branch main updated (1e2098c -> a517ca1) xtsong
• (flink) branch master updated (3e41e723b9d -> 4b7d62b45a3) dianfu
• (flink-cdc) branch master updated: [hotfix][postgres] PostgresSourceFetchTaskContext log do not output PostgresConnectorConfig (#3855) kunni
• (flink) branch master updated: [FLINK-38365][table] Make invalid operations with `MATERIALIZED TABLE`s returning more user friendly message snuyanzin
• (flink) branch master updated (0748711c1de -> 2e7cac19064) snuyanzin
  • (flink) 01/05: [hotfix][docs] Move distribution before partitioned to match implementation snuyanzin
  • (flink) 03/05: [FLINK-38312][table] `SHOW MATERIALIZED TABLES` should show constraint info and no columns info snuyanzin
  • (flink) 05/05: [FLINK-38311][table] Serializing and deserializing of table and materialized table with distribution snuyanzin
  • (flink) 02/05: [hotfix][table] Use assertJ in `CatalogTableITCase` and `CatalogViewITCase` snuyanzin
  • (flink) 04/05: [FLINK-38311][table] Add support for `DISTRIBUTION` in materialized tables snuyanzin
• (flink) branch master updated: [FLINK-37697][Documentation] Adding Confluent to vendors list (#26992) martijnvisser
• (flink-cdc) branch master updated: [FLINK-37979][minor][mysql] Remove obsolete MySQL CDC snapshot split assigner code (#4048) kunni
• (flink-cdc) branch master updated: [FLINK-38265] Stream Split shouldn't finish when exception occors but met END Watermark. (#4101) kunni
• (flink-cdc) branch master updated: [FLINK-36980][docs] Add "Streaming ELT from MySQL to Kafka" quick-start guide (#4033) yux
• (flink-cdc) branch master updated: [FLINK-37479][postgres] Add support for PARTITIONED TABLE (#4004) kunni
• (flink-cdc) branch master updated: [FLINK-38310] Fix handling equals and hashcode method of binary boundaries in FinishedSnapshotSplitInfo (#4112) kunni
• (flink-agents) branch main updated: [Feature] Change default value of extract_reasoning in OllamaChatModelSetup to true (#167) sxnan
• (flink-kubernetes-operator) branch main updated: Fix README.md typos morhidi
• (flink) branch master updated: [FLINK-38356][table-planner] Respect terminating flag for test values source twalthr
• (flink-cdc) branch master updated: [FLINK-37096][cdc-connector][mongodb] Update the value of emitDelay & fetchDelay from 20098d to -1ms in the snapshot reading phase. (#4034) kunni
• (flink-agents) branch main updated (e02f29c -> 7f35da3) xtsong
  • (flink-agents) 03/03: [api][java] Separate the abstraction of ChatModel to connection and setup in java. xtsong
  • (flink-agents) 01/03: [hotfix] Move BaseTool and related class loaction. xtsong
  • (flink-agents) 02/03: [api][java] Add ResourceDescriptor abstraction. xtsong
• (flink-cdc) branch FLINK-38206 updated (c661d2980 -> 924df1c70) kunni
• (flink-connector-shared-utils) branch ci_utils updated: [hotfix][connectors][build] Replace https://archive.apache.org/ by https://dlcdn.apache.org/ for Flink release download for connectors leonard
• (flink) branch release-2.1 updated: [FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager (#26973) zakelly
• (flink-agents) branch main updated: [api][python] Add Embedding Model abstraction and provide a built-in Ollama embedding model implementation (#150) xtsong
• (flink) branch master updated: [FLINK-37245] Add tests for RowData FieldGetters mxm
• (flink) branch release-2.1 updated: [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager (#26980) zakelly
• (flink) branch release-1.20 updated: [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager (#26978) zakelly
• (flink) branch release-2.0 updated: [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager (#26979) zakelly
• (flink-cdc) branch master updated: [hotfix][docs] Fixed typo on Parameter name for Oracle CDC Adapter (#4116) yux
• (flink) branch master updated (b2b99fe8a49 -> f3bd4a4962f) zakelly
• (flink-cdc) branch master updated: [FLINK-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream. (#4081) kunni
• (flink) branch master updated: [FLINK-32695] Migrated SavepointReaderITTestBase to SourceV2 fpaul
• (flink) branch release-2.0 updated: [FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager (#26972) zakelly
• (flink-cdc) branch master updated: [hotfix][postgres] Use correct table filter during backfill leonard
• (flink) branch master updated: [hotfix][table] Fix incorrect state ttl setting in KeyedLookupJoinWrapper lincoln
• (flink) branch master updated: [FLINK-38109][flink-runtime] Fix `BlobClient` address when `jobmanager.bind-host` is set fcsaky
• (flink) branch master updated: [FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager (#26968) zakelly
• (flink) branch release-2.0 updated: [FLINK-38193] Bump commons-lang3 to version 3.18.0 snuyanzin
• (flink) branch release-2.1 updated: [FLINK-38193] Bump commons-lang3 to version 3.18.0 snuyanzin
• (flink) branch master updated: [FLINK-38317][table] Make PushCalcPastChangelogNormalizeRule tolerant to trimmed fields snuyanzin
• (flink-agents) branch main updated (25ea18f -> e9b5654) xtsong
  • (flink-agents) 06/06: [api][python] Introduce built-in ReAct Agent. xtsong
  • (flink-agents) 04/06: [api][plan][runtime] Support register resources in execution envrionment. xtsong
  • (flink-agents) 02/06: [hotfix] Use re rather than Formatter to format Prompt to support json schema in prompt. xtsong
  • (flink-agents) 01/06: [hotfix] Align class, parameter and decorator name of chat model abstraction. xtsong
  • (flink-agents) 03/06: [runtime][python] Refactor built-in actions to execute tool calls from one response one time. xtsong
  • (flink-agents) 05/06: [api][plan][runtime] Support pass additional parameters to action. xtsong
• (flink-agents) branch main updated: [hotfix] Fix tongyi chat model test failure. (#142) xtsong
• [I] FlinkCDC中从MySQL导入到Paimon，我是直接整库同步。如果此时我想重新同步某张表并保留其他表的进度，目前似乎没有办法进行这种操作。 [flink-cdc] via GitHub
  • Re: [I] FlinkCDC中从MySQL导入到Paimon，我是直接整库同步。如果此时我想重新同步某张表并保留其他表的进度，目前似乎没有办法进行这种操作。 [flink-cdc] via GitHub
  • Re: [I] FlinkCDC中从MySQL导入到Paimon，我是直接整库同步。如果此时我想重新同步某张表并保留其他表的进度，目前似乎没有办法进行这种操作。 [flink-cdc] via GitHub
  • Re: [I] FlinkCDC中从MySQL导入到Paimon，我是直接整库同步。如果此时我想重新同步某张表并保留其他表的进度，目前似乎没有办法进行这种操作。 [flink-cdc] via GitHub
  • Re: [I] FlinkCDC中从MySQL导入到Paimon，我是直接整库同步。如果此时我想重新同步某张表并保留其他表的进度，目前似乎没有办法进行这种操作。 [flink-cdc] via GitHub
• (flink-cdc) branch master updated: [FLINK-38275][pipeline-connectors][doris]Fix table creation when the upstream has no primary key and the first column is String. kunni
• (flink) branch master updated (ae96dc0a006 -> 3ffbe56653d) fcsaky
• Re: [I] Error on Postgres-CDC using incremental snapshot with UUID column as PK [flink-cdc] via GitHub
  • Re: [I] Error on Postgres-CDC using incremental snapshot with UUID column as PK [flink-cdc] via GitHub
• (flink-agents) branch main updated: [integration][python] Anthropic Chat Model APIs Integration (#139) xtsong
• (flink) branch master updated (7a00b0e6840 -> ae96dc0a006) pnowojski
• (flink) branch master updated (67415737056 -> 7a00b0e6840) sxnan
• (flink-agents) branch main updated: [api][runtime] Introduce configuration mechanism (#122) xtsong
• (flink) branch master updated: [hotfix] Use `simplifiedCondition` to check for `isAlwaysTrue` in `PushCalcPastChangelogNormalizeRule` snuyanzin
• (flink-agents) branch main updated: [build] Improve the building process to favor uv and pyproject (#140) sxnan
• (flink-agents) branch main updated: [hotfix] Fix ollama chat model test failure. (#141) xtsong
• (flink) branch master updated: [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` snuyanzin
• (flink-agents) branch main updated: [infra] Show python version in GHA job names xtsong
• (flink-agents) branch main updated: [integration][python] Integrate OpenAI chat model. (#128) xtsong
• (flink) branch master updated: [FLINK-38308] Reduce logging of date parse errors in DateTimeUtils roman
• (flink-connector-kafka) branch main updated: [FLINK-38289] Update to Flink 2.1 gaborgsomogyi
• (flink-agents) branch main updated: [hotfix] Fix incorrect import path of flink_agents (#137) xtsong
• (flink-connector-kafka) branch main updated: [FLINK-37583] Upgrade to Kafka 4.0.0 client. fpaul
• (flink) branch release-2.0 updated (f8a3985c566 -> e4ea3d81948) fanrui
  • (flink) 01/03: [FLINK-38267][checkpoint] Refactor hasInputState and hasOutputState related logic in TaskStateAssignment fanrui
  • (flink) 02/03: [FLINK-38267][checkpoint] Only call channel state rescaling logic for exchange with channel state to avoid UnsupportedOperationException fanrui
  • (flink) 03/03: [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fanrui
• (flink) branch release-1.20 updated (b4a60319045 -> 6268448a811) fanrui
  • (flink) 03/03: [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fanrui
  • (flink) 02/03: [FLINK-38267][checkpoint] Only call channel state rescaling logic for exchange with channel state to avoid UnsupportedOperationException fanrui
  • (flink) 01/03: [FLINK-38267][checkpoint] Refactor hasInputState and hasOutputState related logic in TaskStateAssignment fanrui
• (flink) branch release-2.1 updated (d67c45a750e -> 90762ab27d0) fanrui
  • (flink) 02/03: [FLINK-38267][checkpoint] Only call channel state rescaling logic for exchange with channel state to avoid UnsupportedOperationException fanrui
  • (flink) 01/03: [FLINK-38267][checkpoint] Refactor hasInputState and hasOutputState related logic in TaskStateAssignment fanrui
  • (flink) 03/03: [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fanrui
• (flink) branch master updated: [FLINK-38193] Bump commons-lang3 to version 3.18.0 snuyanzin
• (flink) branch master updated: [FLINK-38288] Enhance BlobWriter logging with offloading time in millis. fanrui
• (flink-kubernetes-operator) branch main updated: [FLINK-37669][HELM] Add Helm chart unit tests to flink kubernetes operator gyfora
• (flink) branch master updated: [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fanrui
• (flink) branch master updated: [FLINK-37827][table] Add support for `SHOW CREATE MATERIALIZED TABLE` snuyanzin
• (flink) branch master updated (e2a2755a046 -> 1e7525f5625) fpaul
• (flink-agents) branch main updated: [hotfix] Fix coredump when close async thread pool. (#133) xtsong
• (flink-agents) branch main updated: [Integration][ChatModel]Add built-in tongyi chat model in python (#121) xtsong
• (flink-cdc) branch master updated: [FLINK-38278][postgres-pipeline] supported array type field. (#4108) kunni
• (flink) branch release-2.1 updated: [FLINK-38286][table] Fix: MAP function with duplicate keys produces non-deterministic results dwysakowicz
• (flink) branch release-2.0 updated: [FLINK-38286][table] Fix: MAP function with duplicate keys produces non-deterministic results dwysakowicz
• (flink) branch master updated (f7a159bfc6b -> e2a2755a046) dwysakowicz
• (flink) branch master updated: [FLINK-38257][SQL] Add module dynamic function loading possibility gaborgsomogyi
• (flink) branch release-2.0 updated: [FLINK-37181][build] Fix MacOS sha256sum tool compile error gaborgsomogyi
• (flink) branch release-1.20 updated: [FLINK-37181][build] Fix MacOS sha256sum tool compile error gaborgsomogyi
• [I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc] via GitHub
  • Re: [I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc] via GitHub
  • Re: [I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc] via GitHub
  • Re: [I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc] via GitHub
  • Re: [I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc] via GitHub
• (flink-cdc) branch master updated: [FLINK-37738][docs] Fix Postgres Chinese and English document contents (#4109) yux
• (flink-kubernetes-operator) branch main updated: [FLINK-37193] Feature flag if operator should manage ingress gyfora
• (flink) branch release-2.1 updated: [FLINK-38020] Fix NPE in NonTimeRangeUnboundedFunction (#26807) fhueske
• (flink) branch master updated: [FLINK-38131][flink-runtime] Fix that JM still redistributes broadcast state when all subtask have reported their states (#26925) zakelly
• (flink-kubernetes-operator) branch main updated: [FLINK-38148] Support Flink v1.17 when listing job exceptions gyfora
• (flink) branch master updated (0eeab73fe4a -> d81751aea0b) fanrui
• (flink-kubernetes-operator) branch main updated: [FLINK-37406] Fix config array serialization gyfora
• (flink-cdc) branch master updated: [FLINK-38157][connect/postgres] Supports assigning unbounded chunk first (#4103) yux
• (flink-web) branch asf-site updated (0af510acc -> a0bec613f) fpaul
  • (flink-web) 01/02: [FLINK-38176] Add Flink kafka connector 4.0.1 fpaul
• svn commit: r78806 - dev/flink/flink-connector-kafka-4.0.1-rc1 arvid
• (flink) branch master updated: [FLINK-32695] [Tests] Migrated TableFactoryHarness.ScanSourceBase to Source V2 fpaul
• (flink-kubernetes-operator) branch main updated: [FLINK-37406] Update examples to use yaml based configs gyfora
• (flink) branch release-2.0 updated: [FLINK-37868][state/forst] Respect the `maxTransferBytes` when using path copying in ForSt (#26763) zakelly
• (flink-agents) branch main updated: [hotfix]Enrich test cases of Short-Term Memory in java (#124) xtsong
• (flink) branch master updated: [FLINK-32695] Moved TestSource in TypeFillTest to SourceV2 fpaul
• svn commit: r78765 - dev/flink/flink-connector-kafka-4.0.1-rc2 release/flink/flink-connector-kafka-4.0.1 arvid
• (flink-cdc) branch master updated: [FLINK-37959][postgres]Supports all pgsql field types like debezium (#4086) kunni
• (flink-agents) branch main updated: [API][Runtime]Introduce Memory Reference (#110) xtsong
• (flink-kubernetes-operator) branch main updated: [FLINK-37391][docs] Improve documentation for dynamic namespace watching configuration gyfora
• (flink) branch master updated: [FLINK-32695]-Added-flink-test-utils-connectors module fpaul
• (flink-agents) branch main updated: [hotfix] fix examples can't execute (#114) sxnan
• svn commit: r78734 - dev/flink/flink-connector-kafka-4.0.1-rc2 arvid
• svn commit: r78733 - dev/flink/flink-connector-kafka-4.0.1-rc2 arvid
• (flink-cdc) branch FLINK-38206 updated (90020ad21 -> c661d2980) kunni
• (flink-agents) branch main updated: [Feature] [API] Support Event Logger and Event Listener in Java (#103) xtsong
• (flink) branch master updated: [FLINK-38255][table] Add ITCase to verify sensitive table option redaction gaborgsomogyi
• (flink-cdc) branch master updated: [FLINK-38244][hotfix] Fix case-insensitive error when adding column After an existed column. (#4100) kunni
• (flink) branch master updated (62ddda7a58a -> 469644d43da) snuyanzin
• (flink) branch master updated: [hotfix][docs] Fix variable name in Java Batch example in `README` snuyanzin
• (flink) branch master updated: [FLINK-38246][table-planner] Remove unreachable code in CodeGenUtils snuyanzin

• Earlier messages
• Later messages