lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2674] hudi hive reader should not print read values. (#3910)

Browse Source
This commit is contained in:
xiarixiaoyao
2021-11-03 11:10:18 +08:00
committed by GitHub
parent b12a25b0b1
commit 5517d292f9
1 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieCombineRealtimeRecordReader.java
View File

@@ -20,7 +20,6 @@ package org.apache.hudi.hadoop.realtime;
import org.apache.hudi.common.util.ValidationUtils; import org.apache.hudi.common.util.ValidationUtils;
import org.apache.hudi.hadoop.hive.HoodieCombineRealtimeFileSplit; import org.apache.hudi.hadoop.hive.HoodieCombineRealtimeFileSplit;
import org.apache.hudi.hadoop.utils.HoodieRealtimeRecordReaderUtils;
import org.apache.hadoop.hive.ql.io.IOContextMap; import org.apache.hadoop.hive.ql.io.IOContextMap;
import org.apache.hadoop.io.ArrayWritable; import org.apache.hadoop.io.ArrayWritable;
@@ -66,8 +65,6 @@ public class HoodieCombineRealtimeRecordReader implements RecordReader<NullWrita
@Override @Override
public boolean next(NullWritable key, ArrayWritable value) throws IOException { public boolean next(NullWritable key, ArrayWritable value) throws IOException {
if (this.currentRecordReader.next(key, value)) { if (this.currentRecordReader.next(key, value)) {
LOG.info("Reading from record reader");
LOG.info(HoodieRealtimeRecordReaderUtils.arrayWritableToString(value));
return true; return true;
} else if (recordReaders.size() > 0) { } else if (recordReaders.size() > 0) {
this.currentRecordReader.close(); this.currentRecordReader.close();