Skip to content

Commit

Permalink
IGNITE-22767 Fix index scan
Browse files Browse the repository at this point in the history
  • Loading branch information
nizhikov committed Aug 2, 2024
1 parent 5f9289c commit 03ae2ac
Show file tree
Hide file tree
Showing 3 changed files with 134 additions and 79 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -660,7 +660,6 @@ private ListFieldsQueryCursor<?> mapAndExecutePlan(
qry.onResponse(nodeId, fragment.fragmentId(), ex);
else {
try {
// TODO: add tx state here.
QueryStartRequest req = new QueryStartRequest(
qry.id(),
qry.localQueryId(),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -255,7 +255,7 @@ private int[] fieldToInlinedKeysMapping(int srcFieldsCnt) {
txChanges = transactionRows(
ectx.getTxWriteEntries(),
// TODO: Use set for partitions here.
e -> (cctx.cacheId() == e.cacheId()) && F.contains(parts, e.key().partition()),
e -> (cctx.cacheId() == e.cacheId()) && (parts == null || F.contains(parts, e.key().partition())),
r -> new IndexRowImpl(rowHnd, r)
);

Expand Down
Loading

0 comments on commit 03ae2ac

Please sign in to comment.