Commits

Commits on Aug 7, 2020

[FLINK-16510] Allow configuring shutdown behavior to avoid JVM freeze

mxm
authored and
tillrohrmann
committedAug 7, 2020

Commits on Apr 3, 2020

[FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

mxm
authored and
tillrohrmann
committedApr 3, 2020

Commits on Mar 16, 2020

[FLINK-16573] Ensure Kinesis RecordFetcher threads shutdown on cancel
mxm
committedMar 16, 2020

Commits on Jan 10, 2020

[FLINK-15504] Allow output to stdout/stderr during execution of PackagedProgram
mxm
committedJan 10, 2020

Commits on Dec 7, 2019

[FLINK-8949] Add dedicated watermarks metric retrieval endpoint (apache#10238 )
mxm
committedDec 7, 2019

Commits on Dec 18, 2018

[FLINK-11168][tests] Relax time-constraints for LargePlanTest

mxm
authored and
zentol
committedDec 18, 2018

Commits on Dec 14, 2018

[FLINK-10566] Fix exponential planning time of large programs
mxm
committedDec 14, 2018

Commits on Dec 23, 2016

[FLINK-4516] update leadership information in ResourceManager

mxm
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager

mxm
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4606] integrate features of old ResourceManager

mxm
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses

mxm
authored and
StephanEwen
committedDec 23, 2016
[hotfix] fix ResourceManagerGateway

mxm
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4535] rebase and refine

mxm
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4537] rebase and refine

mxm
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol

mxm
authored and
StephanEwen
committedDec 23, 2016

Commits on Dec 16, 2016

[FLINK-2821] use custom Akka build to listen on all interfaces
mxm
committedDec 16, 2016
[maven] properly attach the CEP Scala source code
mxm
committedDec 16, 2016
[FLINK-5350] don't overwrite an existing JAAS config
mxm
committedDec 16, 2016
[FLINK-5091] cleanup unused Mesos configuration entries
mxm
committedDec 16, 2016
[FLINK-4922][docs] document how to use Flink on Mesos
mxm
committedDec 16, 2016
[docker] improve Dockerfile host configuration
mxm
committedDec 16, 2016

Commits on Dec 14, 2016

[FLINK-5240][tests] ensure state backends are properly closed
mxm
committedDec 14, 2016

Commits on Dec 7, 2016

[docs] clarify default restart behavior when checkpointing is enabled
mxm
committedDec 7, 2016

Commits on Dec 5, 2016

[test-utils] cleanup and improve method to set the environment
mxm
committedDec 5, 2016
[FLINK-5262][docs] Introduce Gemfile.lock to avoid dependency range conflicts
mxm
committedDec 5, 2016

Commits on Nov 25, 2016

[FLINK-5055][security] skip Hadoop UGI login if unsecured
mxm
committedNov 25, 2016

Commits on Nov 24, 2016

[FLINK-5149] let ContinuousEventTimeTrigger fire at the end of the window
mxm
committedNov 24, 2016

Commits on Nov 21, 2016

[FLINK-5071][yarn] adjust vcore validation check
mxm
committedNov 21, 2016

Commits on Nov 4, 2016

[FLINK-3813][yarn] wait for CLI to complete before checking output
mxm
committedNov 4, 2016
[FLINK-4998][yarn] fail if too many task slots are configured
mxm
committedNov 4, 2016

Commits on Nov 3, 2016

[yarn] fix debug string displayed for failed applications
mxm
committedNov 3, 2016

Commits on Oct 27, 2016

[FLINK-4913][yarn] include user jars in system class loader
mxm
committedOct 27, 2016

Commits on Oct 21, 2016

[FLINK-4833] properly log exceptions in CountMinHeavyHitter
mxm
committedOct 21, 2016

Commits on Oct 18, 2016

[FLINK-4829] snapshot accumulators on a best-effort basis
mxm
committedOct 18, 2016
[FLINK-4829] protect user accumulators against concurrent updates
mxm
committedOct 18, 2016