Beam SQL CURRENT_TIMESTAMP

问题描述

我的Unix Spark Server时区是CDT，但是当我运行Beam sql CURRENT_TIMESTAMP时，如下所示，它总是以UTC出现。我也在本地尝试过，但它始终显示UTC。我希望此CDT与CURRENT_TIMESTAMP函数中的服务器区域相同。您能为此提出建议吗？

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

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）