Messages by Date
-
2025/07/10
(flink-web) 02/03: Add Flink 1.20.2 release
mbalassi
-
2025/07/10
(flink-web) branch asf-site updated (34de995ef -> f250649f2)
mbalassi
-
2025/07/10
(flink-cdc) branch master updated: [docs] improve doc for PostgreSQL (#4055)
kunni
-
2025/07/10
(flink-kubernetes-operator) branch main updated: [hotfix] Fix typo in doc
gyfora
-
2025/07/10
(flink) branch master updated (c02c604c382 -> 9bdad62da3c)
pnowojski
-
2025/07/09
(flink-cdc) branch master updated: [FLINK-38065][cdc-connector/pg] Use curly braces in PostgresOffset#toString()
leonard
-
2025/07/09
(flink-web) branch asf-site updated (a4678c3a8 -> 34de995ef)
gyfora
-
2025/07/09
(flink-web) 01/02: Kubernetes Operator 1.12.1
gyfora
-
2025/07/09
(flink-kubernetes-operator) annotated tag release-1.12.1-rc1 deleted (was b355c0c7)
gyfora
-
2025/07/09
(flink-kubernetes-operator) annotated tag release-1.12.1 updated (0315e911 -> 77b5fea7)
gyfora
-
2025/07/09
svn commit: r78083 - /release/flink/flink-kubernetes-operator-1.12.0/
gyfora
-
2025/07/09
svn commit: r78082 - /dev/flink/flink-kubernetes-operator-1.12.1-rc1/ /release/flink/flink-kubernetes-operator-1.12.1/
gyfora
-
2025/07/09
(flink-agents) branch main updated: [plan][java] Support serializing / deserializing Java workflow plan to / from JSON (#45)
xtsong
-
2025/07/09
(flink) 08/08: [FLINK-37560][docs] Document system events
pnowojski
-
2025/07/09
(flink) 04/08: [FLINK-37561][events] Report AllSubtasksStatusChange event
pnowojski
-
2025/07/09
(flink) 03/08: [FLINK-37561][events] Report job failures as events
pnowojski
-
2025/07/09
(flink) 01/08: [FLINK-37561][events] Report checkpoints as events
pnowojski
-
2025/07/09
(flink) 07/08: [FLINK-37560][docs] Document event reporters
pnowojski
-
2025/07/09
(flink) branch master updated (d8ca92e84bd -> 898e15948fd)
pnowojski
-
2025/07/09
(flink) 05/08: [hotfix][otel] Add missing name to Otel Events
pnowojski
-
2025/07/09
(flink) 02/08: [FLINK-37561][events] Report JobStatusChange event
pnowojski
-
2025/07/09
(flink) 06/08: [hotfix][docs] Fix a couple of bugs in the documentation of traces
pnowojski
-
2025/07/09
(flink) annotated tag release-2.1.0-rc0 updated (71649941e3d -> bb9563045a7)
ron
-
2025/07/09
svn commit: r78080 - in /dev/flink/flink-2.1.0-rc0: ./ python/
ron
-
2025/07/08
(flink-kubernetes-operator) branch main updated: [FLINK-38051] Fix flaky test JobAutoScalerImplTest
gyfora
-
2025/07/08
(flink) branch release-2.1 updated: [FLINK-38040][doc] Add documentation for VARIANT type and PARSE_JSON (#26740)
sxnan
-
2025/07/08
(flink) branch master updated: [FLINK-38040][doc] Add documentation for VARIANT type and PARSE_JSON (#26740)
sxnan
-
2025/07/08
(flink) branch release-2.1 updated: [FLINK-38060][ci] Fix github action failed to build python wheel on linux
ron
-
2025/07/08
(flink) branch master updated: [FLINK-38060][ci] Fix github action failed to build python wheel on linux
ron
-
2025/07/08
(flink) branch master updated: [FLINK-38062][table] `ENCODE` function behaves wrong
snuyanzin
-
2025/07/08
(flink) branch release-1.20 updated: [hotfix][docs] Fix typo in `insert.md`
fcsaky
-
2025/07/08
(flink) branch release-2.1 updated: [hotfix][python] Limits pemja<0.5.4
hxb
-
2025/07/08
(flink) branch master updated: [hotfix][python] Limits pemja<0.5.4
hxb
-
2025/07/08
(flink-docker) branch master updated: Update Dockerfiles for 1.19.3, and 1.20.2 releases
fcsaky
-
2025/07/08
(flink-docker) branch 1.19.3+1.20.2 deleted (was e5c4a8d)
fcsaky
-
2025/07/08
Re: [I] [Bug] Failed to deserialize data of EventHeaderV4 [flink-cdc]
via GitHub
-
2025/07/08
(flink) branch FLINK-FLINK-37991-2 deleted (was 78e3c9d88b2)
hxb
-
2025/07/08
(flink) branch FLINK-FLINK-37991-2 created (now 78e3c9d88b2)
hxb
-
2025/07/08
(flink) branch master updated: [FLINK-36663][Window]Fix the first processWatermark has extra data after restore by restore timeService's watermark. (#25637)
xuyangzhong
-
2025/07/07
(flink-connector-http) branch main updated: [FLIP-532] Initialize repo
rmetzger
-
2025/07/07
(flink-connector-http) 01/01: [FLIP-532] Initialize repo
rmetzger
-
2025/07/07
(flink-connector-http) branch main created (now fc0bbe5)
rmetzger
-
2025/07/07
(flink) branch master updated (fc99b66a1b5 -> fc2b78603b4)
leonard
-
2025/07/07
(flink) branch release-2.1 updated: [FLINK-38022][table] Throw exception in main thread in tests when any exception is thrown in async thread during looking up (#26757)
xuyangzhong
-
2025/07/07
(flink) branch master updated: [FLINK-38038][docs] Fix all typos in code, tests and docs (#26735)
xtsong
-
2025/07/07
(flink) branch master updated: [hotfix] Do not use syntax requiring java higher than java 11
snuyanzin
-
2025/07/07
(flink-docker) branch 1.19.3+1.20.2 created (now e5c4a8d)
fcsaky
-
2025/07/07
(flink-docker) 01/01: Update Dockerfiles for 1.19.3, and 1.20.2 releases
fcsaky
-
2025/07/07
(flink) annotated tag release-1.19.3 updated (4105f8d125f -> 6d2a5c29cd3)
fcsaky
-
2025/07/07
(flink) annotated tag release-1.20.2 updated (1641cb9e43d -> c261dc1cdd6)
fcsaky
-
2025/07/07
(flink-docker) branch dev-1.20 updated: Add GPG key for 1.20.2 release
fcsaky
-
2025/07/07
(flink-docker) branch dev-1.19 updated: Add GPG key for 1.19.3 release
fcsaky
-
2025/07/07
svn commit: r78006 - /dev/flink/flink-1.20.2-rc2/ /release/flink/flink-1.20.2/
mbalassi
-
2025/07/07
svn commit: r78005 - /dev/flink/flink-1.19.3-rc2/ /release/flink/flink-1.19.3/
mbalassi
-
2025/07/07
(flink-connector-kafka) branch main updated: [FLINK-37983] Update to Kafka client 3.9.1 (#180)
arvid
-
2025/07/07
(flink) branch master updated: [FLINK-38056][s3] Improve interruption handling for s5cmd
pnowojski
-
2025/07/07
(flink) branch master updated: [FLINK-37591][table] Add some PruneEmptyRules (#25826)
xuyangzhong
-
2025/07/07
(flink) branch master updated: [FLINK-38022][table] Throw exception in main thread in tests when any exception is thrown in async thread during looking up (#26752)
xuyangzhong
-
2025/07/07
(flink) 02/06: [FLINK-37985][conf] Refactor public config options from StreamConfig to JobConfiguration
fanrui
-
2025/07/07
(flink) 04/06: [FLINK-37985][conf] Refactor CheckpointingMode from StreamConfig to JobConfiguration
fanrui
-
2025/07/07
(flink) 05/06: [FLINK-37985][conf] Refactor CheckpointingEnabled from StreamConfig to JobConfiguration
fanrui
-
2025/07/07
(flink) 03/06: [FLINK-37985][conf] Extract some static methods in CheckpointingOptions to simplify read config options
fanrui
-
2025/07/07
(flink) 06/06: [FLINK-37985][test] Introduce the arch rules to prevent some checkpoint config options are got directly from Configuration.get() or Configuration.getOptional()
fanrui
-
2025/07/07
(flink) 01/06: [FLINK-37985][hotfix] Cleanup unused fields and methods in StreamConfig
fanrui
-
2025/07/07
(flink) branch master updated (c1685d93a76 -> 4110ca7f162)
fanrui
-
2025/07/06
(flink-agents) branch main updated: [all] Rename Workflow to Agent
xtsong
-
2025/07/06
(flink-agents) branch main updated (2f21451 -> ad9adf9)
hxb
-
2025/07/06
svn commit: r77985 - /release/flink/KEYS
lincoln
-
2025/07/06
(flink) branch master updated: [FLINK-38039][docs] Improve instructions for using SQL connectors in Docker mode (#26736)
xtsong
-
2025/07/04
(flink) branch master updated (d24c7469632 -> edfd7f99755)
fcsaky
-
2025/07/04
(flink) branch release-2.1 updated: [FLINK-38043][table] Use empty row instead of null for no join keys
arvid
-
2025/07/04
(flink-connector-shared-utils) branch ci_utils updated: Update Python CI setup steps
arvid
-
2025/07/04
(flink) branch master updated (d2e47276add -> d24c7469632)
gaborgsomogyi
-
2025/07/04
(flink-cdc) branch master updated: [Fix][Docs] Quick Start mysql-to-starrocks Flink Version Incorrect (#4052)
kunni
-
2025/07/04
(flink-cdc) branch master updated: docs: updated StarRocks documentation link (#4054)
kunni
-
2025/07/04
(flink-web) branch asf-site updated: [hotfix] Refresh Slack invite link
martijnvisser
-
2025/07/03
(flink) branch dependabot/maven/flink-connectors/flink-sql-connector-hive-2.3.10/org.apache.hive-hive-exec-4.0.1 deleted (was 73d5c097987)
github-bot
-
2025/07/03
(flink) branch master updated: [FLINK-38043][table] Use empty row instead of null for no join keys
arvid
-
2025/07/03
(flink-cdc) branch master updated: Update starrocks.md (#4021)
kunni
-
2025/07/03
(flink) branch master updated (f72e1df8e2a -> d564c992a77)
fcsaky
-
2025/07/03
(flink) 02/02: [hotfix] Check existing community review labels and do not reapply them
fcsaky
-
2025/07/03
(flink) 01/02: [hotfix] Standardize `community-review.sh` formatting and expression usage
fcsaky
-
2025/07/03
(flink) branch release-2.1 updated: [FLINK-38037][table] Configure hashDistribution with commonJoinKey (#26734) (#26746)
dwysakowicz
-
2025/07/03
Re: [I] Serialized size (> 1682584050 bytes) exceeds JVM heap space [flink-cdc]
via GitHub
-
2025/07/03
(flink-kubernetes-operator) annotated tag release-1.12.1-rc1 updated (0315e911 -> b355c0c7)
gyfora
-
2025/07/03
svn commit: r77918 - /dev/flink/flink-kubernetes-operator-1.12.1-rc1/
gyfora
-
2025/07/03
(flink-kubernetes-operator) 01/02: [FLINK-37895][Job Manager] Fix failing collection of Flink Exceptions for Session Jobs
gyfora
-
2025/07/03
(flink-kubernetes-operator) branch release-1.12 updated (0cd8050b -> de48cdd6)
gyfora
-
2025/07/03
(flink-kubernetes-operator) 02/02: [FLINK-38033] Fix accidental upgrade snapshot dispose bug
gyfora
-
2025/07/02
(flink) branch release-2.0 updated: [FLINK-33926][k8s] Allow using job JARs in the system classpath in native mode
fcsaky
-
2025/07/02
(flink) branch release-2.1 updated: [FLINK-33926][k8s] Allow using job JARs in the system classpath in native mode
fcsaky
-
2025/07/02
(flink) branch release-2.1 updated: [FLINK-38030][table-planner] Fix cast exception for TableLineageDatasetImpl when the catalog is not a AbstractCatalog (#26727) (#26739)
xuyangzhong
-
2025/07/02
(flink) branch release-2.0 updated: [FLINK-38030][table-planner] Fix cast exception for TableLineageDatasetImpl when the catalog is not a AbstractCatalog (#26738)
xuyangzhong
-
2025/07/02
(flink) branch master updated: [FLINK-38041] Fix Schema.Builder#fromResolvedSchema dropping comments (#26741)
arvid
-
2025/07/02
(flink) branch master updated: [FLINK-33926][k8s] Allow using job JARs in the system classpath in native mode
fcsaky
-
2025/07/02
(flink) branch master updated (4aa434fbf46 -> e80c2c22bde)
fcsaky
-
2025/07/02
(flink-kubernetes-operator) branch main updated: [FLINK-38033] Fix accidental upgrade snapshot dispose bug
gyfora
-
2025/07/02
(flink-kubernetes-operator) branch main updated: [FLINK-37895][Job Manager] Fix failing collection of Flink Exceptions for Session Jobs
gyfora
-
2025/07/02
(flink) branch master updated (5497b714347 -> 4aa434fbf46)
dwysakowicz
-
2025/07/01
(flink) branch master updated: [FLINK-38030][table-planner] Fix cast exception for TableLineageDatasetImpl when the catalog is not a AbstractCatalog (#26727)
xuyangzhong
-
2025/07/01
(flink) branch master updated: [FLINK-38036][table] Make PlannerBase#getExecNodeGraphProcessors public
snuyanzin
-
2025/07/01
(flink) branch master updated: [hotfix][test] Move `SlotSharingSlotAllocatorTest#getSlots` into `TestingSlot`
fcsaky
-
2025/06/30
(flink-agents) branch main updated: [Feature][runtime] Introducing the FlinkRunnerContext component to support Python workflow execution (#43)
hxb
-
2025/06/30
(flink) branch master updated (a2f6b1ee3a5 -> c7011080223)
fcsaky
-
2025/06/30
(flink) branch master updated: [hotfix] Change community review job name from `test` to `label`
fcsaky
-
2025/06/30
(flink) branch master updated: [FLINK-37770][ci] Add community review GitHub workflow
fcsaky
-
2025/06/29
(flink) branch master updated: [FLINK-38027][table] Simplify watermark expressions
snuyanzin
-
2025/06/29
(flink) branch master updated: [FLINK-38010][release] Build doc for release-2.1 branch
ron
-
2025/06/29
(flink) branch release-2.1 updated: [FLINK-38019][table] Fix unstable AsyncMLPredictITCase(#26724)
shengkai
-
2025/06/29
(flink-benchmarks) branch master updated: [FLINK-38010] Bump flink version to 2.2-SNAPSHOT (#105)
ron
-
2025/06/29
(flink) branch master updated (95760810b3d -> d0998173d5f)
shengkai
-
2025/06/27
(flink-connector-aws) 01/01: [hotfix][build] Remove Python CI to fix CI
hong
-
2025/06/27
(flink-connector-aws) tag v5.1.0-rc1 created (now 9985260)
hong
-
2025/06/27
(flink-connector-aws) tag v5.1.0-rc1 deleted (was 94ff905)
hong
-
2025/06/27
(flink) branch release-1.20 updated: [FLINK-37991][python] Upgrade pemja to 0.5.3 (#26720)
hxb
-
2025/06/27
(flink) branch release-2.1 updated: [FLINK-37991][python] Upgrade pemja to 0.5.3
hxb
-
2025/06/27
(flink) branch master updated: [FLINK-37991][python] Upgrade pemja to 0.5.3 (#26714)
hxb
-
2025/06/26
svn commit: r77780 - in /dev/flink/flink-connector-aws-6.0.0-rc1: ./ flink-connector-aws-6.0.0-src.tgz flink-connector-aws-6.0.0-src.tgz.asc flink-connector-aws-6.0.0-src.tgz.sha512
dannycranmer
-
2025/06/26
svn commit: r77779 - in /dev/flink/flink-connector-aws-5.1.0-rc1: ./ flink-connector-aws-5.1.0-src.tgz flink-connector-aws-5.1.0-src.tgz.asc flink-connector-aws-5.1.0-src.tgz.sha512
dannycranmer
-
2025/06/26
(flink-connector-aws) 02/02: [hotfix][build] Update submodule to latest commit
hong
-
2025/06/26
(flink-connector-aws) annotated tag v5.1.0-rc1 deleted (was dd1e2fa)
hong
-
2025/06/26
(flink-connector-aws) tag v5.1.0-rc1 created (now 94ff905)
hong
-
2025/06/26
(flink-connector-aws) tag v6.0.0-rc1 created (now a114599)
hong
-
2025/06/26
(flink-connector-aws) 01/02: Update version to 5.1.0
hong
-
2025/06/26
(flink-connector-aws) branch v5.1 updated (d22078f -> 685ded5)
hong
-
2025/06/26
(flink-connector-aws) tag v5.1.0-rc1 deleted (was fc62467)
hong
-
2025/06/26
(flink-connector-aws) 01/02: Update version to 5.1.0
hong
-
2025/06/26
(flink-connector-aws) tag v5.1.0-rc1 created (now fc62467)
hong
-
2025/06/26
(flink-connector-aws) 02/02: [hotfix][build] Update submodule to latest commit
hong
-
2025/06/26
(flink-connector-aws) 01/02: Update version to 6.0.0
hong
-
2025/06/26
(flink-connector-aws) 02/02: [hotfix][build] Update submodule to latest commit
hong
-
2025/06/26
(flink-connector-aws) annotated tag v6.0.0-rc1 deleted (was ee9cfd0)
hong
-
2025/06/26
(flink) 02/02: [hotfix] Use `JavaConverters` instead of deprecated `JavaConversions` in `IntervalJoinUtil`
snuyanzin
-
2025/06/26
(flink) 01/02: [FLINK-37980][table] Adapt Multi-way join to higher Calcite versions (Calcite 1.35+)
snuyanzin
-
2025/06/26
(flink) branch master updated (99e459456b6 -> ce03ea11d10)
snuyanzin
-
2025/06/26
(flink) branch master updated: [FLINK-37851][state] Migrate state processor API from source API v1 to source API v2
gaborgsomogyi
-
2025/06/26
(flink-connector-aws) annotated tag v6.0.0-rc1 updated (b41fa21 -> ee9cfd0)
hong
-
2025/06/26
(flink-connector-aws) branch v6.0 created (now 373be6f)
hong
-
2025/06/26
(flink-connector-aws) annotated tag v5.1.0-rc1 updated (b9e578b -> dd1e2fa)
hong
-
2025/06/26
(flink-agents) branch main updated: [plan][python] Support serialize/deserialize workflow plan to/from json. (#39)
xtsong
-
2025/06/26
(flink) branch master updated (9365049facc -> 97377efc8e7)
ron
-
2025/06/26
(flink) branch release-2.1 created (now 4f246e46082)
ron
-
2025/06/26
(flink) 01/01: Update for 2.1.0
ron
-
2025/06/26
(flink-agents) branch main updated (663dd1e -> 989f249)
xtsong
-
2025/06/25
(flink-cdc) branch master updated: [hotfix][ci] Add missing Iceberg unit tests & split pipeline connector UT into stages (#4046)
gongzhongqiang
-
2025/06/25
(flink-agents) branch main updated: [infra] Add Hao Li as collaborator on github
xtsong
-
2025/06/25
(flink-connector-kafka) branch dependabot/maven/org.apache.kafka-kafka-clients-3.9.1 deleted (was ba7af9d4)
github-bot
-
2025/06/25
(flink) 01/02: [FLINK-37701] Address missed nit from #26663 on using @NonNull annotations.
fanrui
-
2025/06/25
(flink-connector-aws) branch main updated: [FLINK-37866] Migrate glue schema registry e2e test to use aws-kinesis-streams connector
hong
-
2025/06/25
(flink) 02/02: [FLINK-37701] Extract LocalRecoverTest to reduce AdaptiveSchedulerTest length, restore checkstyle line-length limit.
fanrui
-
2025/06/25
(flink) branch master updated (15c48d3b446 -> 9365049facc)
fanrui
-
2025/06/25
(flink-agents) branch main updated: [api][python] Introduce Python API for Workflow, Event and Action.
xtsong
-
2025/06/24
(flink-agents) branch main updated: [Feature][runtime] Adds support of Python Environment Manager (#37)
hxb
-
2025/06/24
(flink) branch master updated (df5bdc6b31f -> 15c48d3b446)
xuyangzhong
-
2025/06/24
(flink-agents) branch main updated: [plan][java] Introduce Workflow, Event, Action & Function in the Java Workflow Plan.
xtsong
-
2025/06/24
(flink-agents) branch main updated: [build] Add 'flink-agents-' prefix to maven artifact ids.
xtsong
-
2025/06/23
(flink) 01/02: Revert "[Flink-37703][hadoop] Add more log info to locate the root cause of failed HadoopRecoverableWriterTest#testRecoverFromIntermWithoutAdditionalState in azure cron pipeline (#26646)"
ron
-
2025/06/23
(flink) branch master updated (bf6333cfa22 -> df5bdc6b31f)
ron
-
2025/06/23
(flink) 02/02: [FLINK-37703][hadoop] Splitting the non-local write unit test to seperated class to fix the unstable tests
ron
-
2025/06/23
(flink-agents) branch main updated (cc6fd45 -> f25093d)
xtsong
-
2025/06/23
(flink-agents) branch main updated: [Feature][runtime] Adds the basic components from flink-statefun to implement feedback ability (#30)
hxb
-
2025/06/22
(flink-agents) branch statefun-basic deleted (was caafa3d)
hxb
-
2025/06/22
(flink-agents) 01/01: update NOTICE
hxb
-
2025/06/22
(flink-agents) branch statefun-basic created (now caafa3d)
hxb
-
2025/06/22
(flink) branch master updated: [FLINK-37978][table] Change buffer-capacity to max-concurrent-operations for ml_predict (#26706)
shengkai
-
2025/06/22
(flink) branch master updated: [FLINK-37365][pyflink] Add API stability decorators for PyFlink APIs
snuyanzin
-
2025/06/21
(flink-agents) branch main updated: [plan][python] Init Event, Action, Function and WorkflowPlan.
xtsong
-
2025/06/21
(flink) branch master updated: [FLINK-37799][model][docs] Add document for OpenAI Model Function (#26671)
shengkai
-
2025/06/20
(flink) branch master updated: [FLINK-37797][doc] Add model documentation (#26694)
shengkai
-
2025/06/20
(flink) 03/03: [FLINK-37923][sql] Introduce variant type and PARSE_JSON to Flink SQL
sxnan
-
2025/06/20
(flink) 02/03: [FLINK-37923][core] Introduce Variant and BinaryVariant
sxnan
-
2025/06/20
(flink) 01/03: [FLINK-37923][sql] Patch calcite to support variant type
sxnan
-
2025/06/20
(flink) branch master updated (615e19bacba -> 2b13a566955)
sxnan
-
2025/06/20
(flink) branch master updated (3aee6acee2b -> 615e19bacba)
martijnvisser
-
2025/06/20
(flink-connector-jdbc) branch main updated: [FLINK-36236] Fix overriding the connection provider in `JdbcSourceBuilder`
fcsaky
-
2025/06/20
(flink) branch master updated: [hotfix] Reuse inline field `barrierId` in `CheckpointBarrierTracker`
fcsaky
-
2025/06/20
(flink) branch master updated: [FLINK-37422][state/forst] Respect the `maxTransferBytes` when using path copying in ForSt (#26700)
zakelly
-
2025/06/20
(flink-kubernetes-operator) branch release-1.12 updated: Refactor: Minor typo correction (#986)
mxm
-
2025/06/20
(flink) branch master updated: [FLINK-35051][checkpoint] Treat handling of unaligned checkpoint barrier as the high priority mail (#26660)
fanrui
-
2025/06/20
Re: [I] [Bug] Failed to deserialize data of EventHeaderV4 [flink-cdc]
via GitHub
-
2025/06/20
Re: [I] [Bug] Failed to deserialize data of EventHeaderV4 [flink-cdc]
via GitHub
-
2025/06/20
(flink) branch master updated (8e7273d3392 -> 5334e7d1f97)
twalthr
-
2025/06/19
(flink) branch master updated: [FLINK-37877][table] Add the key ordered operator in table runtime for key ordered async lookup join (#26668)
xuyangzhong
-
2025/06/19
Re: [I] [Bug] Flink CDC 2.3.0 set startupOptions = specificOffset set specificOffsetFile and specificOffsetPos then can not start from checkpoint [flink-cdc]
via GitHub
-
2025/06/19
Re: [I] [Bug] Flink CDC 2.3.0 set startupOptions = specificOffset set specificOffsetFile and specificOffsetPos then can not start from checkpoint [flink-cdc]
via GitHub
-
2025/06/19
(flink) branch master updated: [FLINK-37701] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment.
dmvk
-
2025/06/19
(flink) branch master updated: [FLINK-37867][state/forst] Ensure files of half-uploaded checkpoints are cleaned when using path copying (#26696)
zakelly
-
2025/06/19
(flink) branch master updated (ef5b0329709 -> a4958171f1d)
zakelly
-
2025/06/19
(flink) branch master updated (f7f96af5355 -> ef5b0329709)
xuyangzhong
-
2025/06/19
(flink) branch master updated (4f424c7a6fd -> f7f96af5355)
twalthr
-
2025/06/18
(flink) branch dependabot/maven/flink-end-to-end-tests/flink-sql-client-test/org.apache.kafka-kafka-clients-3.7.1 deleted (was 62ac3b56c32)
github-bot
-
2025/06/18
(flink) branch master updated: [FLINK-37969] Allow Transformation subgraphs to be merged during translation
arvid
-
2025/06/18
(flink) branch master updated (5d98b8a277a -> 40feb66693b)
snuyanzin
-
2025/06/18
(flink-agents) branch main updated: [hotfix] Fix the ut.sh for java tests (#31)
hxb
-
2025/06/17
(flink) branch master updated: [FLINK-37249] Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util
junrui
-
2025/06/17
(flink) branch master updated (edc776b403c -> 7b73fb5954e)
zakelly
-
2025/06/17
Re: [I] I want to use flink cdc to synchronize oracle data to doris, but I find that the data in oracle cannot be synchronized successfully. [flink-cdc]
via GitHub
-
2025/06/17
Re: [I] I want to use flink cdc to synchronize oracle data to doris, but I find that the data in oracle cannot be synchronized successfully. [flink-cdc]
via GitHub
-
2025/06/17
Re: [I] I want to use flink cdc to synchronize oracle data to doris, but I find that the data in oracle cannot be synchronized successfully. [flink-cdc]
via GitHub
-
2025/06/17
(flink) branch release-1.19 updated: [FLINK-37946][backport][doc] fix sql syntax of page Table API & SQL EXPLAIN
snuyanzin