Commits

Branch selector

 master

User selector

dmvk

Datepicker

All time

Commit History

Commits on Oct 3, 2024

• [FLINK-32483][tests] Ensure RescaleCheckpointManuallyITCase always runs against aligned checkpoints.

  dmvk

  committed
  dd8c485

Commits on Jul 4, 2024

• [FLINK-35553][runtime] Wire-up RescaleManager with CheckpointStatsListener in Executing state

  

  dmvk

  authored and

  XComp

  committed
  1f03a0a

Commits on Jul 3, 2024

• [hotfix][runtime] Remove no longer used CheckpointCoordinator#failUnacknowledgedPendingCheckpointsFor method.

  

  dmvk

  authored and

  XComp

  committed
  097fc7d

Commits on Jun 12, 2024

• [FLINK-20217][task] Allow certains operators to yield to unaligned checkpoint in case timers are firing.

  Show description for f93cac3
  

  dmvk

  and

  pnowojski

  committed
  f93cac3

Commits on Feb 28, 2024

• [FLINK-34274][runtime] Implicitly disable resource wait timeout for AdaptiveSchedulerTest (apache#24238)

  dmvk

  authored
  bfaa75a

Commits on Jan 31, 2024

• [FLINK-34272][runtime] ExecutingState should never transition during its construction.

  dmvk

  committed
  8e11b60

Commits on Jan 29, 2024

• fixup! [FLINK-33976] Consolidate AdaptiveScheduler options into AdaptiveSchduler#Settings object.

  dmvk

  committed
  e945a36

• fixup! [FLINK-33976] Populate scalingInterval{Min,Max} options from the JobMaster's configuration instead of a Job configuration.

  dmvk

  committed
  843fe8f

• fixup! [FLINK-33976] Consolidate AdaptiveScheduler options into AdaptiveSchduler#Settings object.

  dmvk

  committed
  5ae4893

• [hotfix] Speed up AdaptiveSchedulerClusterITCase by setting scalingIntervalMin to 1ms.

  dmvk

  committed
  2337771

• [hotfix] Speed up AdaptiveSchedulerTest by setting scalingIntervalMin to 1ms.

  dmvk

  committed
  9699cf4

• [FLINK-33976] Populate scalingInterval{Min,Max} options from the JobMaster's configuration instead of a Job configuration.

  dmvk

  committed
  e04a232

• [FLINK-33976] Consolidate AdaptiveScheduler options into AdaptiveSchduler#Settings object.

  dmvk

  committed
  92d6932

Commits on Jan 19, 2024

• [FLINK-34063][runtime] Fix OperatorState repartitioning when compression is enabled. We should only write compression headers once, at the end of the "value" part of the serialized stream, to make …

  Show description for b7c314b
  dmvk

  committed
  b7c314b

• [FLINK-34063][runtime] Operator states need to be restored in an order they've been written for the compression to work properly on empty states.

  dmvk

  committed
  d536b5a

• [FLINK-34063][runtime] Fix CompressibleFSDataInputStream#seek in case of partial reads.

  dmvk

  committed
  6f76982

• [FLINK-34063][test-utils] Add ExecutionOptions.SNAPSHOT_COMPRESSION to randomized checkpointing options.

  dmvk

  committed
  006a086

• [FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot.

  dmvk

  committed
  161378a

Commits on Oct 23, 2023

• [FLINK-32671] Document Externalized Declararative Resource Management + minor Elastic Scaling page restructuring.

  dmvk

  committed
  8af765b

Commits on Jul 6, 2023

• [FLINK-31996] Chaining operators with different max parallelism prevents rescaling

  Show description for 58a849b
  dmvk

  authored
  58a849b

Commits on May 5, 2023

• [FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is already known.

  dmvk

  committed
  026d7cc

• [FLINK-32010][runtime] Leader election/retrieval drivers should properly extend AutoCloseable instead of having their own close method with the same signature.

  dmvk

  committed
  6009e81

• [FLINK-32010][kubernetes] Rename KubernetesUtils#checkConfigMaps to KubernetesUtils#getOnlyConfigMap to provide more clarity.

  dmvk

  committed
  075f359

• [FLINK-32010][kubernetes] Remove an unused parameter from KubernetesLeaderRetrievalDriver.

  dmvk

  committed
  058b1f5

• [FLINK-32000][webui] Expose max parallelism in the vertex detail drawer.

  dmvk

  committed
  43528be

Commits on Apr 26, 2023

• [FLINK-31935] Register handlers for resource requirements endpoints in all deployment modes (session, application, per-job).

  

  dmvk

  authored and

  zentol

  committed
  3acb76d

Commits on Apr 21, 2023

• [FLINK-31723] Fix DispatcherTest#testCancellationDuringInitialization to not make assumptions about an underlying scheduler implementation.

  dmvk

  committed
  52bf14b

• [FLINK-31723] Refactor DispatcherTest#testCancellationDuringInitialization to use Assertj matchers and to make it more explicit what it actually tests.

  dmvk

  committed
  378d3ca

• [FLINK-31803] Harden UpdateJobResourceRequirementsRecoveryITCase.

  Show description for c2ab806
  dmvk

  committed
  c2ab806

Commits on Apr 18, 2023

• [FLINK-31823] Make #testWebRescaleFeatureFlagWithReactiveMode work for the AdaptiveScheduler smoke test.

  dmvk

  committed
  1d9f12a

Commits on Apr 14, 2023

• [FLINK-31471] Allow setting JobResourceRequirements through WEB UI.

  dmvk

  committed
  40d2cfb

Commits on Apr 13, 2023

• [FLINK-31792][WebUI] Fix resolution errors during NzNotificationService injection.

  Show description for 3f70900
  dmvk

  committed
  3f70900

Commits on Apr 5, 2023

• [FLINK-31470] Add integration tests for Externalized Declarative Resource Management.

  Show description for d4e3b66
  dmvk

  committed
  d4e3b66

• [hotfix] Introduce InstantiationUtil#cloneUnchecked for the cases where we don't need to handle exceptions.

  Show description for 0a874de
  dmvk

  committed
  0a874de

Commits on Apr 4, 2023

• [FLINK-31469] Allow setting JobResourceRequirements through REST API.

  Show description for a539eb2
  dmvk

  committed
  a539eb2

Pagination

PreviousNext