Skip to content

Commit

Permalink
Remove useless is_tz_utc
Browse files Browse the repository at this point in the history
  • Loading branch information
Chong Gao committed Nov 14, 2023
1 parent ee930f3 commit f1267de
Showing 1 changed file with 0 additions and 10 deletions.
10 changes: 0 additions & 10 deletions integration_tests/src/main/python/spark_session.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,16 +55,6 @@ def _from_scala_map(scala_map):
'spark.sql.legacy.allowNegativeScaleOfDecimal': 'true',
}

def is_tz_utc(spark=_spark):
"""
true if the tz is UTC else false
"""
# Now we have to do some kind of ugly internal java stuff
jvm = spark.sparkContext._jvm
utc = jvm.java.time.ZoneId.of('UTC').normalized()
sys_tz = jvm.java.time.ZoneId.systemDefault().normalized()
return utc == sys_tz

def _set_all_confs(conf):
newconf = _default_conf.copy()
if (should_inject_oom()):
Expand Down

0 comments on commit f1267de

Please sign in to comment.