如何在pyspark中获取系统日期？

Question

我想在pyspark中获取系统日期。 我尝试了一些代码，但它给了我昨天的日期。 你能帮我解决这个问题吗

代码：

spark.sql("SELECT ID AS GRP_ID, DEV_NM AS GRP_NM, NAME, TYPE, from_utc_timestamp(current_timestamp(), 'EST5EDT') AS IM_INSERT_DT  FROM vw_grp").show(2)

输出：

+------------------+---------------+------------+---------+--------------------+
|            GRP_ID|         GRP_NM|        NAME|     TYPE|        IM_INSERT_DT|
+------------------+---------------+------------+---------+--------------------+
|00G0B000002cpcjUAA|   DM_ONC_Users|DM_ONC_Users|  Regular|2020-01-16 23:58:...|
|00G0B000002cpoQUAQ|X105_30_5000035|        null|Territory|2020-01-16 23:58:...|
+------------------+---------------+------------+---------+--------------------+

我要今天的日期：2020-01-17 15:34:15