Commits

History for

Commits on Apr 26, 2018

[FLINK-8841] Remove HashMapSerializer and use MapSerializer instead.
kl0u
committedApr 26, 2018

Commits on Apr 2, 2018

[FLINK-9121] [flip6] Remove Flip6 prefixes and other references
tillrohrmann
committedApr 2, 2018

Commits on Mar 29, 2018

[FLINK-8802] [QS] Fix concurrent access to non-duplicated serializers.
kl0u
committedMar 29, 2018
[FLINK-8926] [QS] Shutdown client proxy after test ends.
kl0u
committedMar 29, 2018
[FLINK-8928] [QS] Improve server binding error message.
kl0u
committedMar 29, 2018

Commits on Mar 11, 2018

[FLINK-8778] Port queryable state ITCases to use MiniClusterResource
aljoscha
committedMar 11, 2018

Commits on Mar 1, 2018

[FLINK-4387][QS] don't wait and process requests at Netty servers after shutdown request

Nico Kruber
authored and
kl0u
committedMar 1, 2018

Commits on Feb 27, 2018

Update version to 1.6-SNAPSHOT
tillrohrmann
committedFeb 27, 2018

Commits on Feb 25, 2018

[FLINK-8360][checkpointing] Implement state storage for local recovery and integrate with task lifecycle
StefanRRichter
committedFeb 25, 2018

Commits on Feb 20, 2018

[FLINK-8698] [flip6] Let LocalExecutor use Flip-6 MiniCluster
tillrohrmann
committedFeb 20, 2018

Commits on Feb 14, 2018

[FLINK-8652] [QS] Reduce log level in getKvState to DEBUG.
fhueske
committedFeb 14, 2018

Commits on Feb 6, 2018

[FLINK-8493] [flip6] Integrate queryable state with Flip-6
tillrohrmann
committedFeb 6, 2018

Commits on Jan 24, 2018

[FLINK-8466] [runtime] Make sure ErrorInfo references no user-defined classes.
StephanEwen
committedJan 24, 2018

Commits on Jan 19, 2018

[FLINK-7938] Introduce addAll() to ListState

bowenli86
authored and
StefanRRichter
committedJan 19, 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-7903] [tests] Add flip6 build profile
tillrohrmann
committedJan 9, 2018

Commits on Dec 14, 2017

[hotfix] [tests] Speed up queryable state IT tests by removing sleep
tillrohrmann
committedDec 14, 2017

Commits on Dec 6, 2017

[FLINK-7880][QS] Wait for proper resource cleanup after each ITCase.
kl0u
committedDec 6, 2017
[FLINK-7974][QS] Wait for QS abstract server to shutdown.
kl0u
committedDec 6, 2017
[FLINK-7975][QS] Wait for QS client to shutdown.
kl0u
committedDec 6, 2017

Commits on Nov 17, 2017

[FLINK-8061][QS] Remove trailing * in QSClient javadocs.

Vetriselvan1187
authored and
kl0u
committedNov 17, 2017
[FLINK-8059][QS] QS client throws FlinkJobNotFoundException for queries with unknown jobIds
kl0u
committedNov 17, 2017
[FLINK-8055][QS] Deduplicate logging messages about QS start.
kl0u
committedNov 17, 2017
[FLINK-8065][QS] Improve error message when client already shut down.
kl0u
committedNov 17, 2017
[FLINK-8062][QS] Make getKvState() with namespace private.
kl0u
committedNov 17, 2017
[FLINK-8063][QS] QS client does not retry when an UnknownKvStateLocation is thrown.
kl0u
committedNov 17, 2017

Commits on Nov 7, 2017

[FLINK-7823][QS] Update Queryable State configuration parameters.
kl0u
committedNov 7, 2017

Commits on Nov 6, 2017

Update version to 1.5-SNAPSHOT
aljoscha
committedNov 6, 2017
[FLINK-7701][network] really fix watermark configuration order this time

Nico Kruber
authored and
tillrohrmann
committedNov 6, 2017

Commits on Nov 2, 2017

[FLINK-7968] [core] Move DataOutputSerializer and DataInputDeserializer to 'flink-core'
StephanEwen
committedNov 2, 2017

Commits on Oct 31, 2017

[hotfix][QS] Disable RocksDB ITCases.
kl0u
committedOct 31, 2017

Commits on Oct 30, 2017

[hotfix] Remove redundant FutureUtils#getFailedFuture
tillrohrmann
committedOct 30, 2017
[FLINK-7739][tests] Properly close flink mini cluster

pnowojski
authored and
tillrohrmann
committedOct 30, 2017

Commits on Oct 29, 2017

[FLINK-7880][QS] Fix QS test instabilities.
kl0u
committedOct 29, 2017

Commits on Oct 26, 2017

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