This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git
commit 743b98e22bb1b85288d70f07bed290951190f24b Author: Dawid Wysakowicz <[email protected]> AuthorDate: Tue Sep 21 13:39:40 2021 +0200 [hotfix] Fix a typo in RecordSource --- .../java/org/apache/flink/benchmark/operators/RecordSource.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/apache/flink/benchmark/operators/RecordSource.java b/src/main/java/org/apache/flink/benchmark/operators/RecordSource.java index 8d0498f..b2e396d 100644 --- a/src/main/java/org/apache/flink/benchmark/operators/RecordSource.java +++ b/src/main/java/org/apache/flink/benchmark/operators/RecordSource.java @@ -70,7 +70,7 @@ public class RecordSource implements Source<Record, EmptySplit, EmptyEnumeratorS @Override public SourceReader<Record, EmptySplit> createReader(SourceReaderContext readerContext) { - return new RecourdSourceReader(minCheckpoints); + return new RecordSourceReader(minCheckpoints); } @Override @@ -95,12 +95,12 @@ public class RecordSource implements Source<Record, EmptySplit, EmptyEnumeratorS return new EnumeratorVersionedSerializer(); } - public static class RecourdSourceReader implements SourceReader<Record, EmptySplit> { + public static class RecordSourceReader implements SourceReader<Record, EmptySplit> { private final int minCheckpoints; private int numCompletedCheckpoints; private long counter = 0; - public RecourdSourceReader(int minCheckpoints) { + public RecordSourceReader(int minCheckpoints) { this.minCheckpoints = minCheckpoints; }
