Commits

History for

Commits on Mar 29, 2018

[FLINK-8802] [QS] Fix concurrent access to non-duplicated serializers.
kl0u
committedMar 29, 2018
[FLINK-8908] Do not create copy when MapSerializer stateless.
kl0u
committedMar 29, 2018
[FLINK-9060][state] Fix concurrent modification exception when iterating keys.

sihuazhou
authored and
kl0u
committedMar 29, 2018
[FLINK-8813][flip6] Disallow PARALLELISM_AUTO_MAX for flip6

pnowojski
authored and
kl0u
committedMar 29, 2018

Commits on Mar 28, 2018

[hotfix] Guard against clock changes when computing the net runtime of a job
tillrohrmann
committedMar 28, 2018
[FLINK-9081] [tests] Harden ResourceManagerJobMasterTest and ResourceManagerTaskExecutorTest

sihuazhou
authored and
tillrohrmann
committedMar 28, 2018
[FLINK-8943] [ha] Fail Dispatcher if jobs cannot be recovered from HA store
tillrohrmann
committedMar 28, 2018
[hotfix] Extend TestingFatalErrorHandler to return an error future
tillrohrmann
committedMar 28, 2018
[FLINK-9063] Fix SpillableSubpartitionTest testSpillFinishedBufferConsumers

pnowojski
authored and
tillrohrmann
committedMar 28, 2018
[FLINK-8887] Wait for JobMaster leader election in Dispatcher
tillrohrmann
committedMar 28, 2018
[FLINK-9099] Assign Execution to LogicalSlot when slot is assigned to Execution
tillrohrmann
committedMar 28, 2018
[hotfix] Remove cluttering comments from JobMaster
tillrohrmann
committedMar 28, 2018
[hotfix] Fix race condition in JobMaster#requestJobDetails
tillrohrmann
committedMar 28, 2018
[hotfix] Remove unused fields in JobMaster
tillrohrmann
committedMar 28, 2018
[hotfix] Create ExecutionGraph when JobMaster is started
tillrohrmann
committedMar 28, 2018
[FLINK-8740] [metrics] Create new JobManagerJobMetricGroup when creating a new ExecutionGraph
tillrohrmann
committedMar 28, 2018
[FLINK-9026] [flip6] Close the TaskManagerMetricGroup when the TaskExecutor is shut down

sihuazhou
authored and
tillrohrmann
committedMar 28, 2018
[FLINK-8941][serialization] make sure we use unique spilling files

Nico Kruber
authored and
tillrohrmann
committedMar 28, 2018
[FLINK-8941][tests] use TestLogger and TemporaryFolder in SpanningRecordSerializationTest

Nico Kruber
authored and
tillrohrmann
committedMar 28, 2018
[FLINK-9057][network] fix an NPE when cleaning up before requesting a subpartition view

Nico Kruber
authored and
tillrohrmann
committedMar 28, 2018

Commits on Mar 27, 2018

Commits on Mar 26, 2018

[FLINK-8721][flip6] Handle archiving failures for accumulators

pnowojski
authored and
tillrohrmann
committedMar 26, 2018
[hotfix][tests] Allow to run SpillableSubpartitionTests in the loop

pnowojski
authored and
tillrohrmann
committedMar 26, 2018
[hotfix][tests] Do not hide original exception in the tests

pnowojski
authored and
tillrohrmann
committedMar 26, 2018
[hotfix][runtime] Remove unused method

pnowojski
authored and
tillrohrmann
committedMar 26, 2018

Commits on Mar 23, 2018