[FLINK-16938] SqlTimestamp has lag when convert long to Timestamp

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.10.0
• Component/s: Table SQL / API
• Labels: stale-major
• Assignee: Unassigned
• Reporter: YufeiLiu
• Created: 02/Apr/20 07:39
• Updated: 29/Apr/21 16:31
• Resolved: 29/Apr/21 16:31

Description

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.

tEnv.fromDataStream(stream, "user_action_time.rowtime, user_name, data");

I look into the conversion logic, the field was go through 'long -> SqlTimestamp -> Timestamp' conversion.

long from = System.currentTimeMillis();
long to = SqlTimestamp
			.fromEpochMillis(from)
			.toTimestamp()
			.getTime();

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.

Issue Links

• relates to: FLINK-20162 Fix time zone problems for some time related functions