Skip to content

Commit 87e0bb3

Browse files
committed
Fix service polling
1 parent 69db019 commit 87e0bb3

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/user/ServiceUserRepository.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import com.fasterxml.jackson.databind.ObjectReader;
2525
import io.confluent.common.config.ConfigException;
2626
import java.io.IOException;
27-
import java.net.MalformedURLException;
2827
import java.net.URL;
2928
import java.time.Duration;
3029
import java.time.Instant;
@@ -45,7 +44,6 @@
4544
import okhttp3.RequestBody;
4645
import okhttp3.Response;
4746
import okhttp3.ResponseBody;
48-
import org.apache.kafka.connect.errors.ConnectException;
4947
import org.radarbase.connect.rest.RestSourceConnectorConfig;
5048
import org.radarbase.connect.rest.fitbit.FitbitRestSourceConnectorConfig;
5149
import org.radarcns.exception.TokenException;
@@ -113,7 +111,7 @@ public void initialize(RestSourceConnectorConfig config) {
113111

114112
@Override
115113
public Stream<? extends User> stream() {
116-
if (nextFetch.get().equals(Instant.MIN)) {
114+
if (nextFetch.get().equals(MIN_INSTANT)) {
117115
try {
118116
applyPendingUpdates();
119117
} catch (IOException ex) {

0 commit comments

Comments
 (0)