Skip to content
This repository was archived by the owner on Feb 10, 2025. It is now read-only.

Commit 16afc93

Browse files
committed
Reverted CL_Local_quorum changes
1 parent e8a8110 commit 16afc93

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

event/src/main/java/com/bazaarvoice/emodb/event/db/astyanax/AstyanaxEventReaderDAO.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -348,7 +348,7 @@ private Iterator<Column<ByteBuffer>> readManifestForChannel(final String channel
348348
range.setStart(oldestSlab);
349349
consistency = ConsistencyLevel.CL_LOCAL_ONE;
350350
} else {
351-
consistency = ConsistencyLevel.CL_TWO;
351+
consistency = ConsistencyLevel.CL_LOCAL_QUORUM;
352352
}
353353

354354
final Iterator<Column<ByteBuffer>> manifestColumns = executePaginated(
@@ -404,7 +404,7 @@ private boolean readSlab(String channel, ByteBuffer slabId, SlabCursor cursor, b
404404

405405
ColumnList<Integer> eventColumns = execute(
406406

407-
_keyspace.prepareQuery(ColumnFamilies.SLAB, ConsistencyLevel.CL_TWO)
407+
_keyspace.prepareQuery(ColumnFamilies.SLAB, ConsistencyLevel.CL_LOCAL_QUORUM)
408408
.getKey(slabId)
409409
.withColumnRange(start, Constants.OPEN_SLAB_MARKER, false, Integer.MAX_VALUE));
410410

0 commit comments

Comments
 (0)