Commits

Commits on Apr 12, 2015

[streaming] Cancellation update in connectors
mbalassi
committedApr 12, 2015

Commits on Apr 10, 2015

[streaming] ITCase for WindowWordCount

mbalassi
authored and
gyfora
committedApr 10, 2015

Commits on Apr 8, 2015

[quickstart] Error msg in streaming quickstarts when run with wrong number of arguments
mbalassi
committedApr 8, 2015
[FLINK-1841] [streaming] More permissive WindowJoinITCase
mbalassi
committedApr 8, 2015
[FLINK-1839] Reworked TwitterStreamITCase for testability
mbalassi
committedApr 8, 2015

Commits on Apr 7, 2015

[FLINK-1837] [streaming] Throw Exception for checkpointed iterative programs
mbalassi
committedApr 7, 2015
[FLINK-1560] [streaming] Streaming example ITCases cleanup
mbalassi
committedApr 7, 2015

Commits on Apr 6, 2015

[streaming] WindowWordCount example added
mbalassi
committedApr 6, 2015

Commits on Mar 29, 2015

[FLINK-1669] [streaming] Test for streaming recovery from process failure

mbalassi
authored and
StephanEwen
committedMar 29, 2015

Commits on Mar 22, 2015

Commits on Mar 20, 2015

[streaming] StreamExecutionEnvironment methods for streaming fault tolerance
mbalassi
committedMar 20, 2015

Commits on Mar 19, 2015

[docs] [streaming] Quick fix for batch lexers in streaming guide
mbalassi
committedMar 19, 2015

Commits on Mar 10, 2015

[FLINK-1638] [streaming] Kafka low level API example, documentation and fixes

mbalassi
authored and
StephanEwen
committedMar 10, 2015
[FLINK-1638] [streaming] Added persistent Kafka source

mbalassi
authored and
StephanEwen
committedMar 10, 2015
[FLINK-1638] [streaming] Added connector for low level Kafka Consumer API

mbalassi
authored and
StephanEwen
committedMar 10, 2015

Commits on Mar 8, 2015

[FLINK-1429] [streaming] Scala programming guide update: intro & operators, minor fixes

mbalassi
authored and
Gábor Hermann
committedMar 8, 2015

Commits on Mar 4, 2015

[FLINK-1625] [streaming] Streaming cancellation minor fix and documentation
mbalassi
committedMar 4, 2015

Commits on Feb 26, 2015

[streaming] Streaming examples dependency fix
mbalassi
committedFeb 26, 2015

Commits on Feb 25, 2015

[FLINK-1582][streaming] SocketStream minor enhancements
mbalassi
committedFeb 25, 2015

Commits on Feb 19, 2015

[FLINK-1560][streaming] streaming WordCount ITCases
mbalassi
committedFeb 19, 2015
[FLINK-1560] [streaming] StreamExecutionEnvironment enhancement for ITCases
mbalassi
committedFeb 19, 2015

Commits on Feb 16, 2015

[docs] [streaming] Documentation updates for stream windowing
mbalassi
committedFeb 16, 2015
[FLINK-1231] [streaming] More sophisticated streaming classloader ITCase
mbalassi
committedFeb 16, 2015

Commits on Feb 13, 2015

[streaming] Added ITCase for streaming classloading
mbalassi
committedFeb 13, 2015

Commits on Feb 10, 2015

[streaming] Windowing examples cleanup
mbalassi
committedFeb 10, 2015

Commits on Feb 9, 2015

[streaming] Java Stock streaming example added
mbalassi
committedFeb 9, 2015

Commits on Feb 6, 2015

[docs] Updated legacy references containing 'incubator' substring
mbalassi
committedFeb 6, 2015

Commits on Jan 18, 2015

Commit for year 2015

mbalassi
authored and
StephanEwen
committedJan 18, 2015
[build tools] Release script update

mbalassi
authored and
StephanEwen
committedJan 18, 2015
Fix for quickstart versions

mbalassi
authored and
StephanEwen
committedJan 18, 2015
[dist] Updated mailing list info in binary distribution

mbalassi
authored and
StephanEwen
committedJan 18, 2015

Commits on Jan 11, 2015

[FLINK-1358] [streaming] Streaming added to the quickstarts

mbalassi
authored and
StephanEwen
committedJan 11, 2015
[FLINK-1225] Fix for quickstart packaging

mbalassi
authored and
StephanEwen
committedJan 11, 2015

Commits on Jan 8, 2015

[streaming] [scala] scala SocketTextStream added and minor fixes
mbalassi
committedJan 8, 2015