diff --git common/src/java/org/apache/hadoop/hive/common/JavaUtils.java common/src/java/org/apache/hadoop/hive/common/JavaUtils.java index 75c07b41b2..04faa9c2ab 100644 --- common/src/java/org/apache/hadoop/hive/common/JavaUtils.java +++ common/src/java/org/apache/hadoop/hive/common/JavaUtils.java @@ -228,14 +228,26 @@ public boolean accept(Path path) { @Override public boolean accept(Path path) { String name = path.getName(); - if (!name.startsWith(DELTA_PREFIX + "_")) return false; - String idStr = name.substring(DELTA_PREFIX.length() + 1, DELTA_PREFIX.length() + 1 + DELTA_DIGITS_LEN); - try { - Long.parseLong(idStr); - } catch (NumberFormatException ex) { - return false; + if (name.startsWith(DELTA_PREFIX + "_")) { + String idStr = name.substring(DELTA_PREFIX.length() + 1, + DELTA_PREFIX.length() + 1 + DELTA_DIGITS_LEN); + try { + Long.parseLong(idStr); + } catch (NumberFormatException ex) { + return false; + } + return true; } - return true; + if (name.startsWith(BASE_PREFIX + "_")) { + String idStr = name.substring(BASE_PREFIX.length() + 1); + try { + Long.parseLong(idStr); + } catch (NumberFormatException ex) { + return false; + } + return true; + } + return false; } } }