2017-12-21 6 views
-2

を取得スパークジョブを提出しながら、私は、IllegalArgumentExceptionを取得していますはIllegalArgumentException

C:\spark\spark-2.2.1-bin-hadoop2.7\hadoop\bin>pyspark 
     Python 2.7.14 (v2.7.14:84471935ed, Sep 16 2017, 20:25:58) [MSC v.1500 64 bit (AMD64)] on win32 
     Type "help", "copyright", "credits" or "license" for more information. 
     Using Spark's default log4j profile: org/apache/spark/log4j-defaults.properties 
     Setting default log level to "WARN". 
     To adjust logging level use sc.setLogLevel(newLevel). For SparkR, use setLogLevel(newLevel). 
     WARNING: An illegal reflective access operation has occurred 
     WARNING: Illegal reflective access by org.apache.hadoop.security.authentication.util.KerberosUtil (file:/C:/spark/spark-2.2.1-bin-hadoop2.7/jars/hadoop-auth-2.7.3.jar) to method sun.security.krb5.Config.getInstance() 
     WARNING: Please consider reporting this to the maintainers of org.apache.hadoop.security.authentication.util.KerberosUtil 
     WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations 
     WARNING: All illegal access operations will be denied in a future release 
     17/12/21 15:48:46 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 
     Traceback (most recent call last): 
      File "C:\spark\spark-2.2.1-bin-hadoop2.7\python\pyspark\shell.py", line 45, in <module> 
      spark = SparkSession.builder\ 
      File "C:\spark\spark-2.2.1-bin-hadoop2.7\python\pyspark\sql\session.py", line 183, in getOrCreate 
      session._jsparkSession.sessionState().conf().setConfString(key, value) 
      File "C:\spark\spark-2.2.1-bin-hadoop2.7\python\lib\py4j-0.10.4-src.zip\py4j\java_gateway.py", line 1133, in __call__ 
      File "C:\spark\spark-2.2.1-bin-hadoop2.7\python\pyspark\sql\utils.py", line 79, in deco 
      raise IllegalArgumentException(s.split(': ', 1)[1], stackTrace) 
     pyspark.sql.utils.IllegalArgumentException: u"Error while instantiating 'org.apache.spark.sql.hive.HiveSessionStateBuilder':" 

/tmp/hive/にあなたの権限を確認し、これらのエラー

+0

例外を考えれば、Hive/Hadoop関連の設定がどこかにあり、Sparkがそれを明らかに使用しているということが問題であると確信しています。あなたのスパークの構成を提供してください。そして、あなたのメッセージをフォーマットしてください。 – luminousmen

答えて

0

を解決する方法を教えてください。 sudo chmod -R 777 /tmp/hive/を使用してください。また、sqlContextを使用してクエリを渡すかどうかを確認してください。それ以外の場合はsparkSessionに変更できます。

+0

返事のためにお返事ありがとうございます。上記のコマンドを使用する場所がわからず、Windows 10マシンでsparkを設定していますが、pysparkを呼び出すと、 count()がエラーpy4jエラーを返すように動作しません。 – Abhishek

+0

CLIでコマンドを発行し、すべてのスパークプロセスを停止し、再度起動して環境変数をチェックする必要があります – Subash

関連する問題