Commits

Branch selector

 master

User selector

tillrohrmann

Datepicker

All time

Commit History

Commits on Apr 26, 2021

• [hotfix] Harden against FLINK-21376 by checking for null failure cause

  Show description for df301ed
  tillrohrmann

  committed
  df301ed

• [hotfix] Add debug logging to the states of the AdaptiveScheduler

  Show description for b88b290
  tillrohrmann

  committed
  b88b290

• [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

  Show description for 6be9668
  tillrohrmann

  committed
  6be9668

• [hotfix] Do not use ExecutorService.submit since it can swallow exceptions

  Show description for fb31e28
  tillrohrmann

  committed
  fb31e28

Commits on Apr 22, 2021

• [FLINK-22001] Fix forwarding of JobMaster exceptions to user

  Show description for 75d27d1
  tillrohrmann

  committed
  75d27d1

Commits on Apr 21, 2021

• [hotfix] Set default value of resource-stabilization-timeout to 10s

  Show description for 4ad4e87
  tillrohrmann

  committed
  4ad4e87

Commits on Apr 16, 2021

• [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

  Show description for ebfdf2a
  tillrohrmann

  committed
  ebfdf2a

Commits on Apr 15, 2021

• [hotfix] Let JobMasterStopWithSavepointITCase.ExceptionOnCallbackStreamTask implement finishTask to finish

  Show description for d5841ea
  tillrohrmann

  committed
  d5841ea

Commits on Apr 13, 2021

• [hotfix] Correct log statement content

  tillrohrmann

  committed
  b3644a4

Commits on Apr 9, 2021

• [hotfix] Use AllocationID instead of JobID when slot cannot be marked as active.

  tillrohrmann

  committed
  bcfaf0b

Commits on Apr 8, 2021

• [FLINK-22142][ci] Don't log Kafka connector output to the AZP console

  Show description for 45141b4
  tillrohrmann

  committed
  45141b4

• [FLINK-21954][tests] Harden JobMasterQueryableStateTest

  Show description for ce4beb6
  tillrohrmann

  committed
  ce4beb6

• [FLINK-21954][tests] Harden JobMasterTest.testRestoringFromSavepoint and .testRequestNextInputSplitWithGlobalFailover

  Show description for a26a5f0
  tillrohrmann

  committed
  a26a5f0

Commits on Apr 7, 2021

• [FLINK-22014][ha] Make sure that AbstractHaServices delete first the HA data before deleting blobs on closeAndCleanupAllData

  Show description for 9c4da7c
  tillrohrmann

  committed
  9c4da7c

Commits on Apr 6, 2021

• [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

  Show description for 97f3330
  tillrohrmann

  committed
  97f3330

Commits on Apr 1, 2021

• [FLINK-21942][tests] Introduce TestingJobLeaderIdService and use it in ResourceManagerTest

  Show description for 2eb5d1c
  tillrohrmann

  committed
  2eb5d1c

• [FLINK-21942] Extract JobLeaderIdService interface to make the ResourceManager better testable

  tillrohrmann

  committed
  6b40ff1

• [FLINK-22048] Remove akka.transport.* config options

  Show description for c0eb9d7
  tillrohrmann

  committed
  c0eb9d7

Commits on Mar 31, 2021

• [hotfix] Make SimpleRecoveryITCaseBase.testRestartMultipleTimes restart strategy agnostic

  tillrohrmann

  committed
  2fc5de7

• [hotfix][tests] Use MiniClusterWithClientResource in SimpleRecoveryITCaseBase

  Show description for 58dfae6
  tillrohrmann

  committed
  58dfae6

• [FLINK-21609][tests] Remove usage of LocalCollectionOutpuFormat from SimpleRecoveryITCaseBase

  Show description for d5ac263
  tillrohrmann

  committed
  d5ac263

• [hotfix][docs] Use Hugo highlighting for danger and info sections

  Show description for 2e831c7
  tillrohrmann

  committed
  2e831c7

• [FLINK-22051][docs] Explain when to use stop-with-savepoint --drain

  Show description for 761ecfc
  tillrohrmann

  committed
  761ecfc

Commits on Mar 26, 2021

• [FLINK-21387][tests] Remove test timeout from DispatcherTest.testNonBlockingJobSubmission and .testInvalidCallDuringInitialization

  Show description for cd02aff
  tillrohrmann

  committed
  cd02aff

• [hotfix] Let SimpleRecoveryITCaseBase extend TestLogger

  tillrohrmann

  committed
  1a2bf71

Commits on Mar 23, 2021

• [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

  Show description for d80fa03
  tillrohrmann

  committed
  d80fa03

• [FLINK-21550][tests] Harden ZooKeeperHaServicesTest.testSimpleClose

  Show description for 241db3f
  tillrohrmann

  committed
  241db3f

Commits on Mar 20, 2021

• [FLINK-21602] Track asynchronous background tasks in the AdaptiveScheduler

  Show description for 3dd938d
  tillrohrmann

  committed
  3dd938d

• [hotfix] Add FutureUtils.switchExecutor utility

  Show description for d6750d6
  tillrohrmann

  committed
  d6750d6

• [FLINK-21602] Allow SchedulerNG to terminate asynchronously

  Show description for a1798ec
  tillrohrmann

  committed
  a1798ec

• [hotfix] Rename SchedulerNG.getTerminationFuture into getJobTerminationFuture

  Show description for ae42e74
  tillrohrmann

  committed
  ae42e74

• [hotfix] Annotate CheckpointsCleaner with @threadsafe

  tillrohrmann

  committed
  6b2e05f

• [hotfix] Factor ExecutionGraph creation out into ExecutionGraphFactory

  Show description for fb94512
  tillrohrmann

  committed
  fb94512

• [FLINK-21602] Split ExecutionGraph generation and slot assignments into two steps

  Show description for 1f5f9aa
  tillrohrmann

  committed
  1f5f9aa

• [hotfix] Make SlotAllocator configurable for the AdaptiveScheduler

  tillrohrmann

  committed
  0809487

Pagination

Previous

Next