Commits

Branch selector

 master

User selector

yunfengzhou-hub

All time

Commit History

Commits on Jan 19, 2024

• [FLINK-34149][Runtime/Checkpointing] Fix SplitEnumeratorContext compatibility issue

  Show description for b309ceb
  yunfengzhou-hub

  authored
  b309ceb

  Copy full SHA for b309ceb

Commits on Jan 17, 2024

• [FLINK-33743][runtime] Optimize partial record split logic

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  a886339

  Copy full SHA for a886339

• [FLINK-33743][runtime] Flush one accumulated buffer at a time

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  be12731

  Copy full SHA for be12731

• [FLINK-33743][runtime] Ignore RecordAttributes when adaptive parallelism is used

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  8358e3a

  Copy full SHA for 8358e3a

• [FLINK-33743][runtime] Align watermark at subpartition granularity

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  32de752

  Copy full SHA for 32de752

• [FLINK-33743][runtime] Rename InputChannelStatus to SubpartitionStatus

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  f2417a7

  Copy full SHA for f2417a7

• [FLINK-33743][runtime] Support consuming multiple subpartition in one inputchannel

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  1199c71

  Copy full SHA for 1199c71

• [FLINK-33743][runtime] Add ResultSubpartitionView parameter to notifyDataAvailable() method

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  8651f73

  Copy full SHA for 8651f73

• [FLINK-33743][runtime] Change numCreditsAvailable to isCreditAvailable in ResultSubpartitionView#getAvailabilityAndBacklog

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  4e6796d

  Copy full SHA for 4e6796d

• [FLINK-33743][runtime] Acquire subpartition id for input channel dynamically in tiered shuffle

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  439d109

  Copy full SHA for 439d109

• [FLINK-33743][runtime] Disable tier shuffle during recovery

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  f0436e5

  Copy full SHA for f0436e5

• [FLINK-33743][runtime] Identify subpartitionId in notifyRequiredSegment

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  6b44f29

  Copy full SHA for 6b44f29

• [FLINK-33743][runtime] Modify parameter subpartitionIndex to subpartitionIndexSet

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  0e8b980

  Copy full SHA for 0e8b980

• [FLINK-33743][runtime] Replace consumer-side SubpartitionId with InputChannelId

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  c65d5f1

  Copy full SHA for c65d5f1

• [FLINK-33743][runtime] Distinguish channel and subpartition

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  2839d06

  Copy full SHA for 2839d06

Commits on Dec 19, 2023

• [FLINK-33534][runtime] Support configuring PARALLELISM_OVERRIDES during job submission

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  4cc24c1

  Copy full SHA for 4cc24c1

Commits on Aug 24, 2023

• [FLINK-32514][Runtime/Checkpointing] Support configuring checkpointing interval during process backlog (#22931)

  Show description for 615e824
  yunfengzhou-hub

  authored
  615e824

  Copy full SHA for 615e824

Commits on May 25, 2023

• [FLINK-31240][table] Reduce the overhead of conversion between DataStream and Table

  Show description for 6b6df3d
  yunfengzhou-hub

  authored
  6b6df3d

  Copy full SHA for 6b6df3d

Commits on Apr 23, 2023

• [FLINK-31752] Fix SourceOperator numRecordsOut duplicate bug

  Show description for 26bd5fe
  yunfengzhou-hub

  authored
  26bd5fe

  Copy full SHA for 26bd5fe

Commits on Jan 19, 2023

• [FLINK-30753][python] Fix the invocation process of Table.explain()

  Show description for 9ebb331
  

  yunfengzhou-hub

  authored and

  HuangXingBo

  committed
  9ebb331

  Copy full SHA for 9ebb331

• [FLINK-30191][python] Update net.sf.py4j:py4j dependency to 0.10.9.7

  Show description for 0bbc7b1
  

  yunfengzhou-hub

  authored and

  HuangXingBo

  committed
  0bbc7b1

  Copy full SHA for 0bbc7b1

Commits on Jan 3, 2023

• [FLINK-29217][Runtime/Checkpointing] Remove OC's guarantee for OperatorEvent on concurrent checkpoints

  Show description for 9bec3b7
  yunfengzhou-hub

  authored
  9bec3b7

  Copy full SHA for 9bec3b7

Commits on Sep 10, 2022

• [FLINK-29217][tests] Guarantee checkpoint order in OC test

  Show description for 36396f7
  yunfengzhou-hub

  authored
  36396f7

  Copy full SHA for 36396f7

Commits on Sep 6, 2022

• [FLINK-28941][Runtime/Checkpointing] Add concurrent checkpoint support in Operator Coordinator

  Show description for 034030b
  yunfengzhou-hub

  authored
  034030b

  Copy full SHA for 034030b

Commits on Aug 10, 2022

• [FLINK-28900] Fix RecreateOnResetOperatorCoordinatorTest compilation failure

  Show description for dea5f09
  yunfengzhou-hub

  authored
  dea5f09

  Copy full SHA for dea5f09

Commits on Aug 9, 2022

• [FLINK-28606][Runtime/Checkpointing] Refractor coordination tests with JUnit5 Assertions

  

  yunfengzhou-hub

  authored and

  lindong28

  committed
  7be6783

  Copy full SHA for 7be6783

• [FLINK-28606][Runtime/Checkpointing] Preserve consistency of OperatorEvent from OperatorCoordinator to subtasks

  

  yunfengzhou-hub

  authored and

  lindong28

  committed
  1486743

  Copy full SHA for 1486743