Skip to content

Commit ef824ad

Browse files
committed
fixed
1 parent 862385f commit ef824ad

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,8 @@ public final void execute(ExecutionParameters parameters) {
5151

5252
if (snapshot.containsKey(PROPERTY_POLLING_VALUE) && Utils
5353
.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
54+
pollingValue = Timestamp.valueOf(snapshot.getString(PROPERTY_POLLING_VALUE));
55+
} else if (configuration.containsKey(PROPERTY_POLLING_VALUE) && Utils
5656
.getNonNullString(configuration, PROPERTY_POLLING_VALUE).matches(DATETIME_REGEX)) {
5757
pollingValue = Timestamp.valueOf(configuration.getString(PROPERTY_POLLING_VALUE));
5858
} else {

0 commit comments

Comments
 (0)