diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-02-19 17:42:49 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-02-19 17:42:49 +0100 |
commit | eaa8348f763045387ae231be51da1782ffe434ec (patch) | |
tree | fec0c5f00c0712a32732460bef8079aabe3734c3 /clustercontroller-reindexer/src/test | |
parent | a219da1a7379606860c874a64f94aafb8973d205 (diff) |
Assume reindexing is done for ready types when no data/data lost
Diffstat (limited to 'clustercontroller-reindexer/src/test')
-rw-r--r-- | clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java b/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java index 8cf96fa8c45..cd9cf9f845d 100644 --- a/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java +++ b/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java @@ -91,9 +91,9 @@ class ReindexerTest { @Test @Timeout(10) void testReindexing() throws ReindexingLockException { - // Reindexer is created without any ready document types, which means nothing should run. - new Reindexer(cluster, Map.of(), database, ReindexerTest::failIfCalled, metric, clock).reindex(); - Reindexing reindexing = Reindexing.empty(); + // Reindexer is created against en empty database, so any ready document types are assumed already done. + new Reindexer(cluster, Map.of(music, Instant.ofEpochMilli(-10)), database, ReindexerTest::failIfCalled, metric, clock).reindex(); + Reindexing reindexing = Reindexing.empty().with(music, Status.ready(Instant.EPOCH).running().successful(Instant.EPOCH)); assertEquals(reindexing, database.readReindexing("cluster")); // New config tells reindexer to reindex "music" documents no earlier than at 10 millis after EPOCH, which isn't yet. @@ -156,6 +156,10 @@ class ReindexerTest { "clusterid", "cluster", "state", "pending"))); + // Reindexer is created without any ready document types, which means nothing should run. + new Reindexer(cluster, Map.of(), database, ReindexerTest::failIfCalled, metric, clock).reindex(); + assertEquals(reindexing, database.readReindexing("cluster")); + // Last reindexing fails. clock.advance(Duration.ofMillis(10)); shutDown.set(false); |