Я использую Kerberized Docker имел oop образ HDP 2.2 для запуска моих тестовых случаев. но при запуске я сталкиваюсь с проблемой с Kerberos. Найдите трассировку стека
java.io.IOException: DestHost:destPort master:8020 , LocalHost:localPort C02Y33A4JGH5/192.168.1.35:0. Failed on local exception: java.io.IOException: Couldn't set up IO streams: java.lang.IllegalArgumentException: Failed to specify server's Kerberos principal name
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at org.apache.hadoop.net.NetUtils.wrapWithMessage(NetUtils.java:833)
at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:808)
at org.apache.hadoop.ipc.Client.getRpcResponse(Client.java:1549)
at org.apache.hadoop.ipc.Client.call(Client.java:1491)
at org.apache.hadoop.ipc.Client.call(Client.java:1388)
at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:233)
at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:118)
at com.sun.proxy.$Proxy12.mkdirs(Unknown Source)
at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.mkdirs(ClientNamenodeProtocolTranslatorPB.java:660)
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.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:422)
at org.apache.hadoop.io.retry.RetryInvocationHandler$Call.invokeMethod(RetryInvocationHandler.java:165)
at org.apache.hadoop.io.retry.RetryInvocationHandler$Call.invoke(RetryInvocationHandler.java:157)
at org.apache.hadoop.io.retry.RetryInvocationHandler$Call.invokeOnce(RetryInvocationHandler.java:95)
at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:359)
at com.sun.proxy.$Proxy13.mkdirs(Unknown Source)
at org.apache.hadoop.hdfs.DFSClient.primitiveMkdir(DFSClient.java:2425)
at org.apache.hadoop.hdfs.DFSClient.mkdirs(DFSClient.java:2401)
at org.apache.hadoop.hdfs.DistributedFileSystem$27.doCall(DistributedFileSystem.java:1318)
at org.apache.hadoop.hdfs.DistributedFileSystem$27.doCall(DistributedFileSystem.java:1315)
at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81)
at org.apache.hadoop.hdfs.DistributedFileSystem.mkdirsInternal(DistributedFileSystem.java:1332)
at org.apache.hadoop.hdfs.DistributedFileSystem.mkdirs(DistributedFileSystem.java:1307)
at org.apache.hadoop.fs.FileSystem.mkdirs(FileSystem.java:2275)
at org.apache.spark.SparkContext$$anonfun$setCheckpointDir$2.apply(SparkContext.scala:2350)
at org.apache.spark.SparkContext$$anonfun$setCheckpointDir$2.apply(SparkContext.scala:2347)
at scala.Option.map(Option.scala:146)
at org.apache.spark.SparkContext.setCheckpointDir(SparkContext.scala:2347)
at com.agoda.ml.spark.CheckpointDirectory.set(Checkpoints.scala:63)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.start(SparkETLTest.scala:116)
at com.agoda.ml.spark.PerTest$$anonfun$4.apply$mcV$sp(SparkTest.scala:226)
at org.scalatest.FixtureMixin$$anonfun$_runBefore$2.apply(FixtureMixin.scala:65)
at org.scalatest.FixtureMixin$$anonfun$_runBefore$2.apply(FixtureMixin.scala:65)
at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:73)
at scala.collection.mutable.MutableList.foreach(MutableList.scala:30)
at org.scalatest.FixtureMixin$class._runBefore(FixtureMixin.scala:65)
at org.scalatest.FixtureMixin$class.withFixture(FixtureMixin.scala:83)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.withFixture(SparkETLTest.scala:49)
at org.scalatest.FunSuiteLike$class.invokeWithFixture$1(FunSuiteLike.scala:183)
at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:196)
at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:196)
at org.scalatest.SuperEngine.runTestImpl(Engine.scala:289)
at org.scalatest.FunSuiteLike$class.runTest(FunSuiteLike.scala:196)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.org$scalatest$OneInstancePerTest$$super$runTest(SparkETLTest.scala:49)
at org.scalatest.OneInstancePerTest$class.runTest(OneInstancePerTest.scala:131)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.runTest(SparkETLTest.scala:49)
at org.scalatest.OneInstancePerTest$class.runTests(OneInstancePerTest.scala:181)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.runTests(SparkETLTest.scala:49)
at org.scalatest.Suite$class.run(Suite.scala:1147)
at org.scalatest.FunSuite.org$scalatest$FunSuiteLike$$super$run(FunSuite.scala:1560)
at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:233)
at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:233)
at org.scalatest.SuperEngine.runImpl(Engine.scala:521)
at org.scalatest.FunSuiteLike$class.run(FunSuiteLike.scala:233)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.org$scalatest$BeforeAndAfterAll$$super$run(SparkETLTest.scala:49)
at org.scalatest.BeforeAndAfterAll$class.liftedTree1$1(BeforeAndAfterAll.scala:213)
at org.scalatest.BeforeAndAfterAll$class.run(BeforeAndAfterAll.scala:210)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.org$scalatest$FixtureMixin$$super$run(SparkETLTest.scala:49)
at org.scalatest.FixtureMixin$class.run(FixtureMixin.scala:97)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.run(SparkETLTest.scala:49)
at org.scalatest.OneInstancePerTest$class.runTest(OneInstancePerTest.scala:128)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.runTest(SparkETLTest.scala:49)
at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:229)
at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:229)
at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:396)
at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:384)
at scala.collection.immutable.List.foreach(List.scala:381)
at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:384)
at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:379)
at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:461)
at org.scalatest.FunSuiteLike$class.runTests(FunSuiteLike.scala:229)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.org$scalatest$OneInstancePerTest$$super$runTests(SparkETLTest.scala:49)
at org.scalatest.OneInstancePerTest$class.runTests(OneInstancePerTest.scala:188)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.runTests(SparkETLTest.scala:49)
at org.scalatest.Suite$class.run(Suite.scala:1147)
at org.scalatest.FunSuite.org$scalatest$FunSuiteLike$$super$run(FunSuite.scala:1560)
at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:233)
at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:233)
at org.scalatest.SuperEngine.runImpl(Engine.scala:521)
at org.scalatest.FunSuiteLike$class.run(FunSuiteLike.scala:233)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.org$scalatest$BeforeAndAfterAll$$super$run(SparkETLTest.scala:49)
at org.scalatest.BeforeAndAfterAll$class.liftedTree1$1(BeforeAndAfterAll.scala:213)
at org.scalatest.BeforeAndAfterAll$class.run(BeforeAndAfterAll.scala:210)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.org$scalatest$FixtureMixin$$super$run(SparkETLTest.scala:49)
at org.scalatest.FixtureMixin$class.run(FixtureMixin.scala:97)
at com.agoda.adp.hadoop.etl.spark.testbase.SparkETLTest.run(SparkETLTest.scala:49)
at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:314)
at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:480)
at sbt.ForkMain$Run$2.call(ForkMain.java:301)
at sbt.ForkMain$Run$2.call(ForkMain.java:291)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.io.IOException: Couldn't set up IO streams: java.lang.IllegalArgumentException: Failed to specify server's Kerberos principal name
at org.apache.hadoop.ipc.Client$Connection.setupIOstreams(Client.java:876)
at org.apache.hadoop.ipc.Client$Connection.access$3800(Client.java:421)
at org.apache.hadoop.ipc.Client.getConnection(Client.java:1606)
at org.apache.hadoop.ipc.Client.call(Client.java:1435)
... 93 common frames omitted
Caused by: java.lang.IllegalArgumentException: Failed to specify server's Kerberos principal name
at org.apache.hadoop.security.SaslRpcClient.getServerPrincipal(SaslRpcClient.java:327)
at org.apache.hadoop.security.SaslRpcClient.createSaslClient(SaslRpcClient.java:234)
at org.apache.hadoop.security.SaslRpcClient.selectSaslClient(SaslRpcClient.java:160)
at org.apache.hadoop.security.SaslRpcClient.saslConnect(SaslRpcClient.java:390)
at org.apache.hadoop.ipc.Client$Connection.setupSaslConnection(Client.java:627)
at org.apache.hadoop.ipc.Client$Connection.access$2300(Client.java:421)
at org.apache.hadoop.ipc.Client$Connection$2.run(Client.java:814)
at org.apache.hadoop.ipc.Client$Connection$2.run(Client.java:810)
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:1730)
at org.apache.hadoop.ipc.Client$Connection.setupIOstreams(Client.java:810)
... 96 common frames omitted
У меня есть запись полного доменного имени в файле / etc / hosts. я также установил dfs.namenode.kerberos.principal.pattern = "*". Но все же я получаю проблему. Может ли кто-нибудь помочь в этом.