diff options
| author | Arne H Juul <arnej@yahooinc.com> | 2022-06-03 10:55:18 +0000 |
|---|---|---|
| committer | gjoranv <gv@verizonmedia.com> | 2022-06-08 11:45:31 +0200 |
| commit | 0b3579b8af74a1bdbab5759a51bd592fdbc11cb8 (patch) | |
| tree | a078096d65da6b15e5bedb00a6a911bbfc078ed9 /clustercontroller-reindexer | |
| parent | e337a30ca89055a6aa3f7aa9267d2f1e523e7bdd (diff) | |
more cleanup of DocumentTypeManager API
Diffstat (limited to 'clustercontroller-reindexer')
| -rw-r--r-- | clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java | 2 |
1 files changed, 1 insertions, 1 deletions
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())), |