Skip to content

Commit 862385f

Browse files
committed
fixed
1 parent ca1d3a0 commit 862385f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public final void execute(ExecutionParameters parameters) {
5454
pollingValue = Timestamp.valueOf(configuration.getString(PROPERTY_POLLING_VALUE));
5555
} else if (configuration.containsKey(PROPERTY_POLLING_VALUE) && Utils
5656
.getNonNullString(configuration, PROPERTY_POLLING_VALUE).matches(DATETIME_REGEX)) {
57-
pollingValue = Timestamp.valueOf(snapshot.getString(PROPERTY_POLLING_VALUE));
57+
pollingValue = Timestamp.valueOf(configuration.getString(PROPERTY_POLLING_VALUE));
5858
} else {
5959
LOGGER.info(
6060
"There is an empty value for Start Polling From at the config and snapshot. So, we set Current Date = "

0 commit comments

Comments
 (0)