From 262b30cf2620b886cf30dd1f6ab3f58e1eaa89d2 Mon Sep 17 00:00:00 2001 From: Claus Stadler Date: Mon, 8 Mar 2021 18:04:15 +0100 Subject: [PATCH] Replacing a 'dash' from system hash code with '_' in order to yield a valid spark table name. --- .../scala/net/sansa_stack/rdf/spark/partition/package.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sansa-rdf/sansa-rdf-spark/src/main/scala/net/sansa_stack/rdf/spark/partition/package.scala b/sansa-rdf/sansa-rdf-spark/src/main/scala/net/sansa_stack/rdf/spark/partition/package.scala index 792254945..d2718615a 100644 --- a/sansa-rdf/sansa-rdf-spark/src/main/scala/net/sansa_stack/rdf/spark/partition/package.scala +++ b/sansa-rdf/sansa-rdf-spark/src/main/scala/net/sansa_stack/rdf/spark/partition/package.scala @@ -55,7 +55,8 @@ package object partition extends Logging { // Create a table prefix for each partitioning of RDDs // TODO Encode partitioner hash into the name - val rddId = System.identityHashCode(rddOfTriples) + val rddSysHash = System.identityHashCode(rddOfTriples) + val rddId = if (rddSysHash < 0) "_" + rddSysHash else "" + rddSysHash val tableNaming: RdfPartitionStateDefault => String = partitionState => "rdd" + rddId + "_" + SQLUtils.encodeTablename(SQLUtils.createDefaultTableName(partitionState))