我正在设置GeoSpark Python,在安装了所有的先决条件之后,我运行非常基本的代码示例来测试它。在
from pyspark.sql import SparkSession
from geo_pyspark.register import GeoSparkRegistrator
spark = SparkSession.builder.\
getOrCreate()
GeoSparkRegistrator.registerAll(spark)
df = spark.sql("""SELECT st_GeomFromWKT('POINT(6.0 52.0)') as geom""")
df.show()
我试着用python3 basic.py
和spark-submit basic.py
运行它,都会出现以下错误:
我使用的是java8、python3、apachespark2.4,我的JAVA_HOME
设置正确,我运行的是linuxmint19。我的SPARK_HOME
也已设置:
我该怎么解决这个问题?在
目前没有回答
相关问题 更多 >
编程相关推荐