Commits

Branch selector

 master

User selector

Myasuka

Datepicker

All time

Commit History

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

Commits on Sep 7, 2021

• [FLINK-23983][tests] Ensure to close and dispose created keyed-statebackend in StateBackendTestBase

  Myasuka

  committed
  4f5978f

  Copy full SHA for 4f5978f

Commits on Sep 2, 2021

• [FLINK-24106][docs] Remove notice that pyflink does not support state TTL

  Myasuka

  committed
  aa2dddc

  Copy full SHA for aa2dddc

Commits on Aug 31, 2021

• [FLINK-23519][metrics] Expose state name as varibale if enable state latency tracking

  Myasuka

  committed
  e2bda3d

  Copy full SHA for e2bda3d

Commits on Aug 27, 2021

• [FLINK-23800][rocksdb] Expose live-sst-files-size to RocksDB native metrics

  Myasuka

  committed
  bbcdb0b

  Copy full SHA for bbcdb0b

Commits on Aug 17, 2021

• [FLINK-23789][rocksdb] Remove unnecessary setTotalOrderForSeek for Rocks iterator

  Show description for ee74231
  Myasuka

  authored
  ee74231

  Copy full SHA for ee74231

• [FLINK-23649][rocksdb] Add FRocksDB packages to parent-first classloading patterns

  Myasuka

  committed
  d57d9f8

  Copy full SHA for d57d9f8

Commits on Jul 23, 2021

• [FLINK-23471][checkpoint] Try best to ensure all operators and state manager handle the checkpoint complete notification

  Myasuka

  committed
  fdde1e4

  Copy full SHA for fdde1e4

Commits on Jul 22, 2021

• [FLINK-21411][rocksdb] Update FRocksDB to bump bzip2 dependency version

  Show description for 26aa7b4
  

  Myasuka

  authored and

  tillrohrmann

  committed
  26aa7b4

  Copy full SHA for 26aa7b4

Commits on Jul 16, 2021

• [FLINK-23367][state] Ensure InternalPriorityQueue#iterator could be closed for changelog state-backend

  Myasuka

  committed
  c225a8c

  Copy full SHA for c225a8c

Commits on Jul 2, 2021

• [FLINK-22528][docs] Document latency tracking metrics for state accesses

  Myasuka

  committed
  9e3b09d

  Copy full SHA for 9e3b09d

Commits on Jun 21, 2021

• [FLINK-23018][state] Enable state factories to handle extended state descriptors

  Myasuka

  committed
  73c103b

  Copy full SHA for 73c103b

Pagination

Previous

Next