.../org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java index f8ea701..4a9c3bc 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java @@ -275,9 +275,7 @@ private boolean hasFilter(int alias) { public void closeOp(boolean abort) throws HiveException { try { if (mapJoinTables == null) { - if (LOG.isDebugEnabled()) { - LOG.debug("mapJoinTables is null"); - } + LOG.debug("mapJoinTables is null"); } else { flushToFile(); } @@ -292,9 +290,7 @@ public void closeOp(boolean abort) throws HiveException { protected void flushToFile() throws IOException, HiveException { // get tmp file URI Path tmpURI = getExecContext().getLocalWork().getTmpPath(); - if (LOG.isInfoEnabled()) { - LOG.info("Temp URI for side table: " + tmpURI); - } + LOG.info("Temp URI for side table: {}", tmpURI); for (byte tag = 0; tag < mapJoinTables.length; tag++) { // get the key and value MapJoinPersistableTableContainer tableContainer = mapJoinTables[tag]; @@ -311,7 +307,7 @@ protected void flushToFile() throws IOException, HiveException { " with group count: " + tableContainer.size() + " into file: " + path); // get the hashtable file and path FileSystem fs = path.getFileSystem(hconf); - ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(fs.create(path), 4096)); + ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(fs.create(path))); try { mapJoinTableSerdes[tag].persist(out, tableContainer); } finally {