Commits

History for

Commits on Nov 18, 2015

[FLINK-2692] Untangle CsvInputFormat
zentol
committedNov 18, 2015

Commits on Nov 3, 2015

[docker] move the #!bash to first line

frett27
authored and
mxm
committedNov 3, 2015

Commits on Nov 1, 2015

[streaming] delegate JobGraph generation to Client class
mxm
committedNov 1, 2015

Commits on Oct 29, 2015

[FLINK-2559] Clean up JavaDocs

hczerpak
authored and
fhueske
committedOct 29, 2015

Commits on Oct 24, 2015

[FLINK-2862] [Storm Compatibility] FlinkTopologyBuilder should use proper generic types

mjsax
authored and
mjsax
committedOct 24, 2015

Commits on Oct 23, 2015

[release] update version to 1.0-SNAPSHOT
mxm
committedOct 23, 2015

Commits on Oct 21, 2015

[contrib, tests] Disable sys out logging in operator stats tests
uce
committedOct 21, 2015
[FLINK-2877] Move Streaming API out of Staging package

Rufus Refactor
authored and
aljoscha
committedOct 21, 2015

Commits on Oct 16, 2015

Commits on Oct 9, 2015

[FLINK-2831] [Storm Compatibility] Failing Test: WrapperSetupHelperTest
mjsax
committedOct 9, 2015

Commits on Oct 8, 2015

[FLINK-1789][core][runtime] Allow adding of URLs to the usercode class loader

twalthr
authored and
mxm
committedOct 8, 2015

Commits on Oct 7, 2015

[FLINK-2381] [Storm Compatibility] Failing Test: WrapperSetupHelperTest
mjsax
committedOct 7, 2015

Commits on Oct 6, 2015

[FLINK-2825] FlinkClient.killTopology fails due to missing leader session ID
mjsax
committedOct 6, 2015
[Storm Compatibility] Maven module restucturing and cleanup

mjsax
authored and
mjsax
committedOct 6, 2015
[FLINK-2566] FlinkTopologyContext not populated completely
mjsax
committedOct 6, 2015

Commits on Oct 5, 2015

[FLINK-2550] Rename SplitDataStream to SplitStream
aljoscha
committedOct 5, 2015
[FLINK-2550] Remove groupBy and GroupedDataStream
aljoscha
committedOct 5, 2015

Commits on Oct 2, 2015

[FLINK-2525] Add configuration support in Storm-compatibility

ffbin
authored and
mjsax
committedOct 2, 2015

Commits on Oct 1, 2015

[streaming] [storm] Clean up instantiation of mini clusters and test environments.
StephanEwen
committedOct 1, 2015
[FLINK-2781] [core] Cleanup NetUtils.
StephanEwen
committedOct 1, 2015

Commits on Sep 29, 2015

[FLINK-2775] [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes
hsaputra
committedSep 29, 2015

Commits on Sep 28, 2015

[FLINK-2690] [api-breaking] [scala api] [java api] Adds functionality to the CsvInputFormat to find fields defined in a super class of a Pojo. Refactors CsvInputFormat to share code between this fo…
tillrohrmann
committedSep 28, 2015

Commits on Sep 24, 2015

[FLINK-2200] [build system] Add scala version suffix to artifact id for Scala 2.11

chiwanpark
authored and
rmetzger
committedSep 24, 2015

Commits on Sep 22, 2015

[FLINK-2097][core] implement a job session management
mxm
committedSep 22, 2015

Commits on Sep 14, 2015

[FLINK-2658] fieldsGrouping for multiple output streams fails

mjsax
authored and
mjsax
committedSep 14, 2015

Commits on Sep 11, 2015

[FLINK-2647] [streaming core] Distinguish between "close" (flushing buffered data) and "dispose" (cleanup resources) in streaming operators.
StephanEwen
committedSep 11, 2015

Commits on Sep 9, 2015

[FLINK-1297] add accumulator called OperatorStatsAccumulator

tammymendt
authored and
mxm
committedSep 9, 2015

Commits on Sep 1, 2015

[FLINK-2584] Check for unshaded classes in fat jar and shade curator

rmetzger
authored and
StephanEwen
committedSep 1, 2015

Commits on Aug 31, 2015

[FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers.
tillrohrmann
committedAug 31, 2015

Commits on Aug 27, 2015

[FLINK-2553] Example Jars not build correctly

mjsax
authored and
StephanEwen
committedAug 27, 2015
[FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval.

rmetzger
authored and
StephanEwen
committedAug 27, 2015
[FLINK-2386] [kafka connector] Add new Kafka Consumer for Flink

rmetzger
authored and
StephanEwen
committedAug 27, 2015

Commits on Aug 21, 2015

[FLINK-2306] Add support for named streams in Storm compatibility layer

mjsax
authored and
StephanEwen
committedAug 21, 2015