From 0b3579b8af74a1bdbab5759a51bd592fdbc11cb8 Mon Sep 17 00:00:00 2001 From: Arne H Juul Date: Fri, 3 Jun 2022 10:55:18 +0000 Subject: more cleanup of DocumentTypeManager API --- .../src/main/java/ai/vespa/reindexing/ReindexingCurator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'clustercontroller-reindexer') diff --git a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java index 94b65a01e57..d5324a3f0b8 100644 --- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java +++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java @@ -135,7 +135,7 @@ public class ReindexingCurator implements Closeable { private Reindexing deserialize(byte[] json) { return new Reindexing(SlimeUtils.entriesStream(SlimeUtils.jsonToSlimeOrThrow(json).get().field(STATUS)) - .filter(object -> require(TYPE, object, field -> types.hasDataType(field.asString()))) // Forget unknown documents. + .filter(object -> require(TYPE, object, field -> types.hasDocumentType(field.asString()))) // Forget unknown documents. .collect(toUnmodifiableMap(object -> require(TYPE, object, field -> types.getDocumentType(field.asString())), object -> new Status(require(STARTED_MILLIS, object, field -> Instant.ofEpochMilli(field.asLong())), get(ENDED_MILLIS, object, field -> Instant.ofEpochMilli(field.asLong())), -- cgit v1.2.3