Commits

Branch selector

 master

User selector

Myasuka

Datepicker

All time

Commit History

Commits on Mar 8, 2024

• [FLINK-34617][docs] Correct the Javadoc of org.apache.flink.api.common.time.Time

  Myasuka

  committed
  9617598

  Copy full SHA for 9617598

Commits on Feb 6, 2024

• [hotfix][web] Correct the hint of options name of rest.profiling.enabled

  Myasuka

  committed
  d2ed2df

  Copy full SHA for d2ed2df

Commits on Nov 24, 2023

• [FLINK-33598][k8s] Mark configmap related label constants as deprecated

  Myasuka

  committed
  b7e8b79

  Copy full SHA for b7e8b79

• [FLINK-33598][k8s] Watch HA configmap via name instead of lables to reduce pressure on APIserver

  Myasuka

  committed
  608546e

  Copy full SHA for 608546e

Commits on Mar 31, 2023

• [FLINK-31683][docs-zh] Update the outdated Chinese filesystem connector docs

  Myasuka

  committed
  370929c

  Copy full SHA for 370929c

Commits on Mar 7, 2023

• [FLINK-31283][docs] Update the scala-2.11 related building doc

  Myasuka

  committed
  6ac4084

  Copy full SHA for 6ac4084

Commits on Mar 6, 2023

• [FLINK-31324][connector] Reintroduce previous SingleThreadFetcherManager constructor and mark it as deprecated

  Show description for d5a6606
  Myasuka

  committed
  d5a6606

  Copy full SHA for d5a6606

Commits on Jan 19, 2023

• [FLINK-30724][docs] Update kafka-per-partition watermark to new source

  Myasuka

  committed
  2a9ceb7

  Copy full SHA for 2a9ceb7

Commits on Aug 31, 2022

• [FLINK-29130][state] Correct the doc description of local-recovery

  Myasuka

  committed
  581e1fe

  Copy full SHA for 581e1fe

Commits on Jul 14, 2022

• [FLINK-24786][state] Introduce and expose RocksDB statistics as metrics

  Myasuka

  committed
  46e0014

  Copy full SHA for 46e0014

Commits on May 17, 2022

• [FLINK-27433][tests] Store RocksDB logs in its database folder for e2e tests

  Myasuka

  authored
  f5aee6e

  Copy full SHA for f5aee6e

Commits on Mar 31, 2022

• [FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend

  Myasuka

  committed
  d8f6279

  Copy full SHA for d8f6279

Commits on Mar 30, 2022

• [FLINK-26882][tests] Fix unstable RescaleCheckpointManuallyITCase

  Myasuka

  committed
  317ba33

  Copy full SHA for 317ba33

Commits on Mar 15, 2022

• [FLINK-26650][checkpoint] Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

  Myasuka

  committed
  2710878

  Copy full SHA for 2710878

• Revert "[FLINK-25528][state-processor-api] state processor api do not support increment checkpoint"

  Myasuka

  committed
  b4f67b7

  Copy full SHA for b4f67b7

Commits on Mar 10, 2022

• [FLINK-26550][checkpoint] Correct the information of checkpoint failure

  Myasuka

  committed
  254c918

  Copy full SHA for 254c918

Commits on Mar 7, 2022

• [FLINK-26464][metrics] Make the meaning of lastCheckpointSize stay as before

  Myasuka

  committed
  b2f4c0e

  Copy full SHA for b2f4c0e

Commits on Mar 1, 2022

• [hotfix][javadoc] Fix typo of getTriggeredSavepointStatus

  Myasuka

  committed
  7368370

  Copy full SHA for 7368370

Commits on Feb 14, 2022

• [FLINK-26101][changelog] Avoid shared state registry to discard multi-registered identical changelog state

  Show description for 8b25ae6
  Myasuka

  committed
  8b25ae6

  Copy full SHA for 8b25ae6

• [FLINK-25466][state] Enable state descriptor to handle StateTtlConfig#DISABLED

  Myasuka

  committed
  c1c9665

  Copy full SHA for c1c9665

Commits on Feb 11, 2022

• [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

  Myasuka

  committed
  a519ed1

  Copy full SHA for a519ed1

• [hotfix][changelog] Let ChangelogStateHandleStreamImpl to serialize checkpointed size

  Myasuka

  committed
  ae16608

  Copy full SHA for ae16608

Commits on Jan 27, 2022

• [FLINK-25557][docs] Add documentation for incremental checkpoint size

  Myasuka

  committed
  ca519f6

  Copy full SHA for ca519f6

• [FLINK-25557][changelog] Introduce incremental checkpoint size stats for changelog state

  Myasuka

  committed
  b2968c7

  Copy full SHA for b2968c7

• [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size Statistics

  Myasuka

  committed
  d34653c

  Copy full SHA for d34653c

Commits on Dec 29, 2021

• [FLINK-25465][state] Correct the logic of materizating wrapped changelog state

  Myasuka

  committed
  5739196

  Copy full SHA for 5739196

• [hotfix] Refactor type of states within ChangelogKeyedStateBackend

  Myasuka

  committed
  d40fc21

  Copy full SHA for d40fc21

Commits on Dec 28, 2021

• [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

  Myasuka

  committed
  c0f46ef

  Copy full SHA for c0f46ef

Commits on Dec 24, 2021

• [FLINK-25429][state] Avoid to close output streams twice during uploading changelogs

  Myasuka

  committed
  804eb8d

  Copy full SHA for 804eb8d

Commits on Dec 10, 2021

• [hotfix] Remove VisibleForTesting for AbstractStreamOperator#getKeyedStateBackend

  Myasuka

  committed
  def3855

  Copy full SHA for def3855

• [FLINK-21504] Add tests to combine subsume with checkpoints and savepoints

  Myasuka

  committed
  4a7fea2

  Copy full SHA for 4a7fea2

• [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

  Myasuka

  committed
  bfbf0fc

  Copy full SHA for bfbf0fc

• [FLINK-21504][checkpoint] Return the subsumed checkpoint when adding the completed checkpoint

  Myasuka

  committed
  b04646b

  Copy full SHA for b04646b

Commits on Dec 6, 2021

• [FLINK-21027][state] Introduce KeyedStateBackend#isSafeToReuseKVState for opmitization hint (apache#17945)

  Myasuka

  authored
  bd4b0aa

  Copy full SHA for bd4b0aa

Commits on Nov 26, 2021

• [FLINK-25067][doc] Correct the description of RocksDB's background threads for flush and compaction

  Myasuka

  committed
  832d412

  Copy full SHA for 832d412

Pagination

Previous

Next