apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CELEBORN-339][FLINK] Should ignore readdata's backlog. (#1275)

Browse Source
This commit is contained in:
Ethan Feng 2023-02-24 17:31:26 +08:00 committed by GitHub
parent a7587c3fe7
commit da292fa369
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java
View File

@ -134,10 +134,6 @@ public class RemoteBufferStreamReader extends CreditListener {
readData.body().release();
return;
}
int backLogInData = readData.getBacklog();
if (backLogInData > 0) {
backlogReceived(backLogInData);
}
dataListener.accept(readData.getFlinkBuffer());
}
}