fix #217

NitorCreations · Mar 30, 2017 · ab7a542 · ab7a542
1 parent c91a48d
commit ab7a542
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-engine/src/main/java/io/nflow/engine/internal/storage/db/MysqlDatabaseConfiguration.java b/...-engine/src/main/java/io/nflow/engine/internal/storage/db/MysqlDatabaseConfiguration.java
@@ -69,7 +69,7 @@ public SQLVariants sqlVariants() {
   public static class MySQLVariants implements SQLVariants {
     @Override
     public String currentTimePlusSeconds(int seconds) {
-      return "date_add(current_timestamp, interval " + seconds + " second)";
+      return "from_unixtime(unix_timestamp() + " + seconds + ")";
     }
 
     @Override