commits
Thread
Date
Earlier messages
Later messages
Messages by Thread
(flink-agents) branch main updated: [ci] Add java 17 pipeline for java ut and it. (#380)
xtsong
(flink-connector-aws) branch main updated (373be6f -> 68acdbd)
fcsaky
(flink) branch master updated: [FLINK-38754][runtime] Avoid reverse DNS lookups when connecting to BlobServer
zhuzh
(flink-cdc) branch master updated: [FLINK-38531][cdc-connector-mysql]Fix data loss when restoring from a checkpoint positioned in the middle of a bulk DML operation. (#4165)
kunni
(flink-agents) annotated tag release-0.1.1 updated (23ebac6 -> ced7fa6)
sxnan
(flink-agents) branch release-0.1 updated: [doc] Update doc version to 0.1.1 (#378)
xtsong
(flink) branch master updated: [FLINK-38796][table] `UnresolvedMetadataColumn` misses type during serializing to string
snuyanzin
(flink-web) branch asf-site updated (f13e4c658 -> 4ab0ef441)
sxnan
(flink-web) 01/02: Announce Flink Agents 0.1.1
sxnan
(flink-cdc) branch FLINK-38730-copy updated (dff4d6ef3 -> 5e0acee36)
kunni
(flink-cdc) 01/06: [FLINK-38730][build] Update jdk version of nightly to 17.
kunni
(flink-cdc) 04/06: Address comment.
kunni
(flink-cdc) 05/06: Address comment.
kunni
(flink-cdc) 06/06: Address comment.
kunni
(flink-cdc) 02/06: Address comment.
kunni
(flink-cdc) 03/06: Address comment.
kunni
(flink-shaded) branch master updated: [hotfix] Fix maven-shade-plugin not printing included artifacts (#154)
martijnvisser
(flink-agents) branch main updated: [hotfix] Fix the type loss issue in agent plan deserialization (#343)
sxnan
svn commit: r81239 - dev/flink/flink-agents-0.1.1-rc1 release/flink/flink-agents-0.1.1
xtsong
(flink-agents) branch main updated: [integration] Remove unnecessary dependency flink-agents-plan for chat model integration. (#375)
xtsong
(flink-agents) branch main updated: [Feature][Java] Add Anthropic chat model integration (#369)
xtsong
(flink-cdc) branch FLINK-38730-copy updated: Address comment.
kunni
(flink-cdc) branch FLINK-38730-copy updated: Address comment.
kunni
(flink-cdc) branch FLINK-38730-copy created (now 521bd1053)
kunni
(flink-cdc) 01/01: Address comment.
kunni
(flink) branch release-2.2 updated (ad477178625 -> 8de272c7d96)
shengkai
(flink) 03/03: [FLINK-38773][table] Fix batch vector search excnode context (#27311)
shengkai
(flink) 02/03: [FLINK-38767][table] Fix vector search execnode transform name (#27304)
shengkai
(flink) 01/03: [FLINK-38084][doc] Add download doc for model providers (#27296)
shengkai
(flink) branch master updated: [hotfix][release] Update japicmp configuration for 2.2.0 (#27312)
ruanhang1993
(flink) branch master updated: [FLINK-38771][table] Allow scalar args for multi-table PTFs
twalthr
(flink-cdc) branch master updated: [FLINK-38737][common] Fix potential backwards incompatibility with fallback keys (#4185)
yux
(flink-cdc) branch master updated: [hotfix] Bump Doris flink connector version to 25.1.0 (#4188)
kunni
(flink) branch master updated: [FLINK-38772][table] `CliClientITCase` is broken in IDE
snuyanzin
(flink) branch master updated (c4d6344ab8e -> 11f61d23b80)
snuyanzin
(flink) 02/02: [FLINK-38766][table] Migrate `TableEnvironmentTest` to assertJ
snuyanzin
(flink) branch master updated: [FLINK-38403][tests] Fix the unexpected test that the second job does not restore from checkpoint (#27254)
fanrui
(flink-connector-http) branch main updated: [FLINK-38481] Make HTTP request/response logging configurable
fcsaky
(flink) branch master updated: [FLINK-38773][table] Fix batch vector search excnode context (#27311)
shengkai
(flink-agents) branch main updated (db9bad9 -> 82b040f)
sxnan
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-5a727f26e2 created (now 22712b20b50)
github-bot
(flink) branch master updated: [hotfix][release] Build 2.2 docs in GitHub Action and mark 2.2 as stable in docs (#27315)
ruanhang1993
(flink) branch master updated: [FLINK-38661][docs] Add 2.2.0 release note (#27235)
ruanhang1993
(flink-web) branch asf-site updated (fdcecfc9d -> f13e4c658)
ruanhang1993
(flink-web) 01/02: Add Flink 2.2.0 release
ruanhang1993
(flink) branch master updated: [FLINK-38767][table] Fix vector search execnode transform name (#27304)
shengkai
(flink) branch master updated (a451e39c6e7 -> 644f4614589)
fanrui
(flink) 02/02: [FLINK-38746][table-runtime] Fix StackOverflowError in RecordsWindowBuffer.addElement
fanrui
(flink) 01/02: [hotfix] WindowBuffer implements AutoCloseable to avoid declare close explicitly
fanrui
Re: [I] flink-cdc实时同步表时考虑过滤归档删除问题 [flink-cdc]
via GitHub
(flink-connector-http) branch main updated: [hotfix] Remove options from docs that do not exist in the code
fcsaky
(flink-docker) branch master updated: Add Flink 2.2.0 release to .github/workflows/docker_push.yml (#246)
ruanhang1993
(flink) branch master updated: [FLINK-38768][table] Materialized table fails with validation exception in case of `LATERAL TABLE`
snuyanzin
(flink-agents) annotated tag release-0.1.1-rc1 updated (23ebac6 -> 5be52f6)
sxnan
(flink-docker) branch dev-master updated: Add GPG key for 2.2.0 release (#244)
ruanhang1993
(flink) branch release-1.20 updated: [FLINK-37813][runtime] Pass numberSlots via WorkerRegistration instead of SlotReport (#27100)
huweihua
svn commit: r81167 - dev/flink/flink-2.2.0-rc2 release/flink/flink-2.2.0
leonard
(flink) annotated tag release-2.2.0 updated (5a336892424 -> 0cc95fcc145)
ruanhang1993
(flink) branch master updated: [FLINK-37813][runtime] Pass numberSlots via WorkerRegistration instead of SlotReport (#27100)
huweihua
(flink) branch master updated: [FLINK-38084][doc] Add download doc for model providers (#27296)
shengkai
(flink) branch release-2.2 updated: [FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow`
snuyanzin
(flink) branch release-2.1 updated: [FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow`
snuyanzin
(flink) branch release-1.20 updated: [FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow`
snuyanzin
(flink-cdc) branch master updated: [FLINK-35633] Add more YAML structure validations & provide better error messages (#4172)
kunni
(flink-cdc) branch master updated: update markdown lint check (#4184)
kunni
(flink-connector-http) branch main updated: [FLINK-38743] Update connector identifiers
fcsaky
(flink) branch master updated (23f2e395322 -> d0ab038ecbb)
snuyanzin
(flink-agents) branch release-0.1 updated: [hotfix] Remove python_event_logging_test that relies on e2e patch #317
sxnan
(flink-agents) branch main updated: [hotfix][runtime] EventLogger displays the content of PythonEvent as string (#367)
sxnan
(flink-agents) branch release-0.1 updated: [hotfix][runtime] EventLogger displays the content of PythonEvent as string (#367)
sxnan
(flink-agents) branch release-0.1 updated: [runtime] Implement hashCode and equals for ActionTask. (#365)
sxnan
(flink-agents) branch main updated: [runtime] Implement hashCode and equals for ActionTask. (#365)
sxnan
(flink) branch release-2.1 updated: [hotfix][doc] Update latest version of 2.1 as 2.1.1 (#27289)
zakelly
(flink) branch release-1.20 updated: [hotfix][doc] Update latest version of 1.20 as 1.20.3 (#27288)
zakelly
(flink-agents) branch main updated: [hotfix] Remove unnecessary space to improve the pass rate of ChatModelIntegrationTest (#355)
xtsong
(flink-agents) branch main updated: [Feature][Java] Add OpenAI chat model integration (#320)
xtsong
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/compiler-20.3.15 created (now fc0e337ed47)
github-bot
(flink) branch master updated: [hotfix][docs] Use stable Fluss doc link to avoid broken link once Fluss community version bump
leonard
(flink) branch master updated: [FLINK-38260][table] Add parser changes for connection sql
snuyanzin
(flink) branch master updated: [FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow`
snuyanzin
(flink) branch master updated (e42cdd1efe3 -> 512fdb2b125)
snuyanzin
(flink) 01/03: [hotfix][table] Rename `SqlAlterDistribution` to `SqlAlterTableDistribution` and `SqlAlterMaterializedTableAddDistribution` to `SqlAlterMaterializedTableDistribution`
snuyanzin
(flink) 03/03: [FLINK-38756][table] Group and reorder converters in registration logica
snuyanzin
(flink) 02/03: [FLINK-38756][table] Add support for ALTER MATERIALIZED TABLE ADD columns in parser
snuyanzin
(flink) branch master updated: [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. (#26981)
weizhong
(flink-agents) branch main updated (393b9ec -> 680bba9)
xtsong
(flink) branch release-1.20 updated: [FLINK-35332][yarn] Do not set "rest.address" to the actual IP address of the YARN NM to support dual network envs
gaborgsomogyi
(flink-connector-http) branch main updated: [FLINK-38749] Document retry code defaults
fcsaky
(flink-connector-jdbc) branch main updated: [FLINK-38732][ci] Enable stale bot
fcsaky
(flink-agents) branch main updated (824b093 -> 393b9ec)
xtsong
(flink-agents) 02/03: [test][java] Clean up and refactor java e2e tests.
xtsong
(flink-agents) 03/03: [infra] Run e2e tests in ci.
xtsong
(flink-agents) 01/03: [test][python] Clean up and refactor python e2e tests.
xtsong
(flink-agents) branch main updated: Revert "Introduce sensory memory in python."
xtsong
(flink-agents) branch main updated (03d1e38 -> 68e37e1)
xtsong
(flink-agents) 01/06: [api][runtime][java] Introduce sensory memory in java.
xtsong
(flink-agents) 05/06: fixup! [api][runtime][java] Introduce sensory memory in java.
xtsong
(flink-agents) 03/06: fixup! [api][runtime][java] Introduce sensory memory in java.
xtsong
(flink-agents) 06/06: fixup! [api][runtime][python] Introduce sensory memory in python.
xtsong
(flink-agents) 04/06: fixup! [api][runtime][python] Introduce sensory memory in python.
xtsong
(flink-agents) 02/06: [api][runtime][python] Introduce sensory memory in python.
xtsong
(flink) branch master updated: [FLINK-38739][table] Drop unused `SqlAlterTableAddConstraint`
snuyanzin
(flink) branch master updated: [FLINK-37618][table-planner] Fix PTFs INTERVAL argument
twalthr
svn commit: r81043 - in dev/flink/flink-2.2.0-rc2: . python
ruanhang1993
(flink) annotated tag release-2.2.0-rc2 updated (5a336892424 -> 81d04f7d909)
ruanhang1993
(flink-agents) branch release-0.1 updated: [hotfix] Add the Apache 2.0 License to the omitted files (#342)
sxnan
(flink-agents) branch main updated: [hotfix] Add the Apache 2.0 License to the omitted files (#342)
sxnan
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/common-20.3.14 created (now f7a9d6964f9)
github-bot
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/node-forge-1.3.2 created (now b759cd14010)
github-bot
(flink) branch master updated (271266a9cd5 -> abcfebbf5ed)
dwysakowicz
(flink) branch master updated: [FLINK-38731][table] Add support for MULTI_JOIN hint
dwysakowicz
svn commit: r81021 - release/flink
leonard
(flink-agents) branch main updated: [feature][documentation] Add Azure AI chat model integration details (#318)
xtsong
(flink-agents) branch release-0.1 updated: [Bug] Tool call doesn't work in OpenAI chat model integration (#337)
xtsong
(flink-agents) branch main updated: [Bug] Tool call doesn't work in OpenAI chat model integration (#337)
xtsong
(flink) branch master updated: [hotfix] Fix flink-model-openai NOTICE for jtokkit
snuyanzin
(flink) branch release-2.2 updated: [hotfix] Fix flink-model-openai NOTICE for jtokkit
snuyanzin
(flink-cdc) branch master updated: [FLINK-38723][common/composer] Add getFlinkConf method to Context. (#4179)
kunni
(flink-connector-kafka) branch main updated: [FLINK-38696] Replace custom RateLimiterStrategy with built-in in KafkaSinkITCase (#200)
kunni
(flink) branch master updated (1cc2f147ddf -> 81bf2ebb581)
snuyanzin
(flink) 01/03: [hotfix][table] Use `Comment` method to parse comments
snuyanzin
(flink) 02/03: [FLINK-38712][table] Move away distribution from table schema
snuyanzin
(flink) 03/03: [FLINK-38712][table] Decouple table and `TableSchemaContext`
snuyanzin
(flink-connector-hbase) branch main updated: [FLINK-38722] Upgrade HBase to 2.6.4
fcsaky
(flink) branch release-2.2 updated: [BP-2.2][FLINK-38711][build] Set maven-shade-plugin logs to DEBUG
snuyanzin
(flink) branch master updated (0bd9ae03e70 -> 1cc2f147ddf)
snuyanzin
(flink) branch master updated (667cacc0ef0 -> 0bd9ae03e70)
dwysakowicz
(flink) branch release-2.2 updated: [FLINK-38700][python] Fix kubernetes pyflink application test
snuyanzin
(flink) annotated tag release-2.2.0-rc1 updated (fdea141397b -> ff06010c655)
ruanhang1993
svn commit: r80986 - in dev/flink/flink-2.2.0-rc1: . python
ruanhang1993
(flink) branch master updated (1e0c54ca7dc -> 667cacc0ef0)
dianfu
(flink) branch master updated: [FLINK-38711][build] Set maven-shade-plugin logs to `DEBUG`
snuyanzin
(flink) branch master updated: [hotfix][docs] Fix a typo in `procedures.md`
snuyanzin
(flink) branch release-2.2 updated: [FLINK-38709][table][python] Fix ScalarFunctionSplitter to allow PythonFunction & AsyncFunction work when taking the recursive field of composite type as input
dianfu
(flink) branch master updated: [FLINK-38709][table][python] Fix ScalarFunctionSplitter to allow PythonFunction & AsyncFunction work when taking the recursive field of composite type as input
dianfu
(flink-web) branch asf-site updated: Add homepage, description and labels to .asf.yaml
rmetzger
(flink) branch release-2.1 updated: [FLINK-36746][core] Fix the deadlock bug in SerializedThrowable
tangyun
(flink) branch release-2.2 updated: [FLINK-36746][core] Fix the deadlock bug in SerializedThrowable
tangyun
(flink) branch master updated: [FLINK-36746][core] Fix the deadlock bug in SerializedThrowable
tangyun
(flink-connector-jdbc) branch main updated: [FLINK-33463] Use Source API implementation in `JdbcDynamicTableSource`
fcsaky
(flink) branch dependabot/maven/flink-runtime/com.squareup.okhttp3-okhttp-4.10.0.redhat-00002 created (now 706f6d89a26)
github-bot
(flink-connector-kafka) branch main updated (3c6991d8 -> 33709609)
arvid
(flink-connector-kafka) 02/03: [hotfix] Avoid parallel usage of KafkaTestBase
arvid
(flink-connector-kafka) 01/03: [FLINK-38681] Revise threading model in enumerator
arvid
(flink-connector-kafka) 03/03: [hotfix] Adjust log properties for CI
arvid
(flink-agents) branch release-0.1 updated: [hotfix] Fix ollama4j can't deserialize tool call message from Ollama v0.12.10 and above. (#333)
sxnan
(flink-agents) branch main updated: [hotfix] Update ollam4j version to resolve tool call exception. (#324)
sxnan
(flink) branch master updated: [FLINK-38693][table] Changelog normalize shouldn't call CNF for marking program
snuyanzin
(flink) branch master updated: [FLINK-38700][python] Fix kubernetes pyflink application test
snuyanzin
(flink) branch release-2.2 updated: [FLINK-38695][table-planner] Fix wrong metric about left cache request count in DeltaJoinCache (#27253)
xuyangzhong
(flink) branch dependabot/maven/flink-end-to-end-tests/flink-sql-client-test/org.apache.kafka-kafka-clients-3.9.1 deleted (was 74d2cb626e8)
github-bot
(flink) branch dependabot/maven/flink-filesystems/flink-s3-fs-presto/commons-beanutils-commons-beanutils-1.11.0 deleted (was 51bf3932381)
github-bot
(flink) branch dependabot/maven/flink-yarn/commons-beanutils-commons-beanutils-1.10.1.redhat-00001 deleted (was 11f5edf0f1d)
github-bot
(flink) branch master updated (dae2cfe4ab7 -> 9773cc823b7)
dianfu
(flink-agents) branch release-0.1 updated: [infra] Support CI on release branches (#329)
sxnan
(flink-agents) branch main updated: [infra] Support CI on release branches (#329)
sxnan
(flink-agents) branch release-0.1 updated: [hotfix] Fix the invalid json data in product_review.txt (#327)
sxnan
(flink-agents) branch main updated: [hotfix] Fix the invalid json data in product_review.txt (#327)
sxnan
(flink-agents) branch release-0.1 updated: [hotfix] Fix the type mismatch issue in the format_messages method (#322)
sxnan
(flink-agents) branch main updated: [hotfix] Fix the type mismatch issue in the format_messages method (#322)
sxnan
(flink-agents) branch release-0.1 updated: [hotfix] Add missing mcp_server in Java ResourceType API (#312)
sxnan
(flink-agents) branch main updated: [hotfix] Add missing mcp_server in Java ResourceType API (#312)
sxnan
(flink-connector-jdbc) branch main updated: [hotfix] Apply the correct version matrix in weekly CI
fcsaky
(flink) branch master updated: [FLINK-35745][docs] Add documentation for Flink lineage
fcsaky
(flink-connector-jdbc) branch main updated: [hotfix] change Flink matrix to resolve Flink correctly (#179)
martijnvisser
(flink-connector-kafka) branch main updated (d10088b3 -> 3c6991d8)
martijnvisser
(flink-connector-kafka) 02/03: [hotfix] Test PRs against both Flink 2.0.x and Flink 2.1.x
martijnvisser
(flink-connector-kafka) 03/03: [hotfix] Refactor weekly tests to use YAML anchors
martijnvisser
(flink-connector-kafka) 01/03: [hotfix] Add Python tests to weekly runs and update to latest Flink minor versions
martijnvisser
(flink-connector-kafka) branch main updated: [hotfix] Fix Python CI
martijnvisser
(flink-connector-kafka) branch v3.4 updated (e93b300d -> f941acb2)
martijnvisser
(flink-connector-kafka) 01/03: [FLINK-37281] Fix KafkaUtil#checkProducerLeak
martijnvisser
(flink-connector-kafka) 03/03: [hotfix] Fix Python CI
martijnvisser
(flink-connector-kafka) 02/03: [hotfix] Fix leaks in FlinkKafkaProducerTest
martijnvisser
(flink-connector-kafka) branch v3.3 updated (06159a21 -> 9f631be2)
martijnvisser
(flink-connector-kafka) 01/03: [FLINK-37281] Fix KafkaUtil#checkProducerLeak
martijnvisser
(flink-connector-kafka) 03/03: [hotfix] Fix Python CI
martijnvisser
(flink-connector-kafka) 02/03: [hotfix] Fix leaks in FlinkKafkaProducerTest
martijnvisser
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/js-yaml-4.1.1 created (now 40bc84e3293)
github-bot
(flink-docker) branch dev-master updated: [FLINK-37881] Drop gosu in favour of Dockerfile USER
gaborgsomogyi
(flink) branch master updated (1c2d953556a -> bdbc8b589ee)
snuyanzin
(flink) branch release-2.2 updated: [FLINK-38686][doc] Add model table api documentation (#27243) (#27246)
shengkai
(flink-cdc) branch master updated: [FLINK-38641][cdc/mysql] Unquote double quotes from default values on MySQL (#4171)
kunni
(flink-connector-jdbc) branch main updated: [FLINK-34467] add lineage integration for jdbc connector (#149)
rmetzger
(flink-cdc) branch master updated: [FLINK-38685][cdc-connector-postgresql] Redact sensitive information like password from logs (#4174)
gongzhongqiang
(flink) branch master updated: [FLINK-36625] Add lineage helper class for connector integration
fcsaky
(flink-cdc) branch master updated: [FLINK-38618][base] Fix offset error due to duplicated stream split during TM failover if startup mode is latest-offset
leonard
(flink) branch master updated: [FLINK-38686][doc] Add model table api documentation (#27243)
shengkai
(flink) branch master updated: [FLINK-38355][table] Support `CREATE OR ALTER MATERIALIZED TABLE` syntax
snuyanzin
(flink-connector-kafka) branch main updated: [FLINK-38322] Update to Kafka client 4.1.0
fcsaky
(flink-connector-kafka) branch main updated: [FLINK-37650][ci] Enable Stale PR Github action
fcsaky
(flink) branch master updated: [hotfix][docs] Fix missed documentation during flink-web migrate to Hugo by FLINK-11293
leonard
(flink-cdc) branch master updated: [FLINK-38491][pipeline-connector][iceberg] fixed iceberg compaction parallelism (#4150)
kunni
(flink) branch release-2.2 updated: [FLINK-38682][table-planner] Support unknown -> RAW cast during type inference in limited validator scope
fcsaky
(flink) branch master updated: [FLINK-38682][table-planner] Support unknown -> RAW cast during type inference in limited validator scope
fcsaky
(flink) branch release-2.2 updated: [hotfix][docs] Add `SHOW MATERIALIZED TABLES`, `SHOW CREATE MATERIALIZED TABLE` to doc
snuyanzin
(flink-cdc) branch master updated: [FLINK-38279][mysql] Add SnapshotPendingSplitsState to MySQL checkpoint state during restoration
leonard
(flink-agents) branch release-0.1 updated: [hotfix] Correcting improper uses of the Pemja (#275)
sxnan
(flink) branch release-2.2 updated: [FLINK-38611][doc] Add doc for delta join (#27225)
xuyangzhong
(flink-agents) branch main updated: [infra] Configure default labels and bots to implement Label-Based Version Control Strategy (#316)
sxnan
Earlier messages
Later messages