Commits

Branch selector

 main

User selector

All users

Datepicker

All time

Commit History

Commits on Feb 17, 2023

• [CELEBORN-235] Implement flink plugin. (apache#1244)

  FMX

  authored
  bfb3963

  Copy full SHA for bfb3963

• [CELEBORN-291] optimize shuffleclientimpl creating client and pushdata for mappartition (apache#1224)

  zhongqiangczq

  authored
  b5dc106

  Copy full SHA for b5dc106

• [CELEBORN-234] Implement buffer stream. (apache#1221)

  FMX

  authored
  0c8bb83

  Copy full SHA for 0c8bb83

• [CELEBORN-290] optimize flink-plugin RemoteShuffleOutputGate/RemoteShuffleResultPartition (apache#1223)

  zhongqiangczq

  authored
  80c922c

  Copy full SHA for 80c922c

• [CELEBORN-310] include roaringbitmap in flink plugin (apache#1245)

  RexXiong

  authored
  4bac219

  Copy full SHA for 4bac219

• [CELEBORN-283] Derive network layer for flink plugin. (apache#1222)

  FMX

  authored
  3aacede

  Copy full SHA for 3aacede

• [CELEBORN-292] optimize mappartitionfilewriter flushing index and reading data header (apache#1225)

  zhongqiangczq

  authored
  5236df6

  Copy full SHA for 5236df6

• [CELEBORN-293] WorkerSource registers timer for mappartition message metrics (apache#1226)

  zhongqiangczq

  authored
  79096d6

  Copy full SHA for 79096d6

• [CELEBORN-297] don't cache file groups for map partition shuffle type (apache#1237)

  RexXiong

  authored
  b7ef9cf

  Copy full SHA for b7ef9cf

• [CELEBORN-281] Add metrics about buffer stream read buffer. (apache#1216)

  FMX

  authored
  1dcfdb0

  Copy full SHA for 1dcfdb0

• [CELEBORN-309] Fix some potential concurrent issues in InFlightRequestTracker (apache#1243)

  waitinfuture

  authored
  89b4eab

  Copy full SHA for 89b4eab

Commits on Feb 16, 2023

• [CELEBORN-273] Move push data timeout checker into TransportResponseHandler to keep callback status consistence (apache#1208)

  AngersZhuuuu

  authored
  57f775a

  Copy full SHA for 57f775a

• [CELEBORN-282] Add BacklogAnnouncement RPC. (apache#1217)

  FMX

  authored
  a364fb2

  Copy full SHA for a364fb2

• [CELEBORN-278] Add openStreamWithCredit RPC. (apache#1214)

  FMX

  authored
  534853b

  Copy full SHA for 534853b

• [CELEBORN-307] fix ArrayComparisonFailure while running lz4 ut (apache#1241)

  zhongqiangczq

  authored
  2c508da

  Copy full SHA for 2c508da

Commits on Feb 15, 2023

• [CELEBORN-305] Change the parameter passed in the registerShuffle method to numPartitions instead of numMappers (apache#1240)

  jiaoqingbo

  authored
  318157e

  Copy full SHA for 318157e

• [CELEBORN-304] Missing setIfMissing celeborn.$module.io.serverThreads (apache#1238)

  jiaoqingbo

  authored
  bd9e0dd

  Copy full SHA for bd9e0dd

Commits on Feb 14, 2023

• [CELEBORN-296] fix map partition commit using wrong partitionId and result (apache#1233)

  RexXiong

  authored
  75c8309

  Copy full SHA for 75c8309

• [CELEBORN-300] fix a bug about non-leader master try to update partition size. (apache#1235)

  FMX

  authored
  d391e7d

  Copy full SHA for d391e7d

• [CELEBORN-298] Fix the wrong configuration name in readme and conf.template (apache#1234)

  zhongqiangczq

  authored
  4fb5b3d

  Copy full SHA for 4fb5b3d

Commits on Feb 13, 2023

• [CELEBORN-279] Add user level push data speed metric (apache#1213)

  

  Rex(Hui) An

  authored
  2068e6a

  Copy full SHA for 2068e6a

• [CELEBORN-286] Fix source package contains license-binary. (apache#1219)

  FMX

  authored
  19bcea2

  Copy full SHA for 19bcea2

Commits on Feb 10, 2023

• [CELEBORN-284] fix typo in CelebornConf (apache#1218)

  Show description for 3a92b0d
  

  jiaoqingbo

  and

  jiaoqb

  authored
  3a92b0d

  Copy full SHA for 3a92b0d

Commits on Feb 9, 2023

• [CELEBORN-277] PushDataHandle callback could miss soft split status (apache#1212)

  

  Rex(Hui) An

  authored
  adb6592

  Copy full SHA for adb6592

Commits on Feb 8, 2023

• [CELEBORN-239][FOLLOWUP] PUSH_DATA_TIMEOUT_MASTER/SLAVE should support convert through RPC (apache#1211)

  Show description for dae58a6
  AngersZhuuuu

  authored
  dae58a6

  Copy full SHA for dae58a6

Commits on Feb 7, 2023

• [CELEBORN-207][FOLLOW_UP] Master could miss the congestion status if enable push.data.replicate

  

  Rex(Hui) An

  authored
  f88f5fc

  Copy full SHA for f88f5fc

• [CELEBORN-275] WrappedCallback should only handle response from replica (apache#1209)

  

  Rex(Hui) An

  authored
  cfe8196

  Copy full SHA for cfe8196

• [CELEBORN-227] Support different push strategies to control the push speed (apache#1167)

  

  Rex(Hui) An

  authored
  bff6e91

  Copy full SHA for bff6e91

• [CELEBORN-207] Support network congestion control (apache#1066)

  

  Rex(Hui) An

  authored
  bb113ec

  Copy full SHA for bb113ec

Commits on Feb 6, 2023

• [CELEBORN-247][FOLLOWUP] Fix NPE issue (apache#1207)

  AngersZhuuuu

  authored
  ae32c70

  Copy full SHA for ae32c70

• [CELEBORN-247][FOLLOWUP] Add metrics for each user's quota usage (apache#1206)

  AngersZhuuuu

  authored
  46240d5

  Copy full SHA for 46240d5

• [CELEBORN-271][BUG] PushState in PushDataHandler should should use peer's location

  AngersZhuuuu

  authored
  c402010

  Copy full SHA for c402010

• [CELEBORN-272][BUG] Don't do replication should directly use callback not wrappedCallback (apache#1205)

  AngersZhuuuu

  authored
  ecc3a0e

  Copy full SHA for ecc3a0e

Commits on Feb 4, 2023

• [CELEBORN-243][REWORK]fix bug that os's disk usage is low but celeborn thinks that it's high_disk_usage (apache#1202)

  

  zhongqiangczq

  authored and

  waitinfuture

  committed
  8e90384

  Copy full SHA for 8e90384

Commits on Feb 3, 2023

• [CELEBORN-269][BUG] Disable replication throw NPE when removeBatch in pushDataHandler (apache#1203)

  AngersZhuuuu

  authored
  2e68912

  Copy full SHA for 2e68912

Pagination

Previous

Next