This is an automated email from the ASF dual-hosted git repository.

ruifengz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/master by this push:
     new f5b620ecbec7 [SPARK-55034][PYTHON][TESTS] Test 
`test_arrow_udf_output_timestamps_ltz` without timezone conversion to UTC
f5b620ecbec7 is described below

commit f5b620ecbec779a95758cfe6bf461b2f5cec69f2
Author: Ruifeng Zheng <[email protected]>
AuthorDate: Mon Jan 19 09:10:39 2026 +0800

    [SPARK-55034][PYTHON][TESTS] Test `test_arrow_udf_output_timestamps_ltz` 
without timezone conversion to UTC
    
    ### What changes were proposed in this pull request?
    Test `test_arrow_udf_output_timestamps_ltz` without timezone conversion to 
UTC
    
    ### Why are the changes needed?
    this conversion is counter-intuitive, and after 
https://github.com/apache/spark/pull/53660, it is no longer needed
    
    ### Does this PR introduce _any_ user-facing change?
    no, test-only
    
    ### How was this patch tested?
    ci
    
    ### Was this patch authored or co-authored using generative AI tooling?
    no
    
    Closes #53796 from zhengruifeng/test_ltz.
    
    Authored-by: Ruifeng Zheng <[email protected]>
    Signed-off-by: Ruifeng Zheng <[email protected]>
---
 python/pyspark/sql/tests/arrow/test_arrow_udf_scalar.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/python/pyspark/sql/tests/arrow/test_arrow_udf_scalar.py 
b/python/pyspark/sql/tests/arrow/test_arrow_udf_scalar.py
index 481684578c5b..88ea7ad08019 100644
--- a/python/pyspark/sql/tests/arrow/test_arrow_udf_scalar.py
+++ b/python/pyspark/sql/tests/arrow/test_arrow_udf_scalar.py
@@ -379,10 +379,10 @@ class ScalarArrowUDFTestsMixin:
                     int(mi[i].as_py()),
                     int(s[i].as_py()),
                     tzinfo=ZoneInfo(tz),
-                ).astimezone(datetime.timezone.utc)
+                )
                 for i in range(len(y))
             ]
-            return pa.array(dates, pa.timestamp("us", "UTC"))
+            return pa.array(dates)
 
         result = df.select(build_ts("y", "m", "d", "h", "mi", "s").alias("ts"))
         self.assertEqual(


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to