HIVE-28965: tez.DagUtils: Failed to add credential supplier, ClassNotFoundException: org.apache.hadoop.hive.kafka.KafkaDagCredentialSupplier

KiranVelumuri · KiranVelumuri · commit 8a6b65b4b5f9 · 2025-09-17T18:47:22.000+05:30
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
@@ -313,7 +313,7 @@ private static List<DagCredentialSupplier> defaultCredentialSuppliers() {
         Class<? extends DagCredentialSupplier> c = Class.forName(s).asSubclass(DagCredentialSupplier.class);
         dagSuppliers.add(c.getConstructor().newInstance());
       } catch (ReflectiveOperationException e) {
-        LOG.error("Failed to add credential supplier", e);
+        LOG.warn("Failed to add credential supplier: {}", s);
       }
     }
     return dagSuppliers;

Original file line number	Diff line number	Diff line change
`@@ -313,7 +313,7 @@ private static List<DagCredentialSupplier> defaultCredentialSuppliers() {`
`313`	`313`	`Class<? extends DagCredentialSupplier> c = Class.forName(s).asSubclass(DagCredentialSupplier.class);`
`314`	`314`	`dagSuppliers.add(c.getConstructor().newInstance());`
`315`	`315`	`} catch (ReflectiveOperationException e) {`
`316`		`- LOG.error("Failed to add credential supplier", e);`
	`316`	`+ LOG.warn("Failed to add credential supplier: {}", s);`
`317`	`317`	`}`
`318`	`318`	`}`
`319`	`319`	`return dagSuppliers;`