You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pr...@apache.org on 2018/07/02 21:48:20 UTC
hive git commit: HIVE-20059: Hive streaming should try shade prefix
unconditionally on exception (Prasanth Jayachandran reviewed by Vineet Garg)
Repository: hive
Updated Branches:
refs/heads/master d83a0be98 -> 1cedb1209
HIVE-20059: Hive streaming should try shade prefix unconditionally on exception (Prasanth Jayachandran reviewed by Vineet Garg)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/1cedb120
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/1cedb120
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/1cedb120
Branch: refs/heads/master
Commit: 1cedb120954679844473fe65ec755ee0f6a6e37e
Parents: d83a0be
Author: Prasanth Jayachandran <pr...@apache.org>
Authored: Mon Jul 2 14:47:47 2018 -0700
Committer: Prasanth Jayachandran <pr...@apache.org>
Committed: Mon Jul 2 14:47:47 2018 -0700
----------------------------------------------------------------------
.../src/java/org/apache/hive/streaming/AbstractRecordWriter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/1cedb120/streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java
----------------------------------------------------------------------
diff --git a/streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java b/streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java
index 281f280..2980028 100644
--- a/streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java
+++ b/streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java
@@ -162,7 +162,7 @@ public abstract class AbstractRecordWriter implements RecordWriter {
try {
this.acidOutputFormat = (AcidOutputFormat<?, ?>) ReflectionUtils
.newInstance(JavaUtils.loadClass(outFormatName), conf);
- } catch (ClassNotFoundException e) {
+ } catch (Exception e) {
String shadePrefix = conf.getVar(HiveConf.ConfVars.HIVE_CLASSLOADER_SHADE_PREFIX);
if (shadePrefix != null && !shadePrefix.trim().isEmpty()) {
try {