Oℕ
Size: a a a
Oℕ
Oℕ
VM
Oℕ
VM
λ
IA
GP
с#
☭S
P
☭S
RK
Exception in thread "main" java.lang.LinkageError: loader constraint violation: when resolving overridden method "org.apache.beam.runners.spark.io.SourceDStream.rateController()Lscala/Option;" the class loader (instance of org/apache/spark/util/ChildFirstURLClassLoader) of the current class, org/apache/beam/runners/spark/io/SourceDStream, and its superclass loader (instance of sun/misc/Launcher$AppClassLoader), have different Class objects for the type scala/Option used in the signatureВерсия Scala либ в артефакте 2.11.12, версия Beam 2.13.0 (с либами для Spark 2.4.6, судя по GitHub Scala в Beam SparkRunner 2.11.8), версия Spark на кластере 2.4.7, версия Scala на кластере 2.11.12
at org.apache.beam.runners.spark.io.SparkUnboundedSource.read(SparkUnboundedSource.java:90)
AD
Exception in thread "main" java.lang.LinkageError: loader constraint violation: when resolving overridden method "org.apache.beam.runners.spark.io.SourceDStream.rateController()Lscala/Option;" the class loader (instance of org/apache/spark/util/ChildFirstURLClassLoader) of the current class, org/apache/beam/runners/spark/io/SourceDStream, and its superclass loader (instance of sun/misc/Launcher$AppClassLoader), have different Class objects for the type scala/Option used in the signatureВерсия Scala либ в артефакте 2.11.12, версия Beam 2.13.0 (с либами для Spark 2.4.6, судя по GitHub Scala в Beam SparkRunner 2.11.8), версия Spark на кластере 2.4.7, версия Scala на кластере 2.11.12
at org.apache.beam.runners.spark.io.SparkUnboundedSource.read(SparkUnboundedSource.java:90)
RK
RK
λ
AD
λ
RK