[flink] branch master updated: [hotfix][flink-runtime] Fix the typo of RecordingChannelStateWriter class.

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 77c4305eade [hotfix][flink-runtime] Fix the typo of RecordingChannelStateWriter class.
77c4305eade is described below

commit 77c4305eade86fec4cb7ec69727328200242039c
Author: liuzhuang2017 <ju...@outlook.com>
AuthorDate: Tue Nov 8 09:35:11 2022 +0800

    [hotfix][flink-runtime] Fix the typo of RecordingChannelStateWriter class.
---
 .../checkpoint/channel/RecordingChannelStateWriter.java        | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/RecordingChannelStateWriter.java b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/RecordingChannelStateWriter.java
index 2c6605e8c0b..cc58f2d03fe 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/RecordingChannelStateWriter.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/RecordingChannelStateWriter.java
@@ -33,7 +33,7 @@ public class RecordingChannelStateWriter extends MockChannelStateWriter {
     private long lastStartedCheckpointId = -1;
     private long lastFinishedCheckpointId = -1;
     private ListMultimap<InputChannelInfo, Buffer> addedInput = LinkedListMultimap.create();
-    private ListMultimap<ResultSubpartitionInfo, Buffer> adedOutput = LinkedListMultimap.create();
+    private ListMultimap<ResultSubpartitionInfo, Buffer> addedOutput = LinkedListMultimap.create();
 
     public RecordingChannelStateWriter() {
         super(false);
@@ -44,8 +44,8 @@ public class RecordingChannelStateWriter extends MockChannelStateWriter {
         lastFinishedCheckpointId = -1;
         addedInput.values().forEach(Buffer::recycleBuffer);
         addedInput.clear();
-        adedOutput.values().forEach(Buffer::recycleBuffer);
-        adedOutput.clear();
+        addedOutput.values().forEach(Buffer::recycleBuffer);
+        addedOutput.clear();
     }
 
     @Override
@@ -73,7 +73,7 @@ public class RecordingChannelStateWriter extends MockChannelStateWriter {
     public void addOutputData(
             long checkpointId, ResultSubpartitionInfo info, int startSeqNum, Buffer... data) {
         checkCheckpointId(checkpointId);
-        adedOutput.putAll(info, Arrays.asList(data));
+        addedOutput.putAll(info, Arrays.asList(data));
     }
 
     public long getLastStartedCheckpointId() {
@@ -89,6 +89,6 @@ public class RecordingChannelStateWriter extends MockChannelStateWriter {
     }
 
     public ListMultimap<ResultSubpartitionInfo, Buffer> getAddedOutput() {
-        return adedOutput;
+        return addedOutput;
     }
 }