Skip to content

Commit 7ad51ad

Browse files
committed
fixed snapshot bug
1 parent 9cfbe54 commit 7ad51ad

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/main/java/io/elastic/jdbc/triggers/GetRowsPollingTrigger.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -49,11 +49,11 @@ public final void execute(ExecutionParameters parameters) {
4949
Timestamp cts = new java.sql.Timestamp(cDate.getTimeInMillis());
5050
String formattedDate = new SimpleDateFormat(PROPERTY_DATETIME_FORMAT).format(cts);
5151

52-
if (configuration.containsKey(PROPERTY_POLLING_VALUE) && Utils
53-
.getNonNullString(configuration, PROPERTY_POLLING_VALUE).matches(DATETIME_REGEX)) {
54-
pollingValue = Timestamp.valueOf(configuration.getString(PROPERTY_POLLING_VALUE));
55-
} else if (snapshot.containsKey(PROPERTY_POLLING_VALUE) && Utils
52+
if (snapshot.containsKey(PROPERTY_POLLING_VALUE) && Utils
5653
.getNonNullString(snapshot, PROPERTY_POLLING_VALUE).matches(DATETIME_REGEX)) {
54+
pollingValue = Timestamp.valueOf(configuration.getString(PROPERTY_POLLING_VALUE));
55+
} else if (configuration.containsKey(PROPERTY_POLLING_VALUE) && Utils
56+
.getNonNullString(configuration, PROPERTY_POLLING_VALUE).matches(DATETIME_REGEX)) {
5757
pollingValue = Timestamp.valueOf(snapshot.getString(PROPERTY_POLLING_VALUE));
5858
} else {
5959
LOGGER.info(

0 commit comments

Comments
 (0)