From e59d42b64a66c657a2937d712069c3ad7950305a Mon Sep 17 00:00:00 2001 From: mukeshsbbv Date: Tue, 5 Mar 2024 10:35:38 +0530 Subject: [PATCH] updated to CLTWO --- .../emodb/event/db/astyanax/AstyanaxEventReaderDAO.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/event/src/main/java/com/bazaarvoice/emodb/event/db/astyanax/AstyanaxEventReaderDAO.java b/event/src/main/java/com/bazaarvoice/emodb/event/db/astyanax/AstyanaxEventReaderDAO.java index 81da25eabd..b66a46d413 100644 --- a/event/src/main/java/com/bazaarvoice/emodb/event/db/astyanax/AstyanaxEventReaderDAO.java +++ b/event/src/main/java/com/bazaarvoice/emodb/event/db/astyanax/AstyanaxEventReaderDAO.java @@ -346,7 +346,7 @@ private Iterator> readManifestForChannel(final String channel range.setStart(oldestSlab); consistency = ConsistencyLevel.CL_LOCAL_ONE; } else { - consistency = ConsistencyLevel.CL_LOCAL_QUORUM; + consistency = ConsistencyLevel.CL_TWO; } final Iterator> manifestColumns = executePaginated( @@ -399,7 +399,7 @@ private boolean readSlab(String channel, ByteBuffer slabId, SlabCursor cursor, b // Using a lower consistency level could result in (a) duplicate events because we miss deletes and (b) // incorrectly closing or deleting slabs when slabs look empty if we miss adds. ColumnList eventColumns = execute( - _keyspace.prepareQuery(ColumnFamilies.SLAB, ConsistencyLevel.CL_LOCAL_QUORUM) + _keyspace.prepareQuery(ColumnFamilies.SLAB, ConsistencyLevel.CL_TWO) .getKey(slabId) .withColumnRange(start, Constants.OPEN_SLAB_MARKER, false, Integer.MAX_VALUE));