(flink) 01/04: [hotfix] Make MockSourceSplit#addRecord calls chainable

[pnowojski]

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

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

commit 8df0466aeadbf44999e56afc4267b0eedc0e0d30
Author: Piotr Nowojski <piotr.nowoj...@gmail.com>
AuthorDate: Wed May 15 17:17:59 2024 +0200

    [hotfix] Make MockSourceSplit#addRecord calls chainable
---
 .../org/apache/flink/api/connector/source/mocks/MockSourceSplit.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/MockSourceSplit.java
 
b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/MockSourceSplit.java
index c2578596809..c45add729cd 100644
--- 
a/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/MockSourceSplit.java
+++ 
b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/MockSourceSplit.java
@@ -84,10 +84,11 @@ public class MockSourceSplit implements SourceSplit, 
Serializable {
     }
 
     /** Add a record to this split. */
-    public void addRecord(int record) {
+    public MockSourceSplit addRecord(int record) {
         if (!records.offer(record)) {
             throw new IllegalStateException("Failed to add record to split.");
         }
+        return this;
     }
 
     @Override