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.
1 parent 389d7fc commit a43ae35Copy full SHA for a43ae35
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