Commits

History for

Commits on Feb 1, 2018

[FLINK-8531] [checkpoints] (part 1) Pull CheckpointType into its own class.
StephanEwen
committedFeb 1, 2018

Commits on Jan 26, 2018

[hotfix] improve javadoc and logging of RocksDBKeyedStateBackend

bowenli86
authored and
tillrohrmann
committedJan 26, 2018

Commits on Jan 23, 2018

[FLINK-8469] Unify RocksDB params in RocksDBPerformanceTest

bowenli86
authored and
StefanRRichter
committedJan 23, 2018
[FLINK-8411] [State Backend] HeapListState#add(null) will wipe out entire list state

bowenli86
authored and
StefanRRichter
committedJan 23, 2018
[FLINK-8441] [State Backend] [RocksDB] change RocksDBListState to serialize values and separators in stream to avoid extra bytes copying

bowenli86
authored and
StefanRRichter
committedJan 23, 2018

Commits on Jan 22, 2018

[FLINK-7720] [checkpoints] Centralize creation of backends and state related resources
StefanRRichter
committedJan 22, 2018

Commits on Jan 19, 2018

[FLINK-7938] Introduce addAll() to ListState

bowenli86
authored and
StefanRRichter
committedJan 19, 2018

Commits on Jan 18, 2018

Commits on Jan 16, 2018

[FLINK-8175] remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

bowenli86
authored and
tillrohrmann
committedJan 16, 2018

Commits on Jan 12, 2018

[FLINK-8347] [flip6] Make cluster id used by ClusterDescriptor typesafe
tillrohrmann
committedJan 12, 2018

Commits on Jan 10, 2018

[FLINK-7475] [state] Introduce ListState#update()

bowenli86
authored and
StefanRRichter
committedJan 10, 2018

Commits on Jan 9, 2018

[FLINK-5982] [runtime] Refactor AbstractInvokable and StatefulTask to accept Environment and State in the constructor.

tony810430
authored and
StephanEwen
committedJan 9, 2018
[FLINK-7909] Replace StreamingMultipleProgramsTestBase by AbstractTestBase
tillrohrmann
committedJan 9, 2018
[FLINK-7903] [tests] Add flip6 build profile
tillrohrmann
committedJan 9, 2018

Commits on Jan 8, 2018

[FLINK-8200][tests] Use TemporaryFolder in RocksDBAsyncSnapshotTest

wenlong.lwl
authored and
zentol
committedJan 8, 2018

Commits on Jan 5, 2018

[hotfix] Fix many many typos

greghogan
authored and
StephanEwen
committedJan 5, 2018

Commits on Dec 12, 2017

[FLINK-8213][metrics] Improve fallback behaviors
zentol
committedDec 12, 2017

Commits on Dec 4, 2017

[FLINK-7762] [connector-wikiedits] Make WikipediaEditsSourceTest proper test

uce
authored and
zentol
committedDec 4, 2017
[FLINK-8167] [connector-wikiedits] Harden WikipediaEditsSource

uce
authored and
zentol
committedDec 4, 2017

Commits on Nov 27, 2017

[FLINK-8105] Remove "unnecessary 'null' check before 'instanceof' expression"

yew1eb
authored and
greghogan
committedNov 27, 2017

Commits on Nov 23, 2017

[FLIN-6505] Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

bowenli86
authored and
StefanRRichter
committedNov 23, 2017

Commits on Nov 22, 2017

[FLINK-8126] [build] Fix and update checkstyle

greghogan
authored and
zentol
committedNov 22, 2017

Commits on Nov 6, 2017

Update version to 1.5-SNAPSHOT
aljoscha
committedNov 6, 2017

Commits on Oct 27, 2017

[FLINK-7924] [checkpoints] Fix incorrect names of checkpoint options
StephanEwen
committedOct 27, 2017

Commits on Oct 26, 2017

[FLINK-7908][QS] Restructure the queryable state module.
kl0u
committedOct 26, 2017

Commits on Oct 25, 2017

[FLINK-7669] Always load Flink classes via parent ClassLoader
aljoscha
committedOct 25, 2017

Commits on Oct 21, 2017

[FLINK-7837] Extend AggregateFunction.add() to work with immutable types
aljoscha
committedOct 21, 2017

Commits on Oct 20, 2017

[FLINK-5372] [tests] Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()
StefanRRichter
committedOct 20, 2017

Commits on Oct 18, 2017

[FLINK-7757] [checkpointing] Introduce resource guard for RocksDBKeyedStateBackend to reduce locking and avoid blocking behavior.
StefanRRichter
committedOct 18, 2017

Commits on Oct 11, 2017

[FLINK-7769][QS] Move queryable state outside the runtime.
kl0u
committedOct 11, 2017

Commits on Sep 28, 2017

[FLINK-5619] Consolidate AggregatingState Tests in StateBackendTestBase
aljoscha
committedSep 28, 2017
[FLINK-7700] Fix RocksDB ReducingState merging
aljoscha
committedSep 28, 2017