[flink-benchmarks] 01/04: [hotfix] Fix a typo in RecordSource

[dw...@apache.org]

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 <dw...@apache.org>
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;
         }