maedhroz commented on code in PR #4428:
URL: https://github.com/apache/cassandra/pull/4428#discussion_r2535801085
##########
src/java/org/apache/cassandra/db/streaming/CassandraStreamReceiver.java:
##########
@@ -256,6 +266,11 @@ public void finished()
// add sstables (this will build non-SSTable-attached
secondary indexes too, see CASSANDRA-10130)
logger.debug("[Stream #{}] Received {} sstables from {} ({})",
session.planId(), readers.size(), session.peer, readers);
+
+ // Don't mark as live until activated by the stream coordinator
+ if (session.streamOperation() ==
StreamOperation.TRACKED_TRANSFER)
+ return;
+
cfs.addSSTables(readers);
//invalidate row and counter cache
Review Comment:
It makes sense that we wouldn't invalidate the caches here on a tracked
import, but do we need to make sure we do it on activation?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
