Beam SQL CURRENT_TIMESTAMP

206 views Asked by At

My Unix Spark Server timezone is CDT but when I'm running Beam SQL CURRENT_TIMESTAMP as below it is always coming as UTC. I tried locally also but it is always displaying UTC. I want this to be CDT same as server zone in CURRENT_TIMESTAMP function. Can you please advise fix for this?

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

There are 0 answers