cocdkl opened a new issue, #406:
URL: https://github.com/apache/incubator-livy/issues/406
现在已经可以使用scala 2.12.15成功编译livy 0.8.0,但是在使用 spark3.2 及 3.3 以上版本时,pyspark 3.3
可以在yarn启动spark,但是提交不了任务,这是代码:
from pyspark.sql import SparkSession
spark=SparkSession.builder.appName("test").enableHiveSupport().getOrCreate()
spark.sql("show databases").show()
这是问题报错:
23/05/18 14:11:34 INFO BlockManagerMasterEndpoint: Registering block manager
localhost:41641 with 366.3 MiB RAM, BlockManagerId(2, localhost, 41641, None)
23/05/18 14:11:34 INFO SparkEntries: Spark context finished initialization
in 16437ms
23/05/18 14:11:34 INFO SparkEntries: Created Spark session.
23/05/18 14:11:41 ERROR PythonInterpreter: Process has died with 1
23/05/18 14:11:41 ERROR PythonInterpreter: Traceback (most recent call last):
File "/tmp/6067082446938324509", line 722, in <module>
sys.exit(main())
File "/tmp/6067082446938324509", line 570, in main
exec('from pyspark.sql import HiveContext', global_dict)
File "<string>", line 1, in <module>
File
"/home/cocdkl/soft/spark-3.3.0-bin-hadoop3/python/lib/pyspark.zip/pyspark/__init__.py",
line 71
def since(version: Union[str, float]) -> Callable[[F], F]:
^
SyntaxError: invalid syntax
通过hue提交的代码,希望得到解答
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]