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.loads are 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_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.

Version 1.0.0 (October 28, 2025)

Snowpark Connect for Spark

新機能

  • 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 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-whl parameter 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') 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.

バージョン0.32.0(2025年10月17日)

Snowpark Connect for Spark

新機能

  • RepairTable をサポートします。

  • jdk4py を Snowpark Connect for Spark のオプションの依存関係にして、エンドユーザー向けのJavaホームの設定を簡単にします。

  • サポートするインターバルタイプのケースを増やします。

改善

なし。

バグ修正

  • 修飾子をリファクタリングすることで、Join の問題を修正します。

  • percentile_cont を修正し、フィルターとソート順の式を使えるようにします。

  • histogram_numeric UDAF を修正します。

  • 複数の引数で呼び出された場合の COUNT 関数を修正します。

バージョン0.31.0(2025年10月9日)

Snowpark Connect for Spark

新機能

  • GROUP BY 句が明示的に選択されている場合の、その句での式のサポートを追加します。

  • トラブルシューティングの改善のため、エラーメッセージにエラーコードを追加します。

改善

なし。

バグ修正

  • ウィンドウ関数でキャストがサポートされていなかった問題を修正します。