Commits

Branch selector

 master

User selector

StefanRRichter

Datepicker

All time

Commit History

Commits on Oct 20, 2017

• [FLINK-5372] [tests] Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

  StefanRRichter

  committed
  dbf4c86

  Copy full SHA for dbf4c86

Commits on Oct 18, 2017

• [FLINK-7757] [checkpointing] Introduce resource guard for RocksDBKeyedStateBackend to reduce locking and avoid blocking behavior.

  Show description for 7d026aa
  StefanRRichter

  committed
  7d026aa

  Copy full SHA for 7d026aa

Commits on Sep 25, 2017

• [FLINK-7619] Improved abstraction of AbstractAsyncIOCallable to better fit the current usage pattern.

  StefanRRichter

  committed
  5af463a

  Copy full SHA for 5af463a

• [FLINK-7524] Remove potentially blocking behaviour from AbstractCloseableRegistry.

  StefanRRichter

  committed
  0073204

  Copy full SHA for 0073204

Commits on Aug 24, 2017

• [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

  StefanRRichter

  committed
  6642768

  Copy full SHA for 6642768

• [FLINK-7505] Use lambdas in suppressed exception idiom

  StefanRRichter

  committed
  5456cf9

  Copy full SHA for 5456cf9

• [FLINK-7460] [state backends] Close all ColumnFamilyHandles when restoring from rescaled incremental checkpoints

  StefanRRichter

  committed
  ca87bec

  Copy full SHA for ca87bec

Commits on Aug 15, 2017

• [FLINK-7362] [checkpoints] Savepoint property is lost after de/serialization of CheckpointProperties

  StefanRRichter

  committed
  843f0cb

  Copy full SHA for 843f0cb

• [FLINK-7268] [checkpoints] Scope SharedStateRegistry objects per (re)start

  StefanRRichter

  committed
  91a4b27

  Copy full SHA for 91a4b27

• [FLINK-7213] Introduce state management by OperatorID in TaskManager

  StefanRRichter

  committed
  b71154a

  Copy full SHA for b71154a

Commits on Aug 4, 2017

• [FLINK-7369] [backend] Add more information for 'Key group index out of range of key group range' exception

  StefanRRichter

  committed
  0477753

  Copy full SHA for 0477753

Commits on Jul 28, 2017

• Stephan's feedback

  StefanRRichter

  committed
  219ae33

  Copy full SHA for 219ae33

• Bump to 5.6.1

  StefanRRichter

  committed
  d7b0661

  Copy full SHA for d7b0661

• [FLINK-7220] [checkpoints] Update RocksDB dependency to 5.5.5

  StefanRRichter

  committed
  d818fc4

  Copy full SHA for d818fc4

Commits on Jul 20, 2017

• [hotfix] Backwards compatible deserialization of RocksDB backend UUIDs

  StefanRRichter

  committed
  2ba5f87

  Copy full SHA for 2ba5f87

Commits on Jul 18, 2017

• [hotfix] [tests] Workaround for WaitForAllVerticesToBeRunning not working in TestingCluster

  StefanRRichter

  committed
  d7f9f9e

  Copy full SHA for d7f9f9e

Commits on Jul 14, 2017

• [FLINK-6964] [checkpoint] Fix externalized incremental checkpoints for StandaloneCompletedCheckpointStore

  StefanRRichter

  committed
  8cff17f

  Copy full SHA for 8cff17f

Commits on Jul 10, 2017

• [FLINK-7063] [checkpoint] Call super.cancel(...) before closing streams in AsyncStoppableTaskWithCallback

  StefanRRichter

  committed
  74adb84

  Copy full SHA for 74adb84

Commits on Jul 4, 2017

• [FLINK-6773] [documentation] Added documentation for compressed checkpoints

  StefanRRichter

  committed
  41806ba

  Copy full SHA for 41806ba

• [FLINK-6773] [checkpoint] Introduce compression (snappy) for keyed state in full checkpoints and savepoints

  StefanRRichter

  committed
  5171513

  Copy full SHA for 5171513

Commits on Jun 15, 2017

• [hotfix] Additional tests for HadoopDataInputStream#skip vs #seek

  StefanRRichter

  committed
  f27cb2a

  Copy full SHA for f27cb2a

• [FLINK-6776] [runtime] Use skip instead of seek for small forward repositioning in DFS streams

  StefanRRichter

  committed
  9141379

  Copy full SHA for 9141379

Commits on Jun 13, 2017

• [FLINK-6685] Adjust scopes of SafetyNetCloseableRegistry usages

  Show description for 68ac96e
  

  StefanRRichter

  authored and

  tillrohrmann

  committed
  68ac96e

  Copy full SHA for 68ac96e

Commits on May 31, 2017

• [FLINK-6766] [docs] Update documentation about async backends and incremental checkpoints

  Show description for 8854513
  

  StefanRRichter

  authored and

  rmetzger

  committed
  8854513

  Copy full SHA for 8854513

Commits on May 24, 2017

• [FLINK-6690] Fix meta-data restore in RocksDBKeyedStateBackend under rescaling

  StefanRRichter

  committed
  36830ad

  Copy full SHA for 36830ad

• [FLINK-6685] Prevent that SafetyNetCloseableRegistry is closed prematurely in Task::triggerCheckpointBarrier

  StefanRRichter

  committed
  7639d49

  Copy full SHA for 7639d49

Commits on May 22, 2017

• [FLINK-6651] Add synchronization to SharedStateRegistry::clear

  StefanRRichter

  committed
  392bc71

  Copy full SHA for 392bc71

Commits on May 20, 2017

• [FLINK-6640] Ensure registration of shared state happens before externalizing a checkpoint

  StefanRRichter

  committed
  0403563

  Copy full SHA for 0403563

Commits on May 19, 2017

• [FLINK-6633] Register shared state before adding to CompletedCheckpointStore

  StefanRRichter

  committed
  0162543

  Copy full SHA for 0162543

Commits on May 14, 2017

• [FLINK-6534] [checkpoint] Use async IO to dispose state in SharedStateRegistry

  StefanRRichter

  committed
  44fb035

  Copy full SHA for 44fb035

• [FLINK-6545] [checkpoint] Make incremental checkpoints externalizable

  StefanRRichter

  committed
  098e46f

  Copy full SHA for 098e46f

• [FLINK-6527] [checkpoint] OperatorSubtaskState has empty implementations of (un)/registerSharedStates

  StefanRRichter

  committed
  efbb41b

  Copy full SHA for efbb41b

• [FLINK-6504] [checkpoint] Fix synchronization on materializedSstFiles in RocksDBKeyedStateBackend

  StefanRRichter

  committed
  958773b

  Copy full SHA for 958773b

• [FLINK-6537] [checkpoint] First set of fixes for (de)registration of shared state in incremental checkpoints

  StefanRRichter

  committed
  4745d0c

  Copy full SHA for 4745d0c

Commits on May 9, 2017

• [FLINK-6506] [build] Tests in flink-tests exceed memory resources on containerized Travis

  StefanRRichter

  committed
  6b451d9

  Copy full SHA for 6b451d9

Pagination

Previous

Next