Commits

Commits on Jul 28, 2015

[FLINK-2405] [streaming] Added stateful functions to Scala DataStreams
gyfora
committedJul 28, 2015

Commits on Jul 24, 2015

Commits on Jul 23, 2015

Commits on Jul 22, 2015

[FLINK-1818] add cancel method to Client

rainiraj
authored and
mxm
committedJul 22, 2015
[FLINK-2388] forward message to archivist in case accumulators can't be found
mxm
committedJul 22, 2015
[FLINK-2218] Web client cannot distinguesh between Flink options and program arguments

mjsax
authored and
mxm
committedJul 22, 2015
[FLINK-1658] Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent

mjsax
authored and
aljoscha
committedJul 22, 2015
[FLINK-2304] Add named attribute access to Storm compatibility layer

mjsax
authored and
gyfora
committedJul 22, 2015

Commits on Jul 21, 2015

[FLINK-2018] [core] Add ParameterUtil.fromGenericOptionsParser()

Ajay Bhat
authored and
StephanEwen
committedJul 21, 2015
[FLINK-2198] [tests] Under Windows, skip tests that use setWritable

ggevay
authored and
StephanEwen
committedJul 21, 2015
[docs] Clean up completeness checker for configuration docs.
StephanEwen
committedJul 21, 2015
[docs] Document some missing configuration parameters

rmetzger
authored and
StephanEwen
committedJul 21, 2015
[FLINK-1943] [gelly] Added GSA compiler and translation tests

vasia
authored and
StephanEwen
committedJul 21, 2015
[FLINK-2376] Raise the time limit in testFindConnectableAddress under Windows

ggevay
authored and
StephanEwen
committedJul 21, 2015
[FLINK-2362] [docs] Add Scala and Java documentation for the 'distinct()' transformation

Pietro Pinoli
authored and
StephanEwen
committedJul 21, 2015
[FLINK-2377] [tests] Make buffer closing logic robust to I/O failures.
StephanEwen
committedJul 21, 2015
[FLINK-2377] [tests] Add reader.close() to readAllResultLines in TestBaseUtils

ggevay
authored and
StephanEwen
committedJul 21, 2015
[FLINK-2358] [dashboard] Adding comments to web dashboard files, add LICENSE file entries
StephanEwen
committedJul 21, 2015
[FLINK-2358] [dashboard] Add first stub of angular.js based dashboard.
StephanEwen
committedJul 21, 2015
[FLINK-2358] [dashboard] Add server for static dashboard files (HTML, JS, CSS, ...)
StephanEwen
committedJul 21, 2015
[FLINK-2358] [dashboard] First part dashboard server backend
StephanEwen
committedJul 21, 2015
[core] Remove obsolete OperatorUtil
StephanEwen
committedJul 21, 2015
[FLINK-2382] fix Flink live accumulators for TwoInputStreamTask
mxm
committedJul 21, 2015
[FLINK-2371] improve AccumulatorLiveITCase
mxm
committedJul 21, 2015
[tests] add flag for synchronous execution of futures in TestingCluster
mxm
committedJul 21, 2015

Commits on Jul 20, 2015

[FLINK-1967] Introduce (Event)time in Streaming
aljoscha
committedJul 20, 2015

Commits on Jul 17, 2015

[FLINK-2359] [java api] Add factory methods to the Java TupleX types

ggevay
authored and
fhueske
committedJul 17, 2015

Commits on Jul 16, 2015

[FLINK-1963] Improve distinct() transformation

pietro pinoli
authored and
fhueske
committedJul 16, 2015