Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Feb 20, 2024

• [FLINK-34434][slotmanager] Complete the returnedFuture when slot removed before allocation success

  KarmaGYZ

  committed
  1a494bc

• [hotfix][test] Assert the slot allocation eventually succeed in dedicated tests of DefaultSlotStatusSyncerTest

  Show description for 15af3e4
  KarmaGYZ

  committed
  15af3e4

Commits on Feb 13, 2024

• [FLINK-34199] Add tracing for durations of rescaling/restoring (from local and downloaded remote state).

  StefanRRichter

  committed
  16eae41

• [FLINK-31238] Use IngestDB to speed up Rocksdb rescaling recovery (part 2)

  StefanRRichter

  committed
  5495a96

Commits on Feb 8, 2024

• [FLINK-34344] Pass JobID to CheckpointStatsTracker

  rkhachatryan

  committed
  c84f42c

• [FLINK-34200][test] Fix the bug that AutoRescalingITCase.testCheckpointRescalingInKeyedState fails occasionally

  1996fanrui

  committed
  1b95b19

• [FLINK-33960][Scheduler] Fix the bug that Adaptive Scheduler doesn't respect the lowerBound when one flink job has more than 1 tasks

  1996fanrui

  committed
  777e96f

• [FLINK-33960][JUnit5 migration] Migrate SlotSharingSlotAllocatorTest to Junit5 and Assertj

  1996fanrui

  committed
  71336d6

Commits on Feb 7, 2024

• [FLINK-34345][runtime] Remove TaskExecutorManager related logic

  

  caicancai

  authored and

  1996fanrui

  committed
  f1fba33

• Update version to 1.20-SNAPSHOT

  lincoln-lil

  committed
  bf5068c

Commits on Feb 5, 2024

• [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files

  

  fengjiajie

  authored and

  1996fanrui

  committed
  360c1a0

Commits on Feb 1, 2024

• Revert "[FLINK-33705] Upgrade to flink-shaded 18.0"

  snuyanzin

  authored
  d6c7eee

• [FLINK-34132][runtime] Correct the error message and doc that AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE.

  Show description for dd3e60a
  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  dd3e60a

• [FLINK-34206][runtime] Fix potential job failure due to concurrent global failure and source paralelism inference

  Show description for b737b71
  

  SinBex

  authored and

  zhuzhurk

  committed
  b737b71

Commits on Jan 31, 2024

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

  dmvk

  committed
  8e11b60

Commits on Jan 30, 2024

• [FLINK-32684][rpc] Introduces RpcOptions and deprecates AkkaOptions (apache#24188)

  Show description for c678244
  XComp

  authored
  c678244

• [FLINK-34233][runtime] Avoid enqueuing input channel before subpartitions initialized

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  973190e

• [FLINK-34225][runtime] Fix the race condition in UnionResultSubpartitionView

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  71c9760

• [hotfix][runtime] Fix resource releasing and recovery logic in shuffle

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  4aa4507

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

• [FLINK-34249][runtime] Remove DefaultSlotTracker related logic.

  

  RocMarshal

  authored and

  1996fanrui

  committed
  a24f771

Commits on Jan 26, 2024

• [FLINK-34223][dist] Introduce a migration tool to transfer legacy config file to new config file.

  Show description for 8fceb10
  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  8fceb10

• [FLINK-34204][core] Dispatch legacy serializer related methods in ExecutionConfig to SerializerConfig

  reswqa

  committed
  84444d5

Commits on Jan 25, 2024

• [FLINK-33577][dist] Change the default config file to config.yaml in flink-dist.

  Show description for 9721ce8
  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  9721ce8

• [FLINK-28915][k8s] Kubernetes client supports s3 jar location

  

  SwimSweet

  authored and

  mbalassi

  committed
  a85bcb4

Commits on Jan 24, 2024

• [FLINK-34190][checkpoint] Deprecate RestoreMode#LEGACY

  

  Zakelly

  authored and

  masteryhx

  committed
  f7a2819

• [FLINK-34174][runtime] Remove SlotMatchingStrategy related logic

  

  RocMarshal

  authored and

  1996fanrui

  committed
  551bb9e

• [FLINK-33865][runtime][refactor] Refactor the RestartStrategyType to reduce repeated magic string

  1996fanrui

  committed
  5c895aa

• [FLINK-34143] Modify the effective strategy of execution.batch.adaptive.auto-parallelism.default-source-parallelism

  Show description for 97caa3c
  

  SinBex

  authored and

  zhuzhurk

  committed
  97caa3c

Pagination

PreviousNext