Add is_spark_332cdh method to spark_session.py for integration tests.

Signed-off-by: Rishi <[email protected]>

integration_tests/src/main/python/spark_session.py

@@ -180,8 +180,11 @@ def is_spark_321cdh():
 def is_spark_330cdh():
     return "3.3.0.3.3.718" in spark_version()
 
+def is_spark_332cdh():
+    return "3.3.2.3.3.719" in spark_version()
+
 def is_spark_cdh():
-    return is_spark_321cdh() or is_spark_330cdh()
+    return is_spark_321cdh() or is_spark_330cdh() or is_spark_332cdh()
 
 def is_databricks_version_or_later(major, minor):
     spark = get_spark_i_know_what_i_am_doing()