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 void init(StreamingConnection conn, long minWriteId, long maxWriteId) thr 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 {