Snowpark Connect for Spark release notes for 2025¶

New features¶

• Add parameter for view creation strategies.

• Support string <-> year month interval.

• Support multiple pivot columns and aliases for pivot values in Spark SQL.

• Integrate OpenTelemetry span and traces.

Improvements¶

None.

Bug fixes¶

• Add a trailing slash for remove command.

• Invalid GROUP BY issue with aggregation function and nilary functions.

• Notebook exceeds gRPC maximum message size.

• Fix temporary view creation with colliding names.

• array_size with null argument.

• Fix for $.0 JSON array access in get_json_object function.

• Fix self ANTI and SEMI LEFT joins.

• Handle different types in SQL function range.

• Fixed temporary view describe.

New features¶

• Add rowToInferSchema for CSV reading.

• Support INSERT INTO with CTE SQL command.

• I/O changes to add _SUCCESS file generation and metadata file filtering.

• update(submit): Support installing Snowpark Connect for Spark in Snowpark Submit client container.

Improvements¶

None.

Bug fixes¶

• Fix _SUCCESS path update.

• Throw error on remove failure update.

• Sequence function supporting integral types inputs.

• Fix types in empty CreateTempViewUsing.

• Fix Parquet file repartitioning on write.

• Resolve aliases in ORDER BY clause correctly.

• Remove scope temp session parameter.

• Fixed multiple self joins with join condition.

• Fix column name resolution in pivot.

• SQL parser aware of session timezone.

• Interval type coercion with other types.

• Fix having with nested CTEs.

• Improve qualified name resolution in Spark.

New features¶

• Add script to run on the output from Git action for merging SQLs.

• Add --rebuild-whl parameter to notebook test runner.

• Add support for both qualifiers after join.

Improvements¶

None.

Bug fixes¶

• Support escape parameter in SQL LIKE commands.

• Overwrite bug in partitions.

• Validate column count on INSERT.

• Incompatibility for pow with NAN.

• Cross JOIN with condition.

• Column attribution logic in nested queries.

• Update error message for interval test.

• String type coercion in set operation UNION and EXCEPT, coerce NUMERIC, DATE, DATETIME to STRING.

• Correctly resolve Snowpark columns after a full outer self JOIN.

• Expression in aggregate function might be zero improvement.

• Update: Revert “[SCOS GA BUG] string type coercion in set opera”

• DataFrame union of decimal type columns now widen as necessary.

• String type coercion in set operation UNION and EXCEPT, coerce NUMERIC, DATE, DATETIME to STRING (part1).

• Object not existed issue in TCM.

• Fix to_binary(x, 'hex') where x has odd number of letters and digits.

• Fix joins with empty tables.

• Fix HAVING clause to prioritize grouping columns over aggregate aliases with same name.

New features¶

• Support for RepairTable.

• Make jdk4py an optional dependency of Snowpark Connect for Spark to simplify configuring Java home for end users.

• Support more interval type cases.

Improvements¶

None.

Bug fixes¶

• Fix Join issues by refactoring qualifiers

• Fix percentile_cont to allow filter and sort order expressions.

• Fix histogram_numeric UDAF.

• Fix the COUNT function when called with multiple args.

New features¶

• Add support for expressions in the GROUP BY clause when the clause is explicitly selected.

• Add error codes to the error messages for better troubleshooting.

Improvements¶

None.

Bug fixes¶

• Fix the window function unsupported cast issue.