simplify

apache · Sep 16, 2024 · 656a2d3 · 656a2d3
1 parent 481ee85
commit 656a2d3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...cala/org/apache/spark/sql/execution/streaming/state/StateSchemaCompatibilityChecker.scala b/...cala/org/apache/spark/sql/execution/streaming/state/StateSchemaCompatibilityChecker.scala
@@ -187,8 +187,8 @@ class StateSchemaCompatibilityChecker(
           check(existingStateSchema, newSchema, ignoreValueSchema)
         }
       }
-      val colFamiliesAddedOrRemoved = newStateSchemaList.map(_.colFamilyName).toSet
-        != existingSchemaMap.keySet
+      val colFamiliesAddedOrRemoved =
+        (newStateSchemaList.map(_.colFamilyName).toSet != existingSchemaMap.keySet)
       if (stateSchemaVersion == SCHEMA_FORMAT_V3 && colFamiliesAddedOrRemoved) {
         createSchemaFile(newStateSchemaList, stateSchemaVersion)
       }