(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 release-1.19
in repository https://gitbox.apache.org/repos/asf/flink.git

commit db051086b3b36f8b94e38fb7c656d21ad32d1b86
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