bdeggleston commented on code in PR #3174:
URL: https://github.com/apache/cassandra/pull/3174#discussion_r1548367383
##########
src/java/org/apache/cassandra/db/streaming/CassandraStreamReceiver.java:
##########
@@ -246,7 +246,7 @@ public void finished()
checkNotNull(minVersion, "Unable to determine minimum cluster
version");
IAccordService accordService = AccordService.instance();
if (session.streamOperation().requiresBarrierTransaction()
- && cfs.metadata().isAccordEnabled()
+ && cfs.metadata().requiresAccordSupport()
Review Comment:
This probably counts as a separate migration/interop jira, but we could
probably pass along the epoch in the StreamInitMessage and wait to be caught up
locally before responding. That should make schema change -> migration repair
safe for this case. There may still be a race cause be changing the schema or
completing a migration while an unrelated streaming session is in progress
though
--
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]
