This is an automated email from the ASF dual-hosted git repository. dkuppitz pushed a commit to branch TINKERPOP-2076 in repository https://gitbox.apache.org/repos/asf/tinkerpop.git
commit d5cfde86e4ac0221bbbb2b9d452e4689ee2aa241 Author: stephen <spmalle...@gmail.com> AuthorDate: Tue Nov 12 06:16:03 2019 -0500 TINKERPOP-2076 Minor adjustments to gryo registrations to get spark integration tests passing --- .../tinkerpop/gremlin/spark/structure/io/gryo/GryoRegistrator.java | 2 +- .../tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoRegistrator.java b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoRegistrator.java index d1f7725..4b64ddc 100644 --- a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoRegistrator.java +++ b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoRegistrator.java @@ -198,7 +198,7 @@ public class GryoRegistrator implements KryoRegistrator { // the ordering of the existing entries in that constructor, since not all // of the entries are for TinkerPop (and the ordering is significant). try { - m.put(Class.forName("scala.reflect.ClassTag$$anon$1"), new JavaSerializer()); + m.put(Class.forName("scala.reflect.ClassTag$GenericClassTag"), new JavaSerializer()); m.put(Class.forName("org.apache.spark.internal.io.FileCommitProtocol$TaskCommitMessage"), new JavaSerializer()); m.put(Class.forName("org.apache.spark.internal.io.FileCommitProtocol$EmptyTaskCommitMessage$"), new JavaSerializer()); diff --git a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java index 6fba103..9b21744 100644 --- a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java +++ b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java @@ -138,7 +138,7 @@ public final class GryoSerializer extends Serializer implements Serializable { super.register(GryoIo.class, TorrentBroadcast.class, null); super.register(GryoIo.class, PythonBroadcast.class, null); super.register(GryoIo.class, BoxedUnit.class, null); - super.register(GryoIo.class, Class.forName("scala.reflect.ClassTag$$anon$1"), new JavaSerializer()); + super.register(GryoIo.class, Class.forName("scala.reflect.ClassTag$GenericClassTag"), new JavaSerializer()); super.register(GryoIo.class, Class.forName("org.apache.spark.internal.io.FileCommitProtocol$TaskCommitMessage"), new JavaSerializer()); super.register(GryoIo.class, Class.forName("org.apache.spark.internal.io.FileCommitProtocol$EmptyTaskCommitMessage$"), new JavaSerializer()); super.register(GryoIo.class, Class.forName("scala.collection.immutable.Map$EmptyMap$"), new JavaSerializer());