Commits

Commits on Mar 8, 2024

[FLINK-34617][docs] Correct the Javadoc of org.apache.flink.api.common.time.Time
Myasuka
committedMar 8, 2024

Commits on Feb 6, 2024

[hotfix][web] Correct the hint of options name of rest.profiling.enabled
Myasuka
committedFeb 6, 2024

Commits on Nov 24, 2023

[FLINK-33598][k8s] Mark configmap related label constants as deprecated
Myasuka
committedNov 24, 2023
[FLINK-33598][k8s] Watch HA configmap via name instead of lables to reduce pressure on APIserver
Myasuka
committedNov 24, 2023

Commits on Mar 31, 2023

[FLINK-31683][docs-zh] Update the outdated Chinese filesystem connector docs
Myasuka
committedMar 31, 2023

Commits on Mar 7, 2023

[FLINK-31283][docs] Update the scala-2.11 related building doc
Myasuka
committedMar 7, 2023

Commits on Mar 6, 2023

[FLINK-31324][connector] Reintroduce previous SingleThreadFetcherManager constructor and mark it as deprecated
Myasuka
committedMar 6, 2023

Commits on Jan 19, 2023

[FLINK-30724][docs] Update kafka-per-partition watermark to new source
Myasuka
committedJan 19, 2023

Commits on Aug 31, 2022

[FLINK-29130][state] Correct the doc description of local-recovery
Myasuka
committedAug 31, 2022

Commits on Jul 14, 2022

[FLINK-24786][state] Introduce and expose RocksDB statistics as metrics
Myasuka
committedJul 14, 2022

Commits on May 17, 2022

[FLINK-27433][tests] Store RocksDB logs in its database folder for e2e tests
Myasuka
committedMay 17, 2022

Commits on Mar 31, 2022

[FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend
Myasuka
committedMar 31, 2022

Commits on Mar 30, 2022

[FLINK-26882][tests] Fix unstable RescaleCheckpointManuallyITCase
Myasuka
committedMar 30, 2022

Commits on Mar 15, 2022

Commits on Mar 10, 2022

[FLINK-26550][checkpoint] Correct the information of checkpoint failure
Myasuka
committedMar 10, 2022

Commits on Mar 7, 2022

[FLINK-26464][metrics] Make the meaning of lastCheckpointSize stay as before
Myasuka
committedMar 7, 2022

Commits on Mar 1, 2022

[hotfix][javadoc] Fix typo of getTriggeredSavepointStatus
Myasuka
committedMar 1, 2022

Commits on Feb 14, 2022

Commits on Feb 11, 2022

Commits on Jan 27, 2022

[FLINK-25557][docs] Add documentation for incremental checkpoint size
Myasuka
committedJan 27, 2022
[FLINK-25557][changelog] Introduce incremental checkpoint size stats for changelog state
Myasuka
committedJan 27, 2022
[FLINK-25557][checkpoint] Introduce incremental/full checkpoint size Statistics
Myasuka
committedJan 27, 2022

Commits on Dec 29, 2021

[FLINK-25465][state] Correct the logic of materizating wrapped changelog state
Myasuka
committedDec 29, 2021
[hotfix] Refactor type of states within ChangelogKeyedStateBackend
Myasuka
committedDec 29, 2021

Commits on Dec 28, 2021

[FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])
Myasuka
committedDec 28, 2021

Commits on Dec 24, 2021

[FLINK-25429][state] Avoid to close output streams twice during uploading changelogs
Myasuka
committedDec 24, 2021

Commits on Dec 10, 2021

Commits on Dec 6, 2021

[FLINK-21027][state] Introduce KeyedStateBackend#isSafeToReuseKVState for opmitization hint (apache#17945 )
Myasuka
committedDec 6, 2021

Commits on Nov 26, 2021

[FLINK-25067][doc] Correct the description of RocksDB's background threads for flush and compaction
Myasuka
committedNov 26, 2021