Github user paul-rogers commented on a diff in the pull request: https://github.com/apache/drill/pull/1045#discussion_r156180593 --- Diff: contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/MongoRecordReader.java --- @@ -91,9 +90,9 @@ public MongoRecordReader(MongoSubScan.MongoSubScanSpec subScanSpec, List<SchemaP subScanSpec.getMinFilters(), subScanSpec.getMaxFilters()); buildFilters(subScanSpec.getFilter(), mergedFilters); - enableAllTextMode = fragmentContext.getOptions().getOption(ExecConstants.MONGO_ALL_TEXT_MODE).bool_val; - readNumbersAsDouble = fragmentContext.getOptions().getOption(ExecConstants.MONGO_READER_READ_NUMBERS_AS_DOUBLE).bool_val; - isBsonRecordReader = fragmentContext.getOptions().getOption(ExecConstants.MONGO_BSON_RECORD_READER).bool_val; + enableAllTextMode = fragmentContext.getOptionSet().getOption(ExecConstants.MONGO_ALL_TEXT_MODE).bool_val; + readNumbersAsDouble = fragmentContext.getOptionSet().getOption(ExecConstants.MONGO_READER_READ_NUMBERS_AS_DOUBLE).bool_val; + isBsonRecordReader = fragmentContext.getOptionSet().getOption(ExecConstants.MONGO_BSON_RECORD_READER).bool_val; --- End diff -- More to replace.
---