[CELEBORN-2264] Support cancel shuffle when write bytes exceeds threshold

yew1eb · yew1eb · commit d15fecab9a83 · 2026-02-11T11:43:14.000+08:00
diff --git a/common/src/main/proto/TransportMessages.proto b/common/src/main/proto/TransportMessages.proto
@@ -377,6 +377,7 @@ message PbMapperEnd {
   int32 numPartitions = 7;
   repeated int32 crc32PerPartition = 8;
   repeated int64 bytesWrittenPerPartition = 9;
+  int64 bytesWritten = 10;
 }
 
 message PbLocationPushFailedBatches {

Original file line number	Diff line number	Diff line change
`@@ -377,6 +377,7 @@ message PbMapperEnd {`
`377`	`377`	`int32 numPartitions = 7;`
`378`	`378`	`repeated int32 crc32PerPartition = 8;`
`379`	`379`	`repeated int64 bytesWrittenPerPartition = 9;`
	`380`	`+ int64 bytesWritten = 10;`
`380`	`381`	`}`
`381`	`382`
`382`	`383`	`message PbLocationPushFailedBatches {`