Commits

History for

Commits on Oct 9, 2018

[FLINK-10514][docs] change tachyon to alluxio in doc

Guibo-Pan
authored and
tillrohrmann
committedOct 9, 2018

Commits on Sep 20, 2018

[FLINK-10050][DataStream API] Support allowedLateness in CoGroupedStreams.

Eugen Yushin
authored and
kl0u
committedSep 20, 2018

Commits on Aug 17, 2018

[FLINK-9850][streaming] Add a string to the print method to identify output for DataStream (apache#6367 )

yanghua
authored and
pnowojski
committedAug 17, 2018

Commits on Jul 16, 2018

Update version to 1.7-SNAPSHOT
tillrohrmann
committedJul 16, 2018

Commits on Jul 12, 2018

[FLINK-8480][DataStream] Add APIs for Interval Joins.

florianschmidt1994
authored and
kl0u
committedJul 12, 2018

Commits on Jun 15, 2018

[FLINK-9366] DistributedCache works with Distributed File System
dawidwys
committedJun 15, 2018

Commits on Jun 2, 2018

[FLINK-7789] Add handler for Async IO operator timeouts

blueszheng
authored and
kl0u
committedJun 2, 2018

Commits on May 28, 2018

[hotfix] Removed unused scala imports.

bowenli86
authored and
StefanRRichter
committedMay 28, 2018

Commits on May 24, 2018

[FLINK-9415] [scala, test] Remove ScalaStreamingMultipleProgramsTestBase

tweise
authored and
tzulitai
committedMay 24, 2018

Commits on May 10, 2018

[FLINK-9179][REST] Deduplicate WebOptions.PORT and RestOptions.PORT

zhangminglei
authored and
zentol
committedMay 10, 2018

Commits on May 2, 2018

[FLINK-9136][tests] Remove StreamingProgramTestBase
zentol
committedMay 2, 2018

Commits on Apr 12, 2018

[FLINK-9152] Harmonize BroadcastProcessFunction Context names
aljoscha
committedApr 12, 2018

Commits on Apr 6, 2018

[FLINK-8837][annotations] Add @experimental annotation and annotate some classes

bowenli86
authored and
zentol
committedApr 6, 2018

Commits on Mar 21, 2018

[FLINK-8649] [scala api] Pass on TypeInfo in StreamExecutionEnvironment.createInput

ggevay
authored and
zentol
committedMar 21, 2018

Commits on Mar 6, 2018

[FLINK-8667] Expose key in KeyedBroadcastProcessFunction#onTimer()

bowenli86
authored and
kl0u
committedMar 6, 2018
[FLINK-8560] Add KeyedProcessFunction exposing key in onTimer().

bowenli86
authored and
kl0u
committedMar 6, 2018

Commits on Feb 27, 2018

Update version to 1.6-SNAPSHOT
tillrohrmann
committedFeb 27, 2018

Commits on Feb 26, 2018

[FLINK-8703][tests] Migrate tests to MiniClusterResource (batch #2 )
zentol
committedFeb 26, 2018

Commits on Feb 13, 2018

[FLINK-8642] Initialize descriptors before use at getBroadcastState().
kl0u
committedFeb 13, 2018

Commits on Feb 9, 2018

Commits on Jan 31, 2018

[Flink-8407] [DataStream] Setting the parallelism after a partitioning operation should be forbidden

xccui
authored and
aljoscha
committedJan 31, 2018

Commits on Jan 18, 2018

[FLINK-5823] [checkpoints] Pass state backend to checkpoint coordinator
StephanEwen
committedJan 18, 2018

Commits on Jan 16, 2018

[FLINK-8175] remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

bowenli86
authored and
tillrohrmann
committedJan 16, 2018

Commits on Jan 10, 2018

[FLINK-8389] [flip6] Release all slots upon closing of JobManager
tillrohrmann
committedJan 10, 2018

Commits on Jan 9, 2018

[FLINK-7909] Replace StreamingMultipleProgramsTestBase by AbstractTestBase
tillrohrmann
committedJan 9, 2018
[FLINK-7903] [tests] Add flip6 build profile
tillrohrmann
committedJan 9, 2018

Commits on Jan 6, 2018

[FLINK-8116] [DataStream] Fix stale comments referring to Checkpointed interface

0xparashar
authored and
tzulitai
committedJan 6, 2018

Commits on Jan 5, 2018

[hotfix] Fix many many typos

greghogan
authored and
StephanEwen
committedJan 5, 2018

Commits on Nov 9, 2017

[FLINK-7765][build] Enable dependency convergence by default

pnowojski
authored and
aljoscha
committedNov 9, 2017

Commits on Nov 6, 2017

Update version to 1.5-SNAPSHOT
aljoscha
committedNov 6, 2017

Commits on Nov 3, 2017

[FLINK-7972] [core] Move SerializationSchema to 'flink-core'
StephanEwen
committedNov 3, 2017

Commits on Oct 24, 2017

[hotfix] [tests] Remove AbstractTestBase from CsvOutputFormatITCase and TextOutputFormatITCase
tillrohrmann
committedOct 24, 2017

Commits on Oct 21, 2017

[FLINK-7837] Extend AggregateFunction.add() to work with immutable types
aljoscha
committedOct 21, 2017