diff --git beeline/src/java/org/apache/hive/beeline/BeeLine.java beeline/src/java/org/apache/hive/beeline/BeeLine.java index 82077cc3a9..65ec560950 100644 --- beeline/src/java/org/apache/hive/beeline/BeeLine.java +++ beeline/src/java/org/apache/hive/beeline/BeeLine.java @@ -1324,7 +1324,16 @@ private int executeFile(String fileName) { } fileStream = fs.open(path); } else { - fileStream = new FileInputStream(fileName); + org.apache.hadoop.fs.Path path = new org.apache.hadoop.fs.Path(fileName); + FileSystem fs; + HiveConf conf = new HiveConf(); + if (!path.toUri().isAbsolute()) { + fs = FileSystem.getLocal(conf); + path = fs.makeQualified(path); + } else { + fs = FileSystem.get(path.toUri(), conf); + } + fileStream = fs.open(path); } return execute(initializeConsoleReader(fileStream), !getOpts().getForce()); } catch (Throwable t) {