Commits

History for

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

Commits on Oct 20, 2017

[hotfix][docs][javadocs] Remove double "the"

yew1eb
authored and
zentol
committedOct 20, 2017

Commits on Oct 18, 2017

[FLINK-7826][QS] Add support for all types of state to the QS Client.
kl0u
committedOct 18, 2017

Commits on Oct 12, 2017

[FLINK-7660] Support sideOutput in ProcessAllWindowFunction

bowenli86
authored and
aljoscha
committedOct 12, 2017

Commits on Sep 28, 2017

[FLINK-7547] Make AsyncFunction.scala extends Function

yew1eb
authored and
aljoscha
committedSep 28, 2017
[FLINK-7438] [scala] Remove unused import

yew1eb
authored and
zentol
committedSep 28, 2017

Commits on Sep 25, 2017

[FLINK-7635] Support side output in ProcessWindowFunction

bowenli86
authored and
aljoscha
committedSep 25, 2017