Commits

Commits on Jan 31, 2017

[FLINK-5684] [web frontend] Add MacOS section to README.md

mushketyk
authored and
StephanEwen
committedJan 31, 2017

Commits on Jan 27, 2017

[FLINK-5612] [code] Make GlobPathFilter serializable

mushketyk
authored and
StephanEwen
committedJan 27, 2017

Commits on Jan 10, 2017

[FLINK-5280] [table] Refactor TableSource interface.

mushketyk
authored and
fhueske
committedJan 10, 2017

Commits on Jan 9, 2017

[FLINK-5360] Fix argument names in WindowedStream

mushketyk
authored and
aljoscha
committedJan 9, 2017

Commits on Jan 5, 2017

[FLINK-5349] [docs] Fix typos in Twitter connector example

mushketyk
authored and
zentol
committedJan 5, 2017

Commits on Dec 16, 2016

[FLINK-5311] [gelly] [docs] Add user documentation for bipartite graph

mushketyk
authored and
vasia
committedDec 16, 2016

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