Yixiao Shen created BEAM-14541:
----------------------------------
Summary: Timestamp value conversion in Cloud Datastore connector
is wrong
Key: BEAM-14541
URL: https://issues.apache.org/jira/browse/BEAM-14541
Project: Beam
Issue Type: Bug
Components: io-java-gcp
Reporter: Yixiao Shen
Assignee: Yixiao Shen
Code in org.apache.beam.sdk.io.gcp.datastore.EntityToRow class:
{code:java}
com.google.protobuf.Timestamp time = val.getTimestampValue();
long millis = time.getSeconds() * 1000 + time.getNanos() / 1000;
return Instant.ofEpochMilli(millis).toDateTime();{code}
1 millisecond = 1,000,000 nanoseconds
--
This message was sent by Atlassian Jira
(v8.20.7#820007)