[geomesa-users] ClassCastException error in geomesa_pyspark 4.0.5

[zhou lihuang <zlh_0923@xxxxxxxxxxx>]

hello everyone:

I used pyspark to query data in hbase, and the code returned the following exception:

code is as follows:

 

the error message is as below:

java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.spark.rdd.MapPartitionsRDD.f of type scala.Function3 in instance of org.apache.spark.rdd.MapPartitionsRDD

The env is :

geomesa_pyspark: 4.0.5

spark: 3.3.0

python: 3.8

How can I fix this problem now? 

Thank you everyone.

Best Regards, 

Mike