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