diff --git a/README.md b/README.md index e26763f1..a4c629a4 100644 --- a/README.md +++ b/README.md @@ -154,6 +154,7 @@ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. + [Build Status]:https://travis-ci.org/mysql-time-machine/replicator [Build Status img]:https://travis-ci.org/mysql-time-machine/replicator.svg?branch=master [Coverage Status]:https://codecov.io/gh/mysql-time-machine/replicator @@ -162,3 +163,4 @@ limitations under the License. [Known Vulnerabilities]:https://snyk.io/test/github/mysql-time-machine/replicator [license]:LICENSE [license img]:https://img.shields.io/badge/license-Apache%202-blue.svg + diff --git a/mysql-replicator-augmenter-model/src/main/java/com/booking/replication/augmenter/model/format/MysqlTypeDeserializer.java b/mysql-replicator-augmenter-model/src/main/java/com/booking/replication/augmenter/model/format/MysqlTypeDeserializer.java index 37fb8229..9e1fde2e 100644 --- a/mysql-replicator-augmenter-model/src/main/java/com/booking/replication/augmenter/model/format/MysqlTypeDeserializer.java +++ b/mysql-replicator-augmenter-model/src/main/java/com/booking/replication/augmenter/model/format/MysqlTypeDeserializer.java @@ -132,7 +132,7 @@ public static Object convertToObject(Serializable cellValue, ColumnSchema column case TIMESTAMP: { Long timestamp = (Long) cellValue; - ZoneId zoneId = ZonedDateTime.now().getZone(); + ZoneId zoneId = ZoneId.of("UTC"); LocalDateTime aLDT = Instant.ofEpochMilli(timestamp).atZone(zoneId).toLocalDateTime(); Integer offset = ZonedDateTime.from(aLDT.atZone(zoneId)).getOffset().getTotalSeconds();