2025年の Snowpark Connect for Spark リリースノート¶
Snowflake は、 Snowpark Connect for Spark の更新にセマンティックバージョニングを使用します。
For documentation, see Snowpark Connect for Spark を使用してSnowflakeで Apache Spark™ ワークロードを実行する and Sparkバッチワークロードを Snowpark Submit から実行する.
Version 1.2.0 (November 17, 2025)¶
Snowpark Connect for Spark¶
新機能¶
Relax version requirements for grpcio and aiobotocore.
改善¶
Specify dependencies version in
meta.yaml.Build compiled and architecture-specific conda package.
Ensure all
CloudPickleSerializer.loadsare not done in TCM.Include OSS SQL tests that start with the WITH clause.
Do not upload Spark jars when running the server for pyt.
Update internal queries count.
バグ修正¶
Fix tests for tcm.
Fix CSV column name discrepancy from Spark.
Use type cache for empty frames.
Resolve Windows OSS runner general issues.
Snowpark Submit¶
改善¶
Generate unique workload names.
Bug Fixes¶
Fix staged file reading.
Version 1.0.1 (November 3, 2025)¶
注釈
With the release of this version, version 0.24 and previous versions are deprecated.
Snowpark Connect for Spark¶
新機能¶
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.
改善¶
なし。
バグ修正¶
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_sizewith null argument.Fix for
$.0JSON array access inget_json_objectfunction.Fix self ANTI and SEMI LEFT joins.
Handle different types in SQL function range.
Fixed temporary view describe.
Version 1.0.0 (October 28, 2025)¶
Snowpark Connect for Spark¶
新機能¶
Add
rowToInferSchemafor 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 the Snowpark Submit client container.
改善¶
なし。
バグ修正¶
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.
Version 0.33.0 (October 10, 2025)¶
Snowpark Connect for Spark¶
新機能¶
Add script to run on the output from Git action for merging SQLs.
Add
--rebuild-whlparameter to notebook test runner.Add support for both qualifiers after join.
改善¶
なし。
バグ修正¶
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')wherexhas odd number of letters and digits.Fix joins with empty tables.
Fix HAVING clause to prioritize grouping columns over aggregate aliases with same name.
バージョン0.32.0(2025年10月17日)¶
Snowpark Connect for Spark¶
新機能¶
RepairTableをサポートします。jdk4pyを Snowpark Connect for Spark のオプションの依存関係にして、エンドユーザー向けのJavaホームの設定を簡単にします。サポートするインターバルタイプのケースを増やします。
改善¶
なし。
バグ修正¶
修飾子をリファクタリングすることで、
Joinの問題を修正します。percentile_contを修正し、フィルターとソート順の式を使えるようにします。histogram_numericUDAF を修正します。複数の引数で呼び出された場合の
COUNT関数を修正します。
バージョン0.31.0(2025年10月9日)¶
Snowpark Connect for Spark¶
新機能¶
GROUP BY 句が明示的に選択されている場合の、その句での式のサポートを追加します。
トラブルシューティングの改善のため、エラーメッセージにエラーコードを追加します。
改善¶
なし。
バグ修正¶
ウィンドウ関数でキャストがサポートされていなかった問題を修正します。