Skip to content

Commit 8976c54

Browse files
committed
Don't cancel TimerTask just because we had a network issue
1 parent a5f4ecc commit 8976c54

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/main/java/de/komoot/photon/elasticsearch/Replicatior.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public void start() {
7474
/**
7575
* Read the local and remote state file and then download any missing replication files
7676
*
77-
* FIXME: should likely throw and exception if the difference between sequence numbers is very large
77+
* FIXME: should likely throw an exception if the difference between sequence numbers is very large
7878
*
7979
*/
8080
class ReplicationTask extends TimerTask {
@@ -132,8 +132,7 @@ public void run() {
132132
log.info(String.format("Update done. %d deletions %d updates or additions.", deletions, updates));
133133
}
134134
} catch (IOException e) {
135-
log.error("Replicator failing", e);
136-
cancel();
135+
log.error("Replicator failing because ", e);
137136
}
138137
}
139138
}

0 commit comments

Comments
 (0)