commits
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/01/13
(flink) branch master updated: [hotfix] Improve test coverage of UnalignedCheckpointsInterruptibleTimersTest
pnowojski
2026/01/13
(flink) branch master updated (5e02d64bf01 -> 4d72763053c)
roman
2026/01/12
(flink) branch master updated (40dca974558 -> 5e02d64bf01)
fanrui
2026/01/12
(flink) 03/04: [FLINK-38542][checkpoint] Recover output buffers of upstream task on downstream task side directly
fanrui
2026/01/12
(flink) 01/04: [hotfix][checkpoint] Refactor output buffers distribution logic via ResultSubpartitionDistributor
fanrui
2026/01/12
(flink) 04/04: [FLINK-38542][checkpoint] Randomize UNALIGNED_ALLOW_ON_RECOVERY for testing
fanrui
2026/01/12
(flink) branch master updated: [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates
fanrui
2026/01/12
(flink) 02/04: [hotfix][checkpoint] Limit that the one buffer is only distributed to one target InputChannel
fanrui
2026/01/12
(flink-cdc) branch master updated: [build] Update copyright year to 2026
leonard
2026/01/12
(flink-agents) 02/03: [api][runtime][java] Introduce Long-Term Memory.
xtsong
2026/01/12
(flink-agents) 01/03: [hotfix] Fixes and clean-ups for long-term memory in python.
xtsong
2026/01/12
(flink-agents) branch main updated (c9e03cb -> ca315e7)
xtsong
2026/01/12
(flink-agents) 03/03: [runtime][java] Support use Long-Term Memory in action.
xtsong
2026/01/12
(flink-agents) branch main updated (71b8bff -> c9e03cb)
xtsong
2026/01/12
(flink-agents) 04/04: [Feature][runtime] Support the use of Java EembeddingModel in Python
xtsong
2026/01/12
(flink-agents) 02/04: [feature] Support Python resource retrieval through the Java resource using the getResource function
xtsong
2026/01/12
(flink-agents) 03/04: [feature] Support Java resource retrieval through the Python resource using the get_resource function
xtsong
2026/01/12
(flink-agents) 01/04: [runtime] Support using JavaChatModelConnection directly in Python
xtsong
2026/01/12
(flink-connector-aws) annotated tag v5.1.0 updated (e82733d -> 7fc9965)
fcsaky
2026/01/12
(flink-connector-aws) annotated tag v deleted (was ee7c915)
fcsaky
2026/01/12
(flink-connector-aws) annotated tag v updated (e82733d -> ee7c915)
fcsaky
2026/01/12
(flink-connector-http) branch main updated: [hotfix] Fixup test implmentation
fcsaky
2026/01/12
(flink-web) branch asf-site updated: [released] Add Flink-Shaded 21.0
martijnvisser
2026/01/12
(flink-shaded) annotated tag release-21.0 updated (e458d63 -> 052e58f)
martijnvisser
2026/01/12
svn commit: r81840 - dev/flink/flink-shaded-21.0-rc3 release/flink/flink-shaded-21.0
martijnvisser
2026/01/12
(flink-connector-http) branch main updated: [FLINK-38816] Use Flink 2 compatible deserialize in `JavaNetHttpPollingClient`
fcsaky
2026/01/12
(flink) branch master updated: [FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures (#27061)
panyuepeng
2026/01/11
(flink-agents) branch main updated: [doc] Add doc for ElasticsearchVectorStore in java (#397)
xtsong
2026/01/10
(flink) branch master updated: [FLINK-38884][table] Migrate IncrementalAggregateRule to java
snuyanzin
2026/01/10
(flink-shaded) branch master updated: [hotfix] Update copyright year to 2026
martijnvisser
2026/01/10
(flink) branch master updated: [FLINK-37009][table] Migrate `PruneAggregateCallRule` to java
snuyanzin
2026/01/10
(flink) branch master updated: [FLINK-34597][table] Migrate `SimplifyFilterConditionRule` to java
snuyanzin
2026/01/09
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/compiler-20.3.16 created (now cfb35d90a3b)
github-bot
2026/01/09
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/core-20.3.16 created (now 634c7bc4e9e)
github-bot
2026/01/09
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/compiler-20.3.15 deleted (was fc0e337ed47)
github-bot
2026/01/09
(flink) branch master updated: [hotfix] Use `source.java.version` as `maven.compiler.source` in root POM
fcsaky
2026/01/09
(flink-cdc) branch master updated: [FLINK-38596][pipeline-connector][maxcompute] Fix the column comment of CreateTableEvent and AddColumnEvent (#4215)
kunni
2026/01/08
(flink) branch master updated (6ffb7edea75 -> 8c5735f0357)
zhuzh
2026/01/08
(flink) branch master updated: [FLINK-38189][core][python] Introduce RowFieldExtractorSchema for Row field serialization (#27353)
dianfu
2026/01/08
(flink-agents) branch main updated: [doc] Add doc for JAVA MCP Server tools and prompts (#421)
xtsong
2026/01/08
svn commit: r81706 - dev/flink/flink-shaded-21.0-rc3
martijnvisser
2026/01/08
(flink-shaded) annotated tag release-21.0-rc3 updated (e458d63 -> cfe32a7)
martijnvisser
2026/01/07
(flink-cdc) branch FLINK-38835 deleted (was 2f32836a7)
kunni
2026/01/07
(flink-cdc) 01/01: [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01.
kunni
2026/01/07
(flink-cdc) branch FLINK-38835 created (now 2f32836a7)
kunni
2026/01/07
(flink-agents) branch main updated: [Feature] Support multiple jdk versions (#413)
sxnan
2026/01/07
(flink-agents) branch main updated: [plan][hotfix] Avoid retrying chat even if response is valid. (#420)
xtsong
2026/01/07
(flink-cdc) 02/02: [FLINK-38838] Update spotless style version to AOSP 1.24.0
yux
2026/01/07
(flink-cdc) branch master updated (91a7af1da -> a40b870f3)
yux
2026/01/07
(flink-cdc) 01/02: [ci] Combine test modules together to reduce test matrix size
yux
2026/01/07
(flink-cdc) branch master updated: [FLINK-38100][pipeline-connector][iceberg] Bump Iceberg dependency to 1.10.1 in iceberg-pipeline-sink connector (#4145)
kunni
2026/01/07
(flink-agents) branch main updated: [infra] Add Yash Anand as collaborators.
xtsong
2026/01/07
(flink-agents) branch main updated: [infra] Add Ioannis Stavrakantonakis as collaborators.
xtsong
2026/01/07
(flink-shaded) branch master updated: Revert "[hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35"
martijnvisser
2026/01/07
svn commit: r81697 - dev/flink/flink-connector-aws-5.1.0-rc2
fcsaky
2026/01/07
(flink-connector-aws) annotated tag v5.1.0-rc2 updated (e82733d -> b492f2b)
fcsaky
2026/01/07
(flink-agents) branch main updated: [api][integration][java] Enrich interface for vector store and implement these for elasticsearch. (#416)
xtsong
2026/01/07
(flink) branch release-1.20 updated: [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner
mapohl
2026/01/07
(flink) branch release-2.1 updated: [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner
mapohl
2026/01/07
(flink) branch release-2.2 updated: [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner
mapohl
2026/01/07
(flink-agents) branch main updated (8c7ae45 -> 1fb13d7)
xtsong
2026/01/07
(flink-agents) branch main updated: [Feature][runtime] Support the use of Python EembeddingModel in Java (#417)
xtsong
2026/01/07
(flink-connector-kafka) branch main updated: [FLINK-38862] Configurable partition discovery interval in upsert mode
fpaul
2026/01/07
(flink-agents) branch main updated: [api][integration] Move mcp module from api to integration. (#415)
xtsong
2026/01/07
(flink-agents) branch main updated: [Feature] Improve Python Async Execution API (#409)
xtsong
2026/01/06
(flink) branch master updated (d481fb32219 -> fec9336e7d9)
zhuzh
2026/01/06
(flink-agents) 05/05: [plan] Support error handling strategy for chat action.
xtsong
2026/01/06
(flink-agents) 04/05: [plan] Refactor built-in chat action.
xtsong
2026/01/06
(flink-agents) branch main updated (6066182 -> 4012835)
xtsong
2026/01/06
(flink-agents) 03/05: [plan] Use sensory memory for tool call context.
xtsong
2026/01/06
(flink-agents) 02/05: [api] Move agent api to agents module.
xtsong
2026/01/06
(flink-agents) 01/05: [test] Revise the question and tool description to improve test stability
xtsong
2026/01/06
(flink-cdc) branch master updated: [FLINK-38840][postgres] Postgres YAML connector supports emitting complete Table ID (#4209)
yux
2026/01/06
(flink-connector-aws) branch v5.1 updated: [FLINK-38868] Bump Flink version to 1.20.3
fcsaky
2026/01/06
(flink-connector-aws) branch v5.1 updated: [hotfix] Fix Python CI
fcsaky
2026/01/06
(flink) branch master updated: [hotfix][NOTICE] Update copyright NOTICE year to 2026 (#27380)
panyuepeng
2026/01/06
(flink) branch master updated (452479b6368 -> e02393ee8a9)
shengkai
2026/01/06
(flink) branch master updated: [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner
mapohl
2026/01/06
(flink) branch master updated (94c65494b20 -> 76337add10b)
snuyanzin
2026/01/05
(flink) branch master updated: [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures (#27060)
panyuepeng
2026/01/05
(flink) branch master updated: [FLINK-38748][runtime] Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. (#27286)
panyuepeng
2026/01/05
(flink) branch master updated: [FLINK-38225] Sets proper precondition to ensure that GCS operations are retryable (#27101)
xtsong
2026/01/05
(flink-kubernetes-operator) branch main updated: [FLINK-38860] Remove flink shaded guava usage
gyfora
2026/01/05
(flink-kubernetes-operator) branch main updated (90edc9c6 -> e480eb72)
gyfora
2026/01/05
(flink-kubernetes-operator) branch main updated: [FLINK-38859] Do not apply minimum job vertex parallelism for whole job in native mode
gyfora
2026/01/04
(flink-agents) branch main updated (9429239 -> 6066182)
xtsong
2026/01/04
(flink-agents) branch main updated: [infra] Add doc-including label to indicate docs are included in the PR (#407)
xtsong
2026/01/04
(flink-cdc) branch master updated: [FLINK-37676][common] Add caching mechanism to Table ID Selectors for better performance (#3994)
yux
2026/01/04
(flink-benchmarks) 01/02: [FLINK-38801][benchmark] Adjust code lines format and corresponding namings to follow Google AOSP style.
panyuepeng
2026/01/04
(flink-benchmarks) 02/02: [FLINK-38801][benchmark] Add Spotless and checkstyle plugins with Google AOSP style for flink benchmark repository
panyuepeng
2026/01/04
(flink-benchmarks) branch master updated (6810df8 -> 9ac3569)
panyuepeng
2026/01/03
Re: [I] [Bug] Flink-CDC-MySQL,任务正常运行一段时间后,就无法继续获取新Binlog数据,程序保持运行,无任何报错。 [flink-cdc]
via GitHub
2026/01/03
Re: [I] [Bug] Flink-CDC-MySQL,任务正常运行一段时间后,就无法继续获取新Binlog数据,程序保持运行,无任何报错。 [flink-cdc]
via GitHub
2026/01/03
(flink-cdc) branch master updated: [FLINK-38847][postgres] Update PostgresConnectionPoolFactory#getPoolId method to use username correctly. (#4204)
kunni
2026/01/03
(flink) branch master updated: [FLINK-38855] Upgrade jackson to 2.20.1
snuyanzin
2026/01/03
(flink-agents) branch main updated (6bc5f58 -> 57f968a)
xtsong
2026/01/03
(flink-agents) 04/05: [build] Support Multi-Version Flink in Python
xtsong
2026/01/03
(flink-agents) 05/05: [ci] Enable testing for all Flink versions in CI
xtsong
2026/01/03
(flink-agents) 03/05: [build] Support Multi-Version Flink in Java
xtsong
2026/01/03
(flink-agents) 02/05: [build] Update default flink to 2.2.0
xtsong
2026/01/03
(flink-agents) 01/05: [build] Use Unified Jackson in Flink Agents
xtsong
2026/01/01
(flink) branch master updated: [FLINK-34596][table] Migrate RemoveRedundantLocalHashAggRule to java
snuyanzin
2026/01/01
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/node-forge-1.3.2 deleted (was b759cd14010)
github-bot
2026/01/01
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/node-forge-1.3.3 created (now 9b7662f0735)
github-bot
2026/01/01
(flink) branch master updated: [FLINK-34895][table] Migrate FlinkRewriteSubQueryRule to java
snuyanzin
2026/01/01
(flink) branch master updated (02106293bb8 -> fc8b531c6b6)
snuyanzin
2025/12/30
Re: [I] [Bug] Flink-CDC-MySQL,任务正常运行一段时间后,就无法继续获取新Binlog数据,程序保持运行,无任何报错。 [flink-cdc]
via GitHub
2025/12/29
(flink) branch master updated: [FLINK-38717][runtime] Display the assigned task numbers for TaskManagers on the UI
fcsaky
2025/12/29
(flink) branch master updated (e287f22140d -> 2c9bbebc231)
zhuzh
2025/12/29
(flink-cdc) branch master updated (db1caee89 -> 44fb79fa5)
yux
2025/12/28
(flink) branch master updated: [FLINK-38740][table] Introduce Welford's online algorithm for variance related functions to avoid catastrophic cancellation in naive algorithm
lincoln
2025/12/27
(flink-connector-http) branch main updated: [FLINK-38803] Add HTTP response deserialize failed completion state
fcsaky
2025/12/27
svn commit: r81536 - dev/flink/flink-shaded-21.0-rc2
martijnvisser
2025/12/27
(flink-shaded) annotated tag release-21.0-rc2 updated (8f9e83c -> 6b1b2f4)
martijnvisser
2025/12/27
svn commit: r81534 - release/flink
martijnvisser
2025/12/26
(flink-cdc) branch master updated: [FLINK-38837][docs][pipeline-connector/hudi] Add documentation for Hudi connector and improve the configuration
leonard
2025/12/26
(flink-cdc) branch master updated: [FLINK-38730][build] Bump default JDK version from 8 to 11 and support optional JDK17
leonard
2025/12/26
(flink) branch master updated: [FLINK-38759][runtime] Refactor application mode with PackagedProgramApplication
zhuzh
2025/12/25
(flink-agents) branch main updated: [metrics] Implement token usage metrics tracking for chat models (#394)
sxnan
2025/12/25
(flink-cdc) branch master updated: [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector (#4198)
kunni
2025/12/25
(flink-cdc) branch master updated: [FLINK-38818][pipeline-connector][posgtresql]Build createTableEventCache using TableSchemas from split (#4194)
kunni
2025/12/24
(flink-web) 02/02: Rebuild website
xtsong
2025/12/24
(flink-web) branch asf-site updated (4ab0ef441 -> cfbf10f99)
xtsong
2025/12/24
(flink-web) 01/02: Fix broken image links in the dynamic iceberg sink blogpost
xtsong
2025/12/24
Re: [I] [Bug] [tidb cdc]a error:java.lang.IllegalArgumentException: Invalid range: [+INF..{xxx}) at org.apache.flink.shaded.guava30.com.google.common.collect.Range.<init>(Range.java:358) [flink-cdc]
via GitHub
2025/12/24
(flink-agents) branch main updated: [runtime] Avoid create new runner context each time execute action. (#392)
xtsong
2025/12/24
(flink) branch release-2.2 updated: [FLINK-38824][table] Fix incorrect default values for primitive types
lincoln
2025/12/24
(flink-shaded) annotated tag release-21.0-rc1 updated (8f9e83c -> 91b9905)
martijnvisser
2025/12/24
svn commit: r81519 - dev/flink/flink-shaded-21.0-rc1
martijnvisser
2025/12/24
(flink) branch release-1.20 updated: [FLINK-38824][table] Fix incorrect default values for primitive types
lincoln
2025/12/23
(flink-agents) branch main updated (ba703da -> 35ab4f2)
xtsong
2025/12/23
(flink-agents) 01/02: [api][runtime] Add return value for add and improve summarization prompt.
xtsong
2025/12/23
(flink-agents) 02/02: [api][runtime] Support use long-term memory in action and async compaction.
xtsong
2025/12/23
svn commit: r81510 - release/flink
martijnvisser
2025/12/23
(flink-shaded) branch master updated: Revert "[hotfix] Add Maven wrapper"
martijnvisser
2025/12/23
(flink-shaded) branch master updated: [hotfix] Add Maven wrapper
martijnvisser
2025/12/23
(flink-shaded) branch master updated: [hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35
martijnvisser
2025/12/23
(flink-shaded) 06/07: [FLINK-38694][Build/Shaded] Update ASM to 9.9.1
martijnvisser
2025/12/23
(flink-shaded) 03/07: [FLINK-38694][Build/Shaded] Update json-path to 2.10.0
martijnvisser
2025/12/23
(flink-shaded) 01/07: [FLINK-38694][Build/Shaded] Update Curator to 5.9.0
martijnvisser
2025/12/23
(flink-shaded) 02/07: [FLINK-38694][Build/Shaded] Update Zookeeper to 3.8.5
martijnvisser
2025/12/23
(flink-shaded) 07/07: [FLINK-38694][Build/Shaded] Update Guava to 33.5.0-jre
martijnvisser
2025/12/23
(flink-shaded) 04/07: [FLINK-38694][Build/Shaded] Update Jackson to 2.20.1
martijnvisser
2025/12/23
(flink-shaded) 05/07: [FLINK-38694][Build/Shaded] Update Swagger to 2.2.41
martijnvisser
2025/12/23
(flink-shaded) branch master updated (8e38d2e -> 013a3af)
martijnvisser
2025/12/23
Re: [I] 一个单节点群集中flink cdc任务超过20个后出错,请问如何调整 [flink-cdc]
via GitHub
2025/12/23
Re: [I] 一个单节点群集中flink cdc任务超过20个后出错,请问如何调整 [flink-cdc]
via GitHub
2025/12/23
(flink-cdc) branch master updated (e2b8076ec -> 2293651e9)
kunni
2025/12/23
(flink-cdc) branch master updated: [FLINK-38813][mysql] Support for emitting heartbeat events (#4193)
kunni
2025/12/22
(flink) branch master updated (e3456e35855 -> ffad337fd15)
panyuepeng
2025/12/22
(flink) branch master updated: [FLINK-38824][table] Fix incorrect default values for primitive types
lincoln
2025/12/19
(flink-connector-kafka) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now 8b784fdd)
github-bot
2025/12/19
(flink-connector-opensearch) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now cbb086b)
github-bot
2025/12/19
(flink-connector-kudu) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now 1d011c9)
github-bot
2025/12/19
(flink-connector-gcp-pubsub) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now ebd0a5f)
github-bot
2025/12/19
(flink-connector-mongodb) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now f6e3981)
github-bot
2025/12/19
(flink-connector-rabbitmq) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now a071d25)
github-bot
2025/12/19
(flink-connector-jdbc) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now 9268ae7d)
github-bot
2025/12/19
(flink-connector-cassandra) branch dependabot/maven/flink-connector-cassandra/org.apache.logging.log4j-log4j-core-2.25.3 created (now ecda1ba)
github-bot
2025/12/19
(flink) branch master updated: [FLINK-38738][table] Expose more context in table connectors to correct UID
twalthr
2025/12/18
(flink-agents) branch main updated: Refactor the resource cross-language test to a cross-language test in CI. (#386)
xtsong
2025/12/18
(flink) 02/02: [FLINK-38758][runtime] Introduce PackagedProgramApplication
zhuzh
2025/12/18
(flink) 01/02: [FLINK-38758][runtime] Use JobStatus instead of ApplicationStatus in JobResult
zhuzh
2025/12/18
(flink) branch master updated (883e33b08b9 -> 4cb44c02699)
zhuzh
2025/12/17
(flink-agents) branch main updated (1ac8583 -> 2d0a8a5)
xtsong
2025/12/17
(flink) branch master updated: [hotfix][table] Fix incorrect error message of `RootArgumentTypeStrategy`
snuyanzin
2025/12/17
(flink-agents) branch main updated: [Feature][runtime] Support the use of Java ChatModel in Python (#373)
xtsong
2025/12/17
(flink-agents) branch main updated (8d14972 -> 8825795)
xtsong
2025/12/17
(flink) branch master updated: [FLINK-38811][docs] Translate async function doc to Chinese (#27346)
shengkai
2025/12/16
(flink-agents) branch release-0.1 updated: [runtime] Remove userCodeClassLoader field for ActionTask to fix can't be serialized to state. (#379)
xtsong
2025/12/16
(flink-agents) branch main updated: [runtime] Remove userCodeClassLoader field for ActionTask to fix can't be serialized to state. (#379)
xtsong
2025/12/16
(flink) branch release-2.1 updated: [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed (#27157)
roman
2025/12/16
(flink) branch release-1.19 updated: [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed (#27157)
roman
2025/12/16
(flink) branch release-2.0 updated: [FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed (#27157)
roman
2025/12/16
(flink) branch master updated: [FLINK-38802][table] DDL with duplicated keys in table options should not fail
snuyanzin
2025/12/15
(flink-cdc) branch master updated: [FLINK-38806] Fix post-transform converters ineffective without projection or filter rules (#4191)
kunni
2025/12/15
(flink) branch master updated: [FLINK-38757][runtime] Introduce the base class for application
zhuzh
2025/12/15
(flink) branch master updated: [FLINK-38776][table] Fix incorrect auxiliary group field names
snuyanzin
2025/12/15
(flink) branch release-2.1 updated: [FLINK-38486] Harden shutdown of system UDFs
roman
2025/12/15
(flink) branch release-2.0 updated: [FLINK-38486] Harden shutdown of system UDFs
roman
2025/12/15
(flink) branch master updated (a56134df9d0 -> c02879020fc)
dwysakowicz
2025/12/15
(flink) 02/02: [hotfix] Pull legacyUidsEnabled as an abstract method to CommonExecTableSourceScan
dwysakowicz
2025/12/15
(flink) 01/02: [FLINK-38765] Fix persisted metadata handling in sink
dwysakowicz
2025/12/15
(flink) branch release-1.20 updated: [FLINK-36026][table] Options from `OPTIONS` hint should be present in compiled plan
mxm
2025/12/14
(flink-connector-aws) branch v5.1 updated: [FLINK-37627] Fix restart from checkpoint/savepoint at shard split can cause data loss
fcsaky
2025/12/14
(flink-connector-aws) branch main updated: [FLINK-37627] Fix restart from checkpoint/savepoint at shard split can cause data loss
fcsaky
2025/12/14
(flink) branch release-1.20 updated: [FLINK-38797][python] Fixed CsvSchemaBuilder.set_null_value to return self
dianfu
2025/12/14
(flink) branch release-2.1 updated: [FLINK-38797][python] Fixed CsvSchemaBuilder.set_null_value to return self
dianfu
2025/12/14
(flink) branch release-2.2 updated: [FLINK-38797][python] Fixed CsvSchemaBuilder.set_null_value to return self
dianfu
2025/12/14
(flink) branch master updated (7ba97419d20 -> a56134df9d0)
dianfu
2025/12/12
(flink) branch release-1.19 updated: [FLINK-38486] Harden shutdown of system UDFs
roman
2025/12/11
(flink-agents) branch main updated: [Feature][runtime] Support the use of Python ChatModel in Java (#314)
xtsong
2025/12/11
(flink-connector-http) branch main updated: [FLINK-38781] Pass format options to response using JSON format
fcsaky
2025/12/11
(flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-lang3-3.18.0 updated (52796937 -> 0c36072d)
fanrui
2025/12/11
(flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-lang3-3.18.0 updated (78e29f8e -> 52796937)
fanrui
2025/12/11
(flink-agents) branch main updated: [ci] Add java 17 pipeline for java ut and it. (#380)
xtsong
2025/12/10
(flink-connector-aws) branch main updated (373be6f -> 68acdbd)
fcsaky
2025/12/09
(flink) branch master updated: [FLINK-38754][runtime] Avoid reverse DNS lookups when connecting to BlobServer
zhuzh
2025/12/09
(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
2025/12/09
(flink-agents) annotated tag release-0.1.1 updated (23ebac6 -> ced7fa6)
sxnan
Earlier messages
Later messages