Commits

Commits on Dec 9, 2016

[FLINK-4646] [gelly] Add BipartiateGraph

mushketyk
authored and
greghogan
committedDec 9, 2016

Commits on Nov 30, 2016

[FLINK-3719][web frontend] Moving the barrier between graph and stats

mushketyk
authored and
greghogan
committedNov 30, 2016
[FLINK-3680] [web frontend] Remove "(not set)" text in the Job Plan UI

mushketyk
authored and
greghogan
committedNov 30, 2016

Commits on Oct 5, 2016

[FLINK-3874] Rewrite Kafka JSON Table sink tests

mushketyk
authored and
twalthr
committedOct 5, 2016

Commits on Aug 29, 2016

[FLINK-3950] Add Meter interface

mushketyk
authored and
zentol
committedAug 29, 2016
[FLINK-3677] Remove Guava dependency from flink-core

mushketyk
authored and
mxm
committedAug 29, 2016

Commits on Aug 25, 2016

[FLINK-3874] [tableApi] Add KafkaJsonTableSink

mushketyk
authored and
fhueske
committedAug 25, 2016
[FLINK-3677] FileInputFormat: Allow to specify include/exclude file name patterns

mushketyk
authored and
mxm
committedAug 25, 2016

Commits on Aug 23, 2016

[FLINK-3866] StringArraySerializer does not treat type as immutable.

mushketyk
authored and
fhueske
committedAug 23, 2016

Commits on Aug 9, 2016

[FLINK-2090] [core] Truncate 'toString()' of CollectionInputFormat when the collection is huge

mushketyk
authored and
StephanEwen
committedAug 9, 2016

Commits on Jul 15, 2016

[FLINK-4053] Add tests for RMQ sink and check connection for null

mushketyk
authored and
zentol
committedJul 15, 2016

Commits on Jul 11, 2016

[FLINK-3943] [table] Add support for EXCEPT operator

mushketyk
authored and
twalthr
committedJul 11, 2016
[FLINK-4096] Ensure JarOutputStream is always closed

mushketyk
authored and
zentol
committedJul 11, 2016