Runtian commented on code in PR #2649:
URL: https://github.com/apache/cassandra/pull/2649#discussion_r1317675471
##########
src/java/org/apache/cassandra/streaming/StreamDeserializingTask.java:
##########
@@ -109,6 +110,10 @@ public StreamSession deriveSession(StreamMessage message)
// Attach this channel to the session: this only happens upon
receiving the first init message as a follower;
// in all other cases, no new control channel will be added, as the
proper control channel will be already attached.
streamSession.attachInbound(channel);
+
+ if (streamSession.getStreamOperation() == StreamOperation.BULK_LOAD &&
!Guardrails.bulkLoadEnabled.isEnabled(null))
+ throw new StreamReceiveException(streamSession, new
RuntimeException("Bulk load is disabled"));
Review Comment:
Made the change please review it again. Thanks.
--
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]
