apache-beam - Beam SQL CURRENT_TIMESTAMP

Question

我的 Unix Spark Server 时区是 CDT，但是当我如下运行 Beam SQL CURRENT_TIMESTAMP 时，它总是以 UTC 的形式出现。我也在本地尝试过，但它总是显示 UTC。我希望这与 CURRENT_TIMESTAMP 函数中的服务器区域 CDT 相同。你能建议解决这个问题吗？

         PCollection<Row> cnct = testApps
                           .apply(SqlTransform.query("SELECT  current_timestamp as ts "
                                        + "FROM PCOLLECTION"));