stuff

apache · Dec 27, 2024 · cd4d1ff · cd4d1ff
1 parent 2af87b2
commit cd4d1ff
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/...e/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateEncoder.scala b/...e/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateEncoder.scala
@@ -1129,15 +1129,13 @@ class AvroStateEncoder(
 
   override def decodeValue(bytes: Array[Byte]): UnsafeRow = {
     val schemaIdRow = decodeStateSchemaIdRow(bytes)
-    logError(s"### schemaId: ${schemaIdRow.schemaId}, currentSchemaId: ${currentValSchemaId}")
     val writerSchema = stateSchemaBroadcast.get.getSchemaMetadataValue(
       StateSchemaMetadataKey(
         getColFamilyName,
         schemaIdRow.schemaId,
         isKey = false
       )
     )
-    logError(s"### writerSchema: ${writerSchema.avroSchema}, readerSchema: ${valueAvroType}")
     decodeFromAvroToUnsafeRow(
       schemaIdRow.bytes,
       avroEncoder.valueDeserializer,