I think this ought to work.

Signed-off-by: Jim Hughes <[email protected]>
locationtech · Nov 16, 2021 · 52c82c7 · 52c82c7
1 parent e25c3dd
commit 52c82c7
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/...src/main/scala/org/locationtech/geomesa/accumulo/iterators/KryoVisibilityRowEncoder.scala b/...src/main/scala/org/locationtech/geomesa/accumulo/iterators/KryoVisibilityRowEncoder.scala
@@ -112,7 +112,7 @@ class KryoVisibilityRowEncoder extends RowEncodingIterator {
 
     // TODO: Calculate size of userData for vis.
 
-    length += 54 // 2 ($s) + 26 "geomesa.feature.visibility" + 2 "$s" + 19 "user,user,user,user" + 4 for two string sizes
+    length += 60 // 2 ($s) + 26 "geomesa.feature.visibility" + 2 "$s" + 19 "user,user,user,user" + 4 for two string sizes
 
     val value = Array.ofDim[Byte](length)
     val output = new Output(value)
@@ -149,7 +149,7 @@ class KryoVisibilityRowEncoder extends RowEncodingIterator {
     // write nulls - we should already be in the right position
     nulls.serialize(output)
     println(s"Output at position after null writer: ${output.position()}")
-    output.setPosition(valueCursor-3)
+    output.setPosition(valueCursor-4)
 
     println(s"Output at position before userdata: ${output.position()}")
     KryoUserDataSerialization.serialize(output, map)

diff --git a/...cala/org/locationtech/geomesa/features/kryo/serialization/KryoUserDataSerialization.scala b/...cala/org/locationtech/geomesa/features/kryo/serialization/KryoUserDataSerialization.scala
@@ -97,7 +97,7 @@ object KryoUserDataSerialization extends LazyLogging {
       map
     } catch {
       case NonFatal(e) =>
-        logger.error("Error reading serialized kryo user data:", e)
+        logger.error(s"Error reading serialized kryo user data at ${in.position()}:", e)
         new java.util.HashMap[AnyRef, AnyRef]()
     }
   }

diff --git a/geomesa-index-api/src/main/scala/org/locationtech/geomesa/index/api/QueryPlan.scala b/geomesa-index-api/src/main/scala/org/locationtech/geomesa/index/api/QueryPlan.scala
@@ -285,6 +285,7 @@ object QueryPlan {
     override def schema: SimpleFeatureType = sft
 
     protected def createSerializer: KryoFeatureSerializer = {
+      println(s"Creating serializer for sft: $sft")
       val builder = KryoFeatureSerializer.builder(sft)
       if (index.serializedWithId) { builder.withId.withUserData.build() } else { builder.withoutId.withUserData.build() }
     }