[hotfix][formats][parquet] Fix argument references

baijian · Mar 29, 2021 · 083d022 · 083d022
1 parent 5b3a8f3
commit 083d022
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetRecordReader.java b/...ink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetRecordReader.java
@@ -82,9 +82,9 @@ public class ParquetRecordReader<T> {
     private long numRecordsUpToCurrentBlock = 0;
 
     public ParquetRecordReader(ReadSupport<T> readSupport, MessageType readSchema, Filter filter) {
-        this.filter = checkNotNull(filter, "readSupport");
-        this.readSupport = checkNotNull(readSupport, "readSchema");
-        this.readSchema = checkNotNull(readSchema, "filter");
+        this.filter = checkNotNull(filter, "filter");
+        this.readSupport = checkNotNull(readSupport, "readSupport");
+        this.readSchema = checkNotNull(readSchema, "readSchema");
     }
 
     public ParquetRecordReader(ReadSupport<T> readSupport, MessageType readSchema) {