You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2015/03/13 23:46:07 UTC
svn commit: r1666600 - in /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql:
exec/DemuxOperator.java
optimizer/listbucketingpruner/ListBucketingPruner.java
Author: gates
Date: Fri Mar 13 22:46:07 2015
New Revision: 1666600
URL: http://svn.apache.org/r1666600
Log:
HIVE-9944 Convert array[] to string properly in log messages (Alexander Pivovarov via Alan Gates)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/DemuxOperator.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/listbucketingpruner/ListBucketingPruner.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/DemuxOperator.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/DemuxOperator.java?rev=1666600&r1=1666599&r2=1666600&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/DemuxOperator.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/DemuxOperator.java Fri Mar 13 22:46:07 2015
@@ -20,6 +20,7 @@ package org.apache.hadoop.hive.ql.exec;
import java.io.Serializable;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
@@ -177,7 +178,7 @@ public class DemuxOperator extends Opera
newChildOperatorsTag[i] = toArray(childOperatorTags);
}
if (isLogInfoEnabled) {
- LOG.info("newChildOperatorsTag " + newChildOperatorsTag);
+ LOG.info("newChildOperatorsTag " + Arrays.toString(newChildOperatorsTag));
}
initializeChildren(hconf);
}
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/listbucketingpruner/ListBucketingPruner.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/listbucketingpruner/ListBucketingPruner.java?rev=1666600&r1=1666599&r2=1666600&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/listbucketingpruner/ListBucketingPruner.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/listbucketingpruner/ListBucketingPruner.java Fri Mar 13 22:46:07 2015
@@ -19,6 +19,7 @@
package org.apache.hadoop.hive.ql.optimizer.listbucketingpruner;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.Set;
@@ -190,7 +191,7 @@ public class ListBucketingPruner impleme
finalPaths = execute(ctx, part, pruner);
} catch (SemanticException e) {
// Use full partition path for error case.
- LOG.warn("Using full partition scan :" + part.getPath() + ".", e);
+ LOG.warn("Using full partition scan :" + Arrays.toString(part.getPath()) + ".", e);
finalPaths = part.getPath();
}
@@ -215,7 +216,7 @@ public class ListBucketingPruner impleme
if (ListBucketingPrunerUtils.isUnknownState(pruner)) {
// Use full partition path for error case.
LOG.warn("List bucketing pruner is either null or in unknown state "
- + " so that it uses full partition scan :" + part.getPath());
+ + " so that it uses full partition scan :" + Arrays.toString(part.getPath()));
finalPaths = part.getPath();
} else {
// Retrieve skewed columns.
@@ -357,7 +358,7 @@ public class ListBucketingPruner impleme
private static Path[] generateFinalPath(Partition part, List<Path> selectedPaths) {
Path[] finalPaths;
if (selectedPaths.size() == 0) {
- LOG.warn("Using full partition scan :" + part.getPath() + ".");
+ LOG.warn("Using full partition scan :" + Arrays.toString(part.getPath()) + ".");
finalPaths = part.getPath();
} else {
finalPaths = selectedPaths.toArray(new Path[0]);