Commits

Breadcrumbs

History for

on048a77c

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 25, 2024

• [FLINK-34913][metrics][state] Fix ConcurrentModificationException in SubTaskInitializationMetricsBuilder.addDurationMetric

  pnowojski

  committed
  048a77c

  Copy full SHA for 048a77c

• [FLINK-34526][runtime] Actively disconnect the TM in RM to reduce restart time (apache#24539)

  qinf

  authored
  a54ee77

  Copy full SHA for a54ee77

Commits on Mar 22, 2024

• [FLINK-34731][runtime] Remove SpeculativeScheduler and incorporate its features into AdaptiveBatchScheduler.

  Show description for cf0d75c
  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  cf0d75c

  Copy full SHA for cf0d75c

Commits on Mar 21, 2024

• [hotfix] Apply fixes to satisfy Checkstyle 9+

  snuyanzin

  committed
  1ddbd61

  Copy full SHA for 1ddbd61

Commits on Mar 20, 2024

• [FLINK-34667][state/changelog] Changelog state backend support local rescaling

  fredia

  committed
  501de48

  Copy full SHA for 501de48

Commits on Mar 18, 2024

• [FLINK-32074][checkpoint] Merge file across checkpoints

  

  Zakelly

  authored and

  masteryhx

  committed
  841f23c

  Copy full SHA for 841f23c

Commits on Mar 15, 2024

• [hotfix] In case of unexpected errors do not loose the primary failure reason

  Show description for f6e1b49
  pnowojski

  committed
  f6e1b49

  Copy full SHA for f6e1b49

• [FLINK-34546] Emit span with failure labels on failure in AdaptiveScheduler. (apache#24498)

  StefanRRichter

  authored
  10bff3d

  Copy full SHA for 10bff3d

Commits on Mar 14, 2024

• [FLINK-34640][metrics] Replace DummyMetricGroup usage with UnregisteredMetricsGroup

  

  jeyhunkarimov

  authored and

  JingGe

  committed
  a0c811e

  Copy full SHA for a0c811e

• [FLINK-34484][tests] Add UT/IT tests to verify localBackup and localRecovery configs

  

  ljz2051

  authored and

  fredia

  committed
  649e2b4

  Copy full SHA for 649e2b4

• [FLINK-34484][state] Split 'state.backend.local-recovery' into two options for checkpointing and recovery

  

  ljz2051

  authored and

  fredia

  committed
  ed75795

  Copy full SHA for ed75795

• [FLINK-34484][state]Move LOCAL_RECOVERY config from CheckpointingOptions to StateRecoveryOption

  

  ljz2051

  authored and

  fredia

  committed
  1d1dca6

  Copy full SHA for 1d1dca6

• [FLINK-32076][checkpoint] Introduce blocking file pool to reuse files (apache#24418)

  masteryhx

  committed
  3b9623e

  Copy full SHA for 3b9623e

• [FLINK-32076][checkpoint] Introduce non-blocking file pool to reuse files

  masteryhx

  committed
  583722e

  Copy full SHA for 583722e

Commits on Mar 11, 2024

• [FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError

  reswqa

  committed
  fcf61b9

  Copy full SHA for fcf61b9

Commits on Mar 8, 2024

• [FLINK-34417] Log Job ID via MDC

  rkhachatryan

  committed
  d6a4eb9

  Copy full SHA for d6a4eb9

• [FLINK-33668][runtime] Avoid the potential deadlock during reserving segments

  

  jiangxin369

  authored and

  reswqa

  committed
  4171b98

  Copy full SHA for 4171b98

• [FLINK-33668][runtime] Close the producer client in case of the result partition is not finished properly

  

  jiangxin369

  authored and

  reswqa

  committed
  c1ea971

  Copy full SHA for c1ea971

• [FLINK-33668][runtime] Make the SortBuffer be able to return unused memory segments

  

  jiangxin369

  authored and

  reswqa

  committed
  ac2ec34

  Copy full SHA for ac2ec34

• [FLINK-33668][runtime] Decouple the network memory and job topology on result partition side

  

  jiangxin369

  authored and

  reswqa

  committed
  88138d0

  Copy full SHA for 88138d0

• [FLINK-33668][runtime] Decouple the network memory and job topology on input gate side

  

  jiangxin369

  authored and

  reswqa

  committed
  2e25789

  Copy full SHA for 2e25789

• [FLINK-33668][runtime] Redefine the redistribution logic of the NetworkBufferPool

  

  jiangxin369

  authored and

  reswqa

  committed
  012b893

  Copy full SHA for 012b893

Commits on Mar 6, 2024

• [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese (apache#24279)

  Show description for 76cce1e
  

  lxliyou001

  and

  Zakelly

  authored
  76cce1e

  Copy full SHA for 76cce1e

• Revert "[FLINK-33532][network] Move the serialization of ShuffleDescriptorGroup out of the RPC main thread]"

  Show description for 7a709bf
  

  caodizhou

  authored and

  KarmaGYZ

  committed
  7a709bf

  Copy full SHA for 7a709bf

Commits on Mar 4, 2024

• [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption (apache#24181)

  

  Zakelly

  authored and

  masteryhx

  committed
  cd9a9f7

  Copy full SHA for cd9a9f7

Commits on Mar 1, 2024

• [FLINK-34546] Emit span with failure labels on failure.

  StefanRRichter

  committed
  7c8e3f5

  Copy full SHA for 7c8e3f5

• [hotfix][runtime] Remove unneeded requestTaskManagerFileUploadByName (apache#24386)

  Show description for f88f750
  1996fanrui

  authored
  f88f750

  Copy full SHA for f88f750

Commits on Feb 29, 2024

• [FLINK-20090][rest] Expose slot sharing group info in REST API

  gaborgsomogyi

  authored
  34a7734

  Copy full SHA for 34a7734

Commits on Feb 28, 2024

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

  dmvk

  authored
  bfaa75a

  Copy full SHA for bfaa75a

• [FLINK-34371][runtime] Fail savepoints until tasks with blocking edge finished

  

  yunfengzhou-hub

  authored and

  xintongsong

  committed
  d4e0084

  Copy full SHA for d4e0084

• [FLINK-34371][runtime] Start checkpoint only after tasks with blocking edge finished

  

  yunfengzhou-hub

  authored and

  xintongsong

  committed
  8d45cd9

  Copy full SHA for 8d45cd9

Commits on Feb 27, 2024

• [FLINK-34454][doc/annotation] Use claim mode instead of restore mode everywhere

  

  Zakelly

  authored and

  masteryhx

  committed
  b906922

  Copy full SHA for b906922

• [FLINK-34454] Introduce StateRecoveryOptions in flink-core and Rename options

  

  Zakelly

  authored and

  masteryhx

  committed
  63dc559

  Copy full SHA for 63dc559

• [hotfix][runtime] Refactors suspend and cancel logic

  Show description for db3e21f
  XComp

  committed
  db3e21f

  Copy full SHA for db3e21f

• [FLINK-34518][runtime] Fixes AdaptiveScheduler#suspend bug when the job is suspended during Restarting phase

  XComp

  committed
  3ba6f15

  Copy full SHA for 3ba6f15

Pagination

Previous

Next