review comment

apache · Sep 17, 2024 · 72b9f2d · 72b9f2d
1 parent 656a2d3
commit 72b9f2d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...cala/org/apache/spark/sql/execution/streaming/state/StateSchemaCompatibilityChecker.scala b/...cala/org/apache/spark/sql/execution/streaming/state/StateSchemaCompatibilityChecker.scala
@@ -173,7 +173,7 @@ class StateSchemaCompatibilityChecker(
 
     if (existingStateSchemaList.isEmpty) {
       // write the schema file if it doesn't exist
-      createSchemaFile(newStateSchemaList, stateSchemaVersion)
+      createSchemaFile(newStateSchemaList.sortBy(_.colFamilyName), stateSchemaVersion)
       true
     } else {
       // validate if the new schema is compatible with the existing schema