diff --git a/flyway-database-yugabytedb/src/main/java/org/flywaydb/community/database/postgresql/yugabytedb/YugabyteDBExecutionTemplate.java b/flyway-database-yugabytedb/src/main/java/org/flywaydb/community/database/postgresql/yugabytedb/YugabyteDBExecutionTemplate.java
index 140bfeb..b9ee04d 100644
--- a/flyway-database-yugabytedb/src/main/java/org/flywaydb/community/database/postgresql/yugabytedb/YugabyteDBExecutionTemplate.java
+++ b/flyway-database-yugabytedb/src/main/java/org/flywaydb/community/database/postgresql/yugabytedb/YugabyteDBExecutionTemplate.java
@@ -86,7 +86,7 @@ private long tryLock() {
 
             if (!tableEntries.containsKey(tableName)) {
                 try {
-                    String now = new Timestamp(Instant.now().getEpochSecond()).toString();
+                    String now = new Timestamp(Instant.now().toEpochMilli()).toString();
                     statement.executeUpdate("INSERT INTO "
                             + YugabyteDBDatabase.LOCK_TABLE_NAME
                             + " VALUES ('" + tableName + "', 0, '" + now + "')");
@@ -116,7 +116,7 @@ private long tryLock() {
             if (rs.next()) {
                 lockIdRead = rs.getLong("lock_id");
                 Timestamp tsRead = rs.getTimestamp("ts");
-                String current = new Timestamp(Instant.now().getEpochSecond()).toString();
+                String current = new Timestamp(Instant.now().toEpochMilli()).toString();
                 long lockIdTtl = DEFAULT_LOCK_ID_TTL;
                 String sysProp = System.getProperty(LOCK_ID_TTL_SYS_PROP_NAME);
                 if (sysProp != null) {
@@ -128,7 +128,7 @@ private long tryLock() {
                     }
                 }
 
-                if (lockIdRead == 0 || Instant.now().getEpochSecond() - tsRead.getTime() > lockIdTtl) {
+                if (lockIdRead == 0 || Instant.now().toEpochMilli() - tsRead.getTime() > lockIdTtl) {
                     lockIdToBeReturned = random.nextLong();
                     if (lockIdRead == 0) {
                         LOG.debug(Thread.currentThread().getName() + "> Setting lock_id = " + lockIdToBeReturned);