Member since
09-03-2021
4
Posts
0
Kudos Received
0
Solutions
07-13-2022
11:44 PM
All Cloudera Data Engineering jobs run into error with this error. This gets stuck in infinite loop to retry the operation. Please find the error stacktrace below: 22/07/14 06:30:55 INFO HadoopFSDelegationTokenProvider: Renewal interval is adjusted from 0 - 1657780255837 = -1657780255837 to 86400000 for token S3ADelegationToken/IDBroker 22/07/14 06:30:56 INFO HiveConf: Found configuration file file:/opt/hadoop/conf/hive-site.xml 22/07/14 06:30:57 WARN HiveServer2CredentialProvider: Failed to get HS2 delegation token java.util.NoSuchElementException: spark.sql.hive.hiveserver2.jdbc.url at org.apache.spark.SparkConf$$anonfun$get$1.apply(SparkConf.scala:246) at org.apache.spark.SparkConf$$anonfun$get$1.apply(SparkConf.scala:246) at scala.Option.getOrElse(Option.scala:121) at org.apache.spark.SparkConf.get(SparkConf.scala:246) at com.hortonworks.spark.deploy.yarn.security.HiveServer2CredentialProvider.obtainCredentials(HiveServer2CredentialProvider.scala:59) at org.apache.spark.deploy.yarn.security.YARNHadoopDelegationTokenManager$$anonfun$5.apply(YARNHadoopDelegationTokenManager.scala:61) at org.apache.spark.deploy.yarn.security.YARNHadoopDelegationTokenManager$$anonfun$5.apply(YARNHadoopDelegationTokenManager.scala:59) at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241) at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241) at scala.collection.Iterator$class.foreach(Iterator.scala:891) at scala.collection.AbstractIterator.foreach(Iterator.scala:1334) at scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206) at scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241) at scala.collection.AbstractTraversable.flatMap(Traversable.scala:104) at org.apache.spark.deploy.yarn.security.YARNHadoopDelegationTokenManager.obtainDelegationTokens(YARNHadoopDelegationTokenManager.scala:59) at org.apache.spark.deploy.security.HadoopDelegationTokenManager$$anon$4.run(HadoopDelegationTokenManager.scala:254) at org.apache.spark.deploy.security.HadoopDelegationTokenManager$$anon$4.run(HadoopDelegationTokenManager.scala:252) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1898) at org.apache.spark.deploy.security.HadoopDelegationTokenManager.obtainTokensAndScheduleRenewal(HadoopDelegationTokenManager.scala:252) at org.apache.spark.deploy.security.HadoopDelegationTokenManager.org$apache$spark$deploy$security$HadoopDelegationTokenManager$$updateTokensTask(HadoopDelegationTokenManager.scala:226) at org.apache.spark.deploy.security.HadoopDelegationTokenManager.start(HadoopDelegationTokenManager.scala:128) at org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend$$anonfun$start$1.apply(CoarseGrainedSchedulerBackend.scala:407) at org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend$$anonfun$start$1.apply(CoarseGrainedSchedulerBackend.scala:404) at scala.Option.foreach(Option.scala:257) at org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend.start(CoarseGrainedSchedulerBackend.scala:404) at org.apache.spark.scheduler.cluster.YarnClientSchedulerBackend.start(YarnClientSchedulerBackend.scala:46) at org.apache.spark.scheduler.TaskSchedulerImpl.start(TaskSchedulerImpl.scala:191) at org.apache.spark.SparkContext.<init>(SparkContext.scala:514) at org.apache.spark.SparkContext$.getOrCreate(SparkContext.scala:2553) at org.apache.spark.sql.SparkSession$Builder$$anonfun$7.apply(SparkSession.scala:939) at org.apache.spark.sql.SparkSession$Builder$$anonfun$7.apply(SparkSession.scala:930) at scala.Option.getOrElse(Option.scala:121) at org.apache.spark.sql.SparkSession$Builder.getOrCreate(SparkSession.scala:930) at template.spark.InitSpark$class.$init$(InitSpark.scala:11) at template.spark.SimpleApp$.<init>(SimpleApp.scala:6) at template.spark.SimpleApp$.<clinit>(SimpleApp.scala) at template.spark.SimpleApp.main(SimpleApp.scala) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) at org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:858) at org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:161) at org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:184) at org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:86) at org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:933) at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:942) at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) 22/07/14 06:30:57 INFO HiveStreamingCredentialProvider: Obtaining delegation token (secure metastore) for hive streaming.. 22/07/14 06:30:57 INFO HiveStreamingCredentialProvider: Getting Hive delegation token for user.kk/cluster-6vfglrb7.dex.cloudera.site@PTY-CDP7.FD9S-2BVH.CLOUDERA.SITE against hive/_HOST@PTY-CDP7.FD9S-2BVH.CLOUDERA.SITE at thrift://pty-dl726-master0.pty-cdp7.fd9s-2bvh.cloudera.site:9083 22/07/14 06:30:57 INFO HiveMetaStoreClient: HMS client filtering is enabled. 22/07/14 06:30:57 INFO HiveMetaStoreClient: Trying to connect to metastore with URI thrift://pty-dl726-master0.pty-cdp7.fd9s-2bvh.cloudera.site:9083 22/07/14 06:30:57 INFO HiveMetaStoreClient: HMSC::open(): Could not find delegation token. Creating KERBEROS-based thrift connection. 22/07/14 06:30:57 INFO HiveMetaStoreClient: Opened a connection to metastore, current connections: 1 22/07/14 06:30:57 INFO HiveMetaStoreClient: Connected to metastore. 22/07/14 06:30:57 INFO HiveStreamingCredentialProvider: Added delegation token (secure metastore) for hive streaming: Kind: HIVE_DELEGATION_TOKEN, Service: , Ident: 00 52 6b 72 69 73 68 6e 61 2e 6b 61 73 68 69 76 2f 63 6c 75 73 74 65 72 2d 36 76 66 67 6c 72 62 37 2e 64 65 78 2e 63 6c 6f 75 64 65 72 61 2e 73 69 74 65 40 50 54 59 2d 43 44 50 37 2e 46 44 39 53 2d 32 42 56 48 2e 43 4c 4f 55 44 45 52 41 2e 53 49 54 45 04 68 69 76 65 52 6b 72 69 73 68 6e 61 2e 6b 61 73 68 69 76 2f 63 6c 75 73 74 65 72 2d 36 76 66 67 6c 72 62 37 2e 64 65 78 2e 63 6c 6f 75 64 65 72 61 2e 73 69 74 65 40 50 54 59 2d 43 44 50 37 2e 46 44 39 53 2d 32 42 56 48 2e 43 4c 4f 55 44 45 52 41 2e 53 49 54 45 8a 01 81 fb 67 41 f5 8a 01 82 1f 73 c5 f5 02 01 alias: HIVE_DELEGATION_TOKEN 22/07/14 06:30:57 INFO HiveMetaStoreClient: Closed a connection to metastore, current connections: 0 22/07/14 06:30:57 INFO YARNHadoopDelegationTokenManager: Calculated delay on renewal is 64798887, based on next renewal 1657866655793 and the ratio 0.75, and current time 1657780257276 22/07/14 06:30:57 INFO YARNHadoopDelegationTokenManager: Scheduling renewal in 18.0 h. 22/07/14 06:30:57 INFO YARNHadoopDelegationTokenManager: Updating delegation tokens. 22/07/14 06:30:57 INFO SparkHadoopUtil: Updating delegation tokens for current user. 22/07/14 06:30:57 INFO SparkHadoopUtil: Updating delegation tokens for current user. 22/07/14 06:30:57 INFO Utils: Using initial executors = 2, max of spark.dynamicAllocation.initialExecutors, spark.dynamicAllocation.minExecutors and spark.executor.instances 22/07/14 06:30:57 INFO RMProxy: Connecting to ResourceManager at /0.0.0.0:8032 22/07/14 06:30:58 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 0 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:30:59 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 1 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:00 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 2 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:01 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 3 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:02 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 4 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:03 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 5 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:04 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 6 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:05 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 7 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:06 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 8 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:07 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 9 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:08 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 0 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS) 22/07/14 06:31:09 INFO Client: Retrying connect to server: 0.0.0.0/0.0.0.0:8032. Already tried 1 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS)
... View more
Labels: