We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 122b25c + a43ae35 commit f95f0d9Copy full SHA for f95f0d9
flinkx-hdfs/flinkx-hdfs-reader/src/main/java/com/dtstack/flinkx/hdfs/reader/HdfsOrcInputFormat.java
@@ -102,6 +102,7 @@ private void openOrcReader(InputSplit inputSplit) throws IOException{
102
numReadCounter = getRuntimeContext().getLongCounter("numRead");
103
HdfsOrcInputSplit hdfsOrcInputSplit = (HdfsOrcInputSplit) inputSplit;
104
OrcSplit orcSplit = hdfsOrcInputSplit.getOrcSplit();
105
+ findCurrentPartition(orcSplit.getPath());
106
recordReader = inputFormat.getRecordReader(orcSplit, conf, Reporter.NULL);
107
key = recordReader.createKey();
108
value = recordReader.createValue();
0 commit comments