Commits

Branch selector

 master

User selector

TanYuxin-tyx

Datepicker

All time

Commit History

Commits on May 21, 2024

• [FLINK-35130][runtime] Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  46aaea8

  Copy full SHA for 46aaea8

Commits on Apr 23, 2024

• [FLINK-35214][runtime] Update result partition id for remote input channel when unknown input channel is updated

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  ea2eabe

  Copy full SHA for ea2eabe

Commits on Apr 22, 2024

• [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  68a84fd

  Copy full SHA for 68a84fd

Commits on Dec 12, 2023

• [FLINK-33612][table-planner] Hybrid shuffle mode avoids unnecessary blocking edges in the plan

  

  TanYuxin-tyx

  authored and

  lsyldliu

  committed
  9cac80b

  Copy full SHA for 9cac80b

Commits on Nov 16, 2023

• [FLINK-33537][docs] Fix missing 1.18 doc link

  TanYuxin-tyx

  authored
  09c1344

  Copy full SHA for 09c1344

Commits on Oct 18, 2023

• [FLINK-33185][tests] Fix unstable test HybridShuffleITCase#testHybridSelectiveExchangesRestart

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  166aab3

  Copy full SHA for 166aab3

Commits on Sep 26, 2023

• [hotfix][tests] Decrease the network memory size to make HybridShuffleITCase more stable

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  b1a111c

  Copy full SHA for b1a111c

Commits on Sep 20, 2023

• [FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  b076c52

  Copy full SHA for b076c52

• [hotfix][network] Flush writing buffers when closing HashSubpartitionBufferAccumulator of tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  887c66a

  Copy full SHA for 887c66a

Commits on Sep 19, 2023

• [FLINK-33103][network] Hybrid shuffle ITCase supports the new mode

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  cc33ce1

  Copy full SHA for cc33ce1

Commits on Sep 15, 2023

• [hotfix][network] Fix the bug of triggering disk writing in Hybrid Shuffle

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  37a9ce1

  Copy full SHA for 37a9ce1

• [FLINK-33088][network] Fix NullPointerException in RemoteTierConsumerAgent for tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  1774b84

  Copy full SHA for 1774b84

Commits on Sep 12, 2023

• [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

  Show description for ade583c
  

  TanYuxin-tyx

  authored and

  xintongsong

  committed
  ade583c

  Copy full SHA for ade583c

• [hotfix][network] Fix the close method for the tiered producer client

  

  TanYuxin-tyx

  authored and

  xintongsong

  committed
  e41b0b2

  Copy full SHA for e41b0b2

Commits on Aug 11, 2023

• [FLINK-32709][network] Fix the bug of low memory utilization for Hybrid Shuffle

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  0f84162

  Copy full SHA for 0f84162

• [hotfix][network] Fix the unreleased bug for the tiered disk io scheduler

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  f2ca310

  Copy full SHA for f2ca310

Commits on Aug 2, 2023

• [FLINK-32675][doc] Add document for the tiered storage of hybrid shuffle

  Show description for b18bde9
  

  TanYuxin-tyx

  authored and

  xintongsong

  committed
  b18bde9

  Copy full SHA for b18bde9

Commits on Jul 19, 2023

• [FLINK-32576][network] ProducerMergedPartitionFileIndex supports caching regions and spilling regions to file

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  1786e2d

  Copy full SHA for 1786e2d

• [FLINK-32576][network] Extract file data index cache for hybrid shuffle

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  0ef0dbd

  Copy full SHA for 0ef0dbd

Commits on Jul 12, 2023

• [FLINK-32549][network] Tiered storage memory manager supports ownership transfer for buffers

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  2dfff43

  Copy full SHA for 2dfff43

• [hotfix][network] Fix the availability of tiered result partition

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  61d8fec

  Copy full SHA for 61d8fec

Commits on Jul 7, 2023

• [FLINK-32541][network] Fix the buffer leaking when buffer accumulator is closed

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  73a0b87

  Copy full SHA for 73a0b87

Commits on Jul 6, 2023

• [FLINK-31646][network] Implement the remote tier producer for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  32044dd

  Copy full SHA for 32044dd

• [FLINK-31646][network] Implement SegmentPartitionFile for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  b9d21f1

  Copy full SHA for b9d21f1

• [hotfix][network] Simplify the fields in TieredInternalShuffleMaster

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  f789db3

  Copy full SHA for f789db3

• [hotfix][network] Remove partition file writer and reader for TierFactory#createProducerAgent

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  13d0900

  Copy full SHA for 13d0900

Commits on Jun 30, 2023

• [FLINK-31644][network] Implement the disk tier producer for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  00e10cd

  Copy full SHA for 00e10cd

• [FLINK-31644][network] Implement ProducerMergePartitionFile for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  8b0afcf

  Copy full SHA for 8b0afcf

• [FLINK-31644][network] Introduce the interface of partition file writer and reader for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  a77aa65

  Copy full SHA for a77aa65

Commits on Jun 29, 2023

• [FLINK-32283][network] Implement the SortBufferAccumulator for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  7466df0

  Copy full SHA for 7466df0

• [hotfix][network] Fix the close method order in TieredResultPartition

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  d0f3ba6

  Copy full SHA for d0f3ba6

Commits on Jun 14, 2023

• [FLINK-31641][network] Implement the memory tier producer for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  54e9eca

  Copy full SHA for 54e9eca

• [hotfix][network] Fix the class name of TieredStoreResultSubpartitionView

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  b9f7a0e

  Copy full SHA for b9f7a0e

Commits on Jun 5, 2023

• [FLINK-31640][network] Write the accumulated buffers to the right storage tier

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  daf476f

  Copy full SHA for daf476f

• [hotfix][network] Fix the writing subpartition id for tiered storage producer client

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  f3ea192

  Copy full SHA for f3ea192

Pagination

Previous

Next