When I set rowtime attribute by using expression 'column.rowtime' , and result type is sql.Timestamp, the result will have lag which is equals with default timezone offset.
I look into the conversion logic, the field was go through 'long -> SqlTimestamp -> Timestamp' conversion.
The result is from!=to. In SqlTimestamp.toTimestamp() using Timestamp.valueOf(LocalDateTime dateTime) which is contain timezone infomation, will casue time lag.
From Timestamp to Timestamp not have this issue, but convert Datastream to Table is use StreamRecord.timestamp as rowtime field.