[
https://issues.apache.org/jira/browse/HIVE-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18020865#comment-18020865
]
Kiran Velumuri commented on HIVE-28965:
---------------------------------------
I was getting the same error in logs while running test -
TestBeeLineWithArgs#testRowsAffected. [~dkuzmenko] Could you please tell which
test this error was from?
This error comes from
org.apache.hadoop.hive.ql.exec.tez.DagUtils#defaultCredentialSuppliers when
KafkaDagCredentialSupplier is loaded as plain string. I see from the comment
that this was done so as to avoid compile time dependency on kafka-handler.
Since kafka-handler is included in packaging jars, this issue would not occur
in normal flow.
But for tests, this is not the case. The error subsided when I added
kafka-handler as a dependency in itests/hive-unit. Similarly, I could add this
dependency for that test reported in this Jira. [~zabetak] Please confirm if my
understanding is correct, so I could go ahead with the change. Thank you!
> tez.DagUtils: Failed to add credential supplier, ClassNotFoundException:
> org.apache.hadoop.hive.kafka.KafkaDagCredentialSupplier
> --------------------------------------------------------------------------------------------------------------------------------
>
> Key: HIVE-28965
> URL: https://issues.apache.org/jira/browse/HIVE-28965
> Project: Hive
> Issue Type: Test
> Reporter: Denys Kuzmenko
> Priority: Major
>
> {code}
> 2025-05-20T00:06:24,194 ERROR [main] tez.DagUtils: Failed to add credential
> supplier
> java.lang.ClassNotFoundException:
> org.apache.hadoop.hive.kafka.KafkaDagCredentialSupplier
> at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
> ~[?:1.8.0_262]
> at java.lang.ClassLoader.loadClass(ClassLoader.java:419) ~[?:1.8.0_262]
> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352)
> ~[?:1.8.0_262]
> at java.lang.ClassLoader.loadClass(ClassLoader.java:352) ~[?:1.8.0_262]
> at java.lang.Class.forName0(Native Method) ~[?:1.8.0_262]
> at java.lang.Class.forName(Class.java:264) ~[?:1.8.0_262]
> at
> org.apache.hadoop.hive.ql.exec.tez.DagUtils.defaultCredentialSuppliers(DagUtils.java:313)
> [hive-exec-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
> at
> org.apache.hadoop.hive.ql.exec.tez.DagUtils.<clinit>(DagUtils.java:184)
> [hive-exec-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
> at org.apache.hadoop.hive.ql.plan.TezWork.<init>(TezWork.java:91)
> [hive-exec-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
> at
> org.apache.hadoop.hive.ql.parse.GenTezProcContext.<init>(GenTezProcContext.java:176)
> [hive-exec-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
> at
> org.apache.hadoop.hive.ql.parse.TezCompiler.generateTaskTree(TezCompiler.java:644)
> [hive-exec-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
> at
> org.apache.hadoop.hive.ql.parse.TaskCompiler.compile(TaskCompiler.java:302)
> [hive-exec-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
> at
> org.apache.hadoop.hive.ql.parse.SemanticAnalyzer.compilePlan(SemanticAnalyzer.java:13103)
> [hive-exec-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
