Commits

Commits on Nov 29, 2017

[FLINK-8165] ParameterTool serialization fix

gyfora
authored and
aljoscha
committedNov 29, 2017

Commits on Aug 24, 2016

[FLINK-4441] Make RocksDB backend return null on empty state + add test for all backends
gyfora
committedAug 24, 2016

Commits on Apr 21, 2016

[hotfix] [FLINK-3798] Make RocksDB state classes also public
gyfora
committedApr 21, 2016
[FLINK-3790] [streaming] Use proper hadoop config in rolling sink
gyfora
committedApr 21, 2016
[FLINK-3798] [streaming] Clean up RocksDB backend field/method access
gyfora
committedApr 21, 2016

Commits on Mar 16, 2016

[FLINK-3620] [streaming] Remove DbStateBackend
gyfora
committedMar 16, 2016

Commits on Feb 15, 2016

[FLINK-3354] Determine correct size for RocksDB snapshots
gyfora
committedFeb 15, 2016

Commits on Nov 29, 2015

[FLINK-3075] Change Either creation method names and expose Right/Left classes
gyfora
committedNov 29, 2015

Commits on Nov 25, 2015

[FLINK-3072] [streaming] Ensure Derby server starts before running any tests
gyfora
committedNov 25, 2015

Commits on Oct 6, 2015

[FLINK-2822] [streaming] Remove scala.Serializable imports

gyfora
authored and
mbalassi
committedOct 6, 2015

Commits on Oct 4, 2015

[FLINK-2802] [streaming] Remove cyclic watermark dependencies for iterations
gyfora
committedOct 4, 2015

Commits on Sep 21, 2015

[FLINK-2713] [streaming] Set state restore to lazy to avoid StateCheckpointer issues and reduce checkpoint overhead
gyfora
committedSep 21, 2015

Commits on Sep 18, 2015

[FLINK-2707] [streaming] Set StateCheckpointer before default state value
gyfora
committedSep 18, 2015

Commits on Sep 14, 2015

[FLINK-2664] [streaming] Allow partitioned state removal
gyfora
committedSep 14, 2015

Commits on Aug 2, 2015

[FLINK-2436] [streaming] Make ByteStreamStateHandles more robust
gyfora
committedAug 2, 2015

Commits on Jul 30, 2015

[FLINK-2324] [streaming] Added test for different StateHandle wrappers
gyfora
committedJul 30, 2015
[FLINK-2324] [streaming] ITCase added for partitioned states
gyfora
committedJul 30, 2015
[FLINK-2324] [streaming] Partitioned state checkpointing rework + test update
gyfora
committedJul 30, 2015

Commits on Jul 29, 2015

[FLINK-2419] Add test for sinks after keyBy and groupBy
gyfora
committedJul 29, 2015

Commits on Jul 28, 2015

Commits on Jul 24, 2015

[streaming] Copy default state values for partitioned states
gyfora
committedJul 24, 2015

Commits on Jul 11, 2015

[FLINK-2335] [streaming] Lazy iteration construction in StreamGraph
gyfora
committedJul 11, 2015

Commits on Jul 7, 2015

[FLINK-2323] [api-breaking] Rename OperatorState interface methods to value() and update(..)
gyfora
committedJul 7, 2015

Commits on Jun 30, 2015

[FLINK-2294] [streaming] Fix partitioned state next-input setting for copying chained collectors
gyfora
committedJun 30, 2015

Commits on Jun 27, 2015

[streaming] Created scala GroupedDataStream
gyfora
committedJun 27, 2015

Commits on Jun 26, 2015

[FLINK-2261] [streaming] Remove reduce/fold/aggregations from DataStream
gyfora
committedJun 26, 2015
[FLINK-2279] [streaming] Add Connected Iteration
gyfora
committedJun 26, 2015