We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0159701 commit 54be80eCopy full SHA for 54be80e
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala
@@ -367,7 +367,6 @@ private[state] class HDFSBackedStateStoreProvider extends StateStoreProvider wit
367
// This is work around for the following.
368
// Pre-Spark 2.3 mistakenly append 4 bytes to the value row in
369
// `FixedLengthRowBasedKeyValueBatch`, which gets persisted into the checkpoint data
370
- assert(valueSize % 8 == 0)
371
valueRow.pointTo(valueRowBuffer, (valueSize / 8) * 8)
372
map.put(keyRow, valueRow)
373
}
0 commit comments