diff --git a/omnioperator/omniop-hive-extension/src/main/java/com/huawei/boostkit/hive/reader/OmniOrcRecordReader.java b/omnioperator/omniop-hive-extension/src/main/java/com/huawei/boostkit/hive/reader/OmniOrcRecordReader.java
index d0fbf3f0b5602585546f4e6e535151d0d35228bb..bb63e7581c1c34bcae600d3bf921656c8317530d 100644
--- a/omnioperator/omniop-hive-extension/src/main/java/com/huawei/boostkit/hive/reader/OmniOrcRecordReader.java
+++ b/omnioperator/omniop-hive-extension/src/main/java/com/huawei/boostkit/hive/reader/OmniOrcRecordReader.java
@@ -95,11 +95,8 @@ public class OmniOrcRecordReader implements RecordReader<NullWritable, VecBatchW
     OmniOrcRecordReader(Configuration conf, FileSplit split) throws IOException {
         TypeDescription schema = getDesiredRowTypeDescr(conf, false, Integer.MAX_VALUE);
         OrcConf.MAPRED_INPUT_SCHEMA.setString(conf, schema.toString());
-        org.apache.orc.Reader.Options options = buildOptions(conf, split.getStart(), split.getLength());
         included = getReadColumnIDs(conf);
         TypeDescription requiredSchema = getRequiredSchema(schema);
-        options.schema(requiredSchema);
-        options.include(null);
         typeIds = new int[included.size()];
         for (int i = 0; i < requiredSchema.getChildren().size(); i++) {
             TypeDescription typeDescription = requiredSchema.getChildren().get(i);
@@ -114,15 +111,14 @@ public class OmniOrcRecordReader implements RecordReader<NullWritable, VecBatchW
                         .get(i).getCategory()).getId().toValue();
             }
         }
-        OrcFile.ReaderOptions readerOptions = OrcFile.readerOptions(conf)
-                .maxLength(OrcConf.MAX_FILE_LENGTH.getLong(conf)).filesystem(split.getPath().getFileSystem(conf));
+
+        this.offset = split.getStart();
+        this.length = split.getLength();
         recordReader = new OrcColumnarBatchScanReader();
-        recordReader.initializeReaderJava(split.getPath().toUri(), readerOptions);
-        recordReader.initializeRecordReaderJava(options);
+        recordReader.initializeReaderJava(split.getPath().toUri());
+        recordReader.initializeRecordReaderJava(this.offset, this.length, requiredSchema);
         recordReader.initBatchJava(BATCH);
         vecs = new Vec[included.size()];
-        this.offset = split.getStart();
-        this.length = split.getLength();
         this.stats = new SerDeStats();
         Utilities.getMapWork(conf).getAliasToWork().values().forEach(op -> {
             if (op.getType().equals(OperatorType.TABLESCAN)) {
@@ -136,23 +132,6 @@ public class OmniOrcRecordReader implements RecordReader<NullWritable, VecBatchW
         return Arrays.stream(skips.split(",")).map(Integer::parseInt).distinct().collect(Collectors.toList());
     }
 
-    private org.apache.orc.Reader.Options buildOptions(Configuration conf, long start, long length) {
-        org.apache.orc.Reader.Options options = (new org.apache.orc.Reader.Options(conf)).range(start, length)
-                .useZeroCopy(OrcConf.USE_ZEROCOPY.getBoolean(conf))
-                .skipCorruptRecords(OrcConf.SKIP_CORRUPT_DATA.getBoolean(conf))
-                .tolerateMissingSchema(OrcConf.TOLERATE_MISSING_SCHEMA.getBoolean(conf));
-        String kryoSarg = OrcConf.KRYO_SARG.getString(conf);
-        String sargColumns = OrcConf.SARG_COLUMNS.getString(conf);
-        if (kryoSarg != null && sargColumns != null) {
-            byte[] sargBytes = Base64.decodeBase64(kryoSarg);
-            SearchArgument sarg = (SearchArgument) (new Kryo()).readObject(new Input(sargBytes),
-                    SearchArgumentImpl.class);
-            options.searchArgument(sarg, sargColumns.split(","));
-            sarg.getExpression().toString();
-        }
-        return options;
-    }
-
     private TypeDescription getRequiredSchema(TypeDescription schema) {
         Set<Integer> requiredIds = new HashSet<>(included);
         TypeDescription result = TypeDescription.createStruct();
diff --git a/omnioperator/omniop-hive-extension/src/main/java/com/huawei/boostkit/hive/reader/OrcColumnarBatchScanReader.java b/omnioperator/omniop-hive-extension/src/main/java/com/huawei/boostkit/hive/reader/OrcColumnarBatchScanReader.java
index 89c40ed4cbd101a80b7cb7df668521b3eb98cd03..3d5e6851ccf3eef8604608c82a79b8ba87d50e74 100644
--- a/omnioperator/omniop-hive-extension/src/main/java/com/huawei/boostkit/hive/reader/OrcColumnarBatchScanReader.java
+++ b/omnioperator/omniop-hive-extension/src/main/java/com/huawei/boostkit/hive/reader/OrcColumnarBatchScanReader.java
@@ -56,6 +56,8 @@ public class OrcColumnarBatchScanReader {
 
     public OrcColumnarBatchJniReader jniReader;
 
+    private TypeDescription requiredSchema;
+
     public OrcColumnarBatchScanReader() {
         jniReader = new OrcColumnarBatchJniReader();
     }
@@ -149,13 +151,9 @@ public class OrcColumnarBatchScanReader {
      * @param options split file options
      * @return long
      */
-    public long initializeReaderJava(URI uri, ReaderOptions options) {
+    public long initializeReaderJava(URI uri) {
         JSONObject job = new JSONObject();
-        if (options.getOrcTail() == null) {
-            job.put("serializedTail", "");
-        } else {
-            job.put("serializedTail", options.getOrcTail().getSerializedTail().toString());
-        }
+        job.put("serializedTail", "");
         job.put("tailLocation", 9223372036854775807L);
         job.put("scheme", uri.getScheme() == null ? "" : uri.getScheme());
         job.put("host", uri.getHost() == null ? "" : uri.getHost());
@@ -174,31 +172,15 @@ public class OrcColumnarBatchScanReader {
      * @param options split file options
      * @return long
      */
-    public long initializeRecordReaderJava(Options options) {
+    public long initializeRecordReaderJava(long offset, long length, TypeDescription requiredSchema) {
+        this.requiredSchema = requiredSchema;
         JSONObject job = new JSONObject();
-        if (options.getInclude() == null) {
-            job.put("include", "");
-        } else {
-            job.put("include", options.getInclude().toString());
-        }
-        job.put("offset", options.getOffset());
-        job.put("length", options.getLength());
-        if (options.getSearchArgument() != null) {
-            LOGGER.debug("SearchArgument: {}", options.getSearchArgument().toString());
-            JSONObject jsonexpressionTree = getSubJson(options.getSearchArgument().getExpression());
-            job.put("expressionTree", jsonexpressionTree);
-            JSONObject jsonleaves = getLeavesJson(options.getSearchArgument().getLeaves(), options.getSchema());
-            job.put("leaves", jsonleaves);
-        }
+        job.put("offset", offset);
+        job.put("length", length);
 
-        List<String> allCols;
-        if (options.getColumnNames() == null) {
-            allCols = Arrays.asList(jniReader.getAllColumnNames(reader));
-        } else {
-            allCols = Arrays.asList(options.getColumnNames());
-        }
+        List<String> allCols = Arrays.asList(jniReader.getAllColumnNames(reader));
         ArrayList<String> colToInclu = new ArrayList<String>();
-        List<String> optionField = options.getSchema().getFieldNames();
+        List<String> optionField = requiredSchema.getFieldNames();
         colsToGet = new int[optionField.size()];
         realColsCnt = 0;
         for (int i = 0; i < optionField.size(); i++) {
@@ -251,6 +233,7 @@ public class OrcColumnarBatchScanReader {
         int rowCount = 0;
         for (int i = 0; i < vectorCnt; i++) {
             if (colsToGet[i] != 0) {
+                rowCount = (int) rtn;
                 vecList[i] = getNullVec(DataType.DataTypeId.values()[typeIds[nativeGetId]], rowCount);
                 nativeGetId++;
                 continue;
@@ -292,7 +275,6 @@ public class OrcColumnarBatchScanReader {
                 }
             }
             nativeGetId++;
-            rowCount = vecList[i].getSize();
         }
         return (int) rtn;
     }