Commits

Branch selector

 master

User selector

StefanRRichter

Datepicker

All time

Commit History

Commits on Dec 7, 2018

• [hotfix][documentation] Mention limitation of local recovery with RocksDB in multi device setups.

  StefanRRichter

  committed
  eaead20

  Copy full SHA for eaead20

Commits on Nov 13, 2018

• [FLINK-10863][tests] Assign UIDs to all operators in DataStreamAllroundTestProgram

  Show description for 31176d5
  StefanRRichter

  committed
  31176d5

  Copy full SHA for 31176d5

• [hotfix] CheckpointDeclineException should lead to pendingCheckpoint.abortDecline()

  Show description for 39f7963
  StefanRRichter

  committed
  39f7963

  Copy full SHA for 39f7963

Commits on Nov 12, 2018

• [FLINK-10753] Improve propagation and logging of snapshot exceptions

  Show description for dc8e27f
  StefanRRichter

  committed
  dc8e27f

  Copy full SHA for dc8e27f

• [FLINK-10809][state] Include keyed state that is not from head operators in state assignment

  Show description for bf760f9
  StefanRRichter

  committed
  bf760f9

  Copy full SHA for bf760f9

• [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

  Show description for 2db59cf
  StefanRRichter

  committed
  2db59cf

  Copy full SHA for 2db59cf

• [FLINK-10839][serializer] Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer

  StefanRRichter

  committed
  c4d366c

  Copy full SHA for c4d366c

• [FLINK-10826] [e2e] Decrease deployment size of heavy deplyment e2e test for Travis

  Show description for f393fb7
  

  StefanRRichter

  authored and

  twalthr

  committed
  f393fb7

  Copy full SHA for f393fb7

Commits on Nov 8, 2018

• [FLINK-10765][test] Include s3p schema in S3 test

  Show description for c5e227b
  StefanRRichter

  committed
  c5e227b

  Copy full SHA for c5e227b

• [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider deep duplication of element serializer

  Show description for 997fa55
  StefanRRichter

  committed
  997fa55

  Copy full SHA for 997fa55

Commits on Nov 7, 2018

• [hotfix][tests] Deduplicate the default timeout constants in FlinkKafkaProducerITCase

  StefanRRichter

  committed
  bf0454b

  Copy full SHA for bf0454b

• [FLINK-10353][kafka] Support change of transactional semantics in Kafka Producer with existing state

  Show description for 85f895b
  StefanRRichter

  committed
  85f895b

  Copy full SHA for 85f895b

Commits on Nov 6, 2018

• [FLINK-10720][tests] Add deployment end-to-end stress test with many inflated task deployment desciptors

  Show description for 660bb68
  StefanRRichter

  committed
  660bb68

  Copy full SHA for 660bb68

Commits on Nov 5, 2018

• [FLINK-10793][ttl] Change visibility of TtlValue and TtlSerializer to public for external tools

  Show description for e1d975d
  StefanRRichter

  committed
  e1d975d

  Copy full SHA for e1d975d

• [FLINK-10364][tests] Fix instability in NonHAQueryableStateFsBackendITCase#testMapState

  Show description for b9351fc
  StefanRRichter

  committed
  b9351fc

  Copy full SHA for b9351fc

• [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Serializer

  Show description for d5296dc
  StefanRRichter

  committed
  d5296dc

  Copy full SHA for d5296dc

Commits on Oct 30, 2018

• [FLINK-9635][scheduling] Avoid task spread-out in scheduling with local recovery

  Show description for c8a6471
  StefanRRichter

  committed
  c8a6471

  Copy full SHA for c8a6471

• [FLINK-8995][tests] Add keyed state that uses custom stateful serializer to allround test job

  Show description for 0e9a249
  StefanRRichter

  committed
  0e9a249

  Copy full SHA for 0e9a249

Commits on Oct 1, 2018

• [hotfix][docs] Improve documentation of savepoints

  Show description for 6ba2a0b
  StefanRRichter

  committed
  6ba2a0b

  Copy full SHA for 6ba2a0b

Commits on Aug 22, 2018

• [FLINK-10176][state] Replace ByteArrayData[Input|Output]View with (enhanced) Data[Output|InputDe]Serializer

  Show description for 3fd6587
  StefanRRichter

  committed
  3fd6587

  Copy full SHA for 3fd6587

• [FLINK-10175][state] Fix concurrent access to shared buffer between RocksDBMapState and querable state

  StefanRRichter

  committed
  2b6beed

  Copy full SHA for 2b6beed

Commits on Aug 21, 2018

• [FLINK-10042][state] (part 2) Refactoring of snapshot algorithms for better abstraction and cleaner resource management

  Show description for f803280
  StefanRRichter

  committed
  f803280

  Copy full SHA for f803280

• [FLINK-10042][state] (part 1) Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes

  StefanRRichter

  committed
  aba02eb

  Copy full SHA for aba02eb

Commits on Aug 20, 2018

• [hotfix] Minor JavaDoc correction in StateTable

  StefanRRichter

  committed
  24e0fbe

  Copy full SHA for 24e0fbe

• [FLINK-10068][docs] Add documentation for RocksDB-based timers and stopping timers

  Show description for b456cca
  StefanRRichter

  committed
  b456cca

  Copy full SHA for b456cca

Commits on Aug 16, 2018

• [hotfix][state] Improve memory-friendliness of state assignment by allocating collections with correct sizes or improved size estimates where possible

  StefanRRichter

  committed
  15e137e

  Copy full SHA for 15e137e

Commits on Aug 13, 2018

• [FLINK-10066] Keep only archived version of previous executions

  Show description for 160dc56
  StefanRRichter

  committed
  160dc56

  Copy full SHA for 160dc56

Commits on Aug 10, 2018

• [FLINK-10124][state] Use ByteArrayDataInput/OutputView instead of stream + wrapper

  StefanRRichter

  committed
  18ff4ab

  Copy full SHA for 18ff4ab

• [FLINK-10041][state] Extract iterators from RocksDBKeyedStateBackend (inner or static inner classes) into full classes

  Show description for 9d67afb
  StefanRRichter

  committed
  9d67afb

  Copy full SHA for 9d67afb

Commits on Aug 2, 2018

• [hotfix] Minor cleanups in LongSerializer

  StefanRRichter

  committed
  6aaf5ed

  Copy full SHA for 6aaf5ed

• [FLINK-9887][state] Integrate priority queue state with existing serializer upgrade mechanism

  Show description for 9d273a3
  StefanRRichter

  committed
  9d273a3

  Copy full SHA for 9d273a3

• [FLINK-10028][core] Introduce reusable ByteArrayData[Input/Output]View as adapter between Data[Input/Output]View and byte-arrays

  StefanRRichter

  committed
  fffd2e8

  Copy full SHA for fffd2e8

• [FLINK-9981][state] Testing and performance tuning for RocksDB-based priority queue

  Show description for a20fd1d
  StefanRRichter

  committed
  a20fd1d

  Copy full SHA for a20fd1d

Commits on Jul 20, 2018

• [hotfix] Fix loop in FailingSource

  StefanRRichter

  committed
  f60aa6e

  Copy full SHA for f60aa6e

• [FLINK-9902][tests] Improve and refactor window checkpointing IT cases

  Show description for d309e61
  StefanRRichter

  committed
  d309e61

  Copy full SHA for d309e61

Pagination

Previous

Next