Commits

Commits on Jan 2, 2023

Update flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java

authored and
gyfora
committedJan 2, 2023
PR comment

authored and
gyfora
committedJan 2, 2023
Use RebalancePartitioner

mxm
authored and
gyfora
committedJan 2, 2023
Replace Java 11 call

mxm
authored and
gyfora
committedJan 2, 2023
[FLINK-30213] Change ForwardPartitioner to RebalancePartitioner on parallelism changes

mxm
authored and
gyfora
committedJan 2, 2023

Commits on Nov 23, 2022

[FLINK-29501] Add option to override job vertex parallelisms during job submission (apache#21023 )
mxm
committedNov 23, 2022

Commits on Sep 14, 2022

[FLINK-28853] Address PR comments / Add Kafka and Pulsar split pausing tests
mxm
committedSep 14, 2022

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