From 357ec7414cc11e83df241ddf067d1046ceeeb988 Mon Sep 17 00:00:00 2001 From: Giambattista Bloisi Date: Fri, 20 Dec 2024 15:25:36 +0100 Subject: [PATCH] Remove global kryo serializer --- .../java/eu/dnetlib/dhp/oa/merge/GroupEntitiesSparkJob.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/dhp-common/src/main/java/eu/dnetlib/dhp/oa/merge/GroupEntitiesSparkJob.java b/dhp-common/src/main/java/eu/dnetlib/dhp/oa/merge/GroupEntitiesSparkJob.java index 98ec09277..5ce203241 100644 --- a/dhp-common/src/main/java/eu/dnetlib/dhp/oa/merge/GroupEntitiesSparkJob.java +++ b/dhp-common/src/main/java/eu/dnetlib/dhp/oa/merge/GroupEntitiesSparkJob.java @@ -85,8 +85,6 @@ public class GroupEntitiesSparkJob { log.info("filterInvisible: {}", filterInvisible); SparkConf conf = new SparkConf(); - conf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer"); - conf.registerKryoClasses(ModelSupport.getOafModelClasses()); final VocabularyGroup vocs = VocabularyGroup.loadVocsFromIS(isLookUpService);