Commits

Branch selector

 master

User selector

dawidwys

Datepicker

All time

Commit History

Commits on Feb 15, 2022

• [FLINK-25982] Support idleness with watermark alignment

  Show description for 0b1ae18
  dawidwys

  committed
  0b1ae18

  Copy full SHA for 0b1ae18

• [hotfix] Correct JUnit 5 assertions in SourceOperatorAlignmentTest

  dawidwys

  committed
  fec48f3

  Copy full SHA for fec48f3

Commits on Feb 11, 2022

• [FLINK-26076] Fix ArchUnit violations in Source(Sink)MetricsITCase

  Show description for 3aa267b
  dawidwys

  committed
  3aa267b

  Copy full SHA for 3aa267b

Commits on Feb 9, 2022

• [FLINK-25745] Document incremental savepoints in CLAIM mode limitation

  Show description for c1f5c53
  dawidwys

  committed
  c1f5c53

  Copy full SHA for c1f5c53

Commits on Feb 7, 2022

• [FLINK-25952] Savepoints on S3 are not relocatable even if entropy injection is not enabled

  Show description for 27cd145
  dawidwys

  committed
  27cd145

  Copy full SHA for 27cd145

• [hotfix] Rewrite FsCheckpointStreamFactoryTest to JUnit 5

  dawidwys

  committed
  efadb68

  Copy full SHA for efadb68

Commits on Feb 4, 2022

• [FLINK-21752] Add a call to TypeSerializer#duplicate in migration tests

  Show description for 860f0a2
  dawidwys

  committed
  860f0a2

  Copy full SHA for 860f0a2

• [FLINK-21752] NullPointerException on restore in PojoSerializer

  Show description for cde85c5
  dawidwys

  committed
  cde85c5

  Copy full SHA for cde85c5

• [FLINK-25745] Do not log exception if CompletedCheckpointStorageLocation#disposeStorageLocation failed in CLAIM mode

  Show description for d91cb00
  dawidwys

  committed
  d91cb00

  Copy full SHA for d91cb00

• [FLINK-25745] Support RocksDB incremental native savepoints

  Show description for b54acb6
  dawidwys

  committed
  b54acb6

  Copy full SHA for b54acb6

Commits on Jan 31, 2022

• [FLINK-25744][docs] Document savepoint format

  dawidwys

  committed
  cd8ea8d

  Copy full SHA for cd8ea8d

• [FLINK-25744] Support native savepoints

  Show description for f9438dd
  dawidwys

  committed
  f9438dd

  Copy full SHA for f9438dd

• [FLINK-25744] Split CheckpointType for checkpoint & savepoint

  Show description for a14fef0
  dawidwys

  committed
  a14fef0

  Copy full SHA for a14fef0

Commits on Jan 19, 2022

• [FLINK-25194] Implement an API for duplicating artefacts

  dawidwys

  committed
  fc1d635

  Copy full SHA for fc1d635

• [refactor] Make CheckpointStateOutputStream a top level class

  dawidwys

  committed
  72b0e9f

  Copy full SHA for 72b0e9f

Commits on Jan 17, 2022

• [FLINK-25193][docs] Document restore mode

  Show description for 6f2769e
  dawidwys

  committed
  6f2769e

  Copy full SHA for 6f2769e

Commits on Dec 17, 2021

• [hotfix][hack] Make ChangelogStateBackend randomized tests work with forced full snapshots

  dawidwys

  committed
  68f2bc3

  Copy full SHA for 68f2bc3

• [hotfix] Make PseudoRandomValueSelector return the selected value

  dawidwys

  committed
  591f315

  Copy full SHA for 591f315

• [FLINK-25192][checkpointing] Implement no-claim mode support

  Show description for 08794a6
  dawidwys

  committed
  08794a6

  Copy full SHA for 08794a6

Commits on Dec 16, 2021

• [FLINK-25191][checkpointing] Update documentation for savepoints & failure recovery

  dawidwys

  committed
  5be5e1f

  Copy full SHA for 5be5e1f

• [FLINK-25191] Skip savepoints for recovery

  Show description for b19cc31
  dawidwys

  committed
  b19cc31

  Copy full SHA for b19cc31

• [refactor] Extract logCheckpointInfo

  dawidwys

  committed
  f696593

  Copy full SHA for f696593

• [refactor] Extract finalizeCheckpoint method

  dawidwys

  committed
  9d8ecc6

  Copy full SHA for 9d8ecc6

• [refactor] Extract addCompletedCheckpointToStore method

  dawidwys

  committed
  ac6ebf2

  Copy full SHA for ac6ebf2

Commits on Dec 9, 2021

• [FLINK-25155] Support claim mode in rest api

  dawidwys

  committed
  7641c23

  Copy full SHA for 7641c23

• [FLINK-25155] Support claim mode in cli

  dawidwys

  committed
  49c4ed2

  Copy full SHA for 49c4ed2

• [FLINK-25155] Implement claim snapshot restore mode

  Show description for 4c4735b
  dawidwys

  committed
  4c4735b

  Copy full SHA for 4c4735b

Commits on Dec 8, 2021

• [FLINK-23532] Remove unnecessary StreamTask#finishTask

  dawidwys

  committed
  2b167ae

  Copy full SHA for 2b167ae

• [FLINK-23532] Unify stop-with-savepoint without and with drain

  Show description for 0bd397b
  dawidwys

  committed
  0bd397b

  Copy full SHA for 0bd397b

• [hotfix] Remove duplicated handling of stop-with-savepoint trigger failure

  Show description for 5a0dcfb
  dawidwys

  committed
  5a0dcfb

  Copy full SHA for 5a0dcfb

• [FLINK-23532] Pass a flag for draining along with EndOfData

  Show description for 72a2471
  dawidwys

  committed
  72a2471

  Copy full SHA for 72a2471

Commits on Dec 1, 2021

• [FLINK-21467] Clarify javadocs of Bounded(One/Multi)Input interfaces

  Show description for e62913f
  dawidwys

  committed
  e62913f

  Copy full SHA for e62913f

Commits on Nov 3, 2021

• [FLINK-24189] Perform buffer debloating per single gate

  Show description for f6d40bc
  dawidwys

  committed
  f6d40bc

  Copy full SHA for f6d40bc

• [FLINK-24189] Extract BufferDebloatConfiguration

  Show description for 314360e
  dawidwys

  committed
  314360e

  Copy full SHA for 314360e

• [hotfix][tests] Allow customized configuration of input gates in StreamTestSingleInputGate

  dawidwys

  committed
  6d9cca4

  Copy full SHA for 6d9cca4

Pagination

Previous

Next