diff --git itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java index c2b8de2..e29600c 100644 --- itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java +++ itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java @@ -267,7 +267,7 @@ public void initConf() throws Exception { // Plug verifying metastore in for testing. conf.setVar(HiveConf.ConfVars.METASTORE_RAW_STORE_IMPL, - "org.apache.hadoop.hive.metastore.VerifyingObjectStore"); + "org.apache.hadoop.hive.metastore.VerifyingObjectStore"); if (mr != null) { assert dfs != null; @@ -926,7 +926,18 @@ private int executeClientInternal(String commands) { String [] cmds = commands.split(";"); int rc = 0; - for (String command : cmds) { + String command = ""; + for (String oneCmd : cmds) { + if (StringUtils.endsWith(oneCmd, "\\")) { + command += StringUtils.chop(oneCmd) + "\\;"; + continue; + } else { + command += oneCmd; + } + if (StringUtils.isBlank(command)) { + continue; + } + if (isCommandUsedForTesting(command)) { rc = executeTestCommand(command); } else { @@ -936,6 +947,7 @@ private int executeClientInternal(String commands) { if (rc != 0) { break; } + command = ""; } return rc;