[ https://issues.apache.org/jira/browse/CASSANDRA-16334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aleksandr Sorokoumov updated CASSANDRA-16334: --------------------------------------------- Description: Inserting a mutation larger than {{max_mutation_size_in_kb}} correctly throws a write error on a single DC keyspace with RF=3: {noformat} cassandra.WriteFailure: Error from server: code=1500 [Replica(s) failed to execute write] message="Operation failed - received 0 responses and 3 failures: UNKNOWN from /127.0.0.3:7000, UNKNOWN from /127.0.0.2:7000, UNKNOWN from /127.0.0.1:7000" info={'consistency': 'LOCAL_ONE', 'required_responses': 1, 'received_responses': 0, 'failures': 3} {noformat} The same insert wrongly causes a timeout on a keyspace with 2 dcs (RF=3 each): {noformat} cassandra.WriteTimeout: Error from server: code=1100 [Coordinator node timed out waiting for replica nodes' responses] message="Operation timed out - received only 0 responses." info={'consistency': 'LOCAL_ONE', 'required_responses': 1, 'received_responses': 0} {noformat} Reproduction steps: {noformat} # Setup cluster ccm create -n 3:3 test for i in {1..6}; do echo 'max_mutation_size_in_kb: 1000' >> ~/.ccm/test/node$i/conf/cassandra.yaml; done ccm start # Create schema ccm node1 cqlsh CREATE KEYSPACE test WITH replication = {'class': 'NetworkTopologyStrategy', 'dc1': 3, 'dc2': 3}; CREATE TABLE test.test (key int PRIMARY KEY, val blob); exit; # Insert data python from cassandra.cluster import Cluster cluster = Cluster() session = cluster.connect('test') blob = f = open("2mbBlob", "rb").read().hex() session.execute("INSERT INTO test (key, val) VALUES (1, textAsBlob('" + blob + "'))") {noformat} Reproduced in 3.0, 3.11, 4.0, trunk. was: Inserting a mutation larger than {{max_mutation_size_in_kb}} correctly throws a write error on a single DC keyspace with RF=3: {noformat} cassandra.WriteFailure: Error from server: code=1500 [Replica(s) failed to execute write] message="Operation failed - received 0 responses and 3 failures: UNKNOWN from /127.0.0.3:7000, UNKNOWN from /127.0.0.2:7000, UNKNOWN from /127.0.0.1:7000" info={'consistency': 'LOCAL_ONE', 'required_responses': 1, 'received_responses': 0, 'failures': 3} {noformat} The same insert wrongly causes a timeout on a keyspace with 2 dcs (RF=3 each): {noformat} cassandra.WriteTimeout: Error from server: code=1100 [Coordinator node timed out waiting for replica nodes' responses] message="Operation timed out - received only 0 responses." info={'consistency': 'LOCAL_ONE', 'required_responses': 1, 'received_responses': 0} {noformat} Reproduction steps: {noformat} # Setup cluster ccm create -n 3:3 test for i in {1..6}; do echo 'max_mutation_size_in_kb: 1000' >> ~/.ccm/test/node$i/conf/cassandra.yaml; done ccm start # Create schema ccm node1 cqlsh CREATE KEYSPACE test WITH replication = {'class': 'NetworkTopologyStrategy', 'dc1': 3, 'dc2': 3}; CREATE TABLE test.test (key int PRIMARY KEY, val blob); exit; # Insert data python from cassandra.cluster import Cluster cluster = Cluster() session = cluster.connect('test') blob = f = open("2mbBlob", "rb").read().hex() session.execute("INSERT INTO test (key, val) VALUES (1, textAsBlob('" + blob + "'))") {noformat} Reproduced in 3.0, 3.11, trunk. > Replica failure causes timeout on multi-DC write > ------------------------------------------------ > > Key: CASSANDRA-16334 > URL: https://issues.apache.org/jira/browse/CASSANDRA-16334 > Project: Cassandra > Issue Type: Bug > Components: Consistency/Coordination, Messaging/Internode > Reporter: Paulo Motta > Assignee: Aleksandr Sorokoumov > Priority: Normal > > Inserting a mutation larger than {{max_mutation_size_in_kb}} correctly throws > a write error on a single DC keyspace with RF=3: > {noformat} > cassandra.WriteFailure: Error from server: code=1500 [Replica(s) failed to > execute write] message="Operation failed - received 0 responses and 3 > failures: UNKNOWN from /127.0.0.3:7000, UNKNOWN from /127.0.0.2:7000, UNKNOWN > from /127.0.0.1:7000" info={'consistency': 'LOCAL_ONE', 'required_responses': > 1, 'received_responses': 0, 'failures': 3} > {noformat} > The same insert wrongly causes a timeout on a keyspace with 2 dcs (RF=3 each): > {noformat} > cassandra.WriteTimeout: Error from server: code=1100 [Coordinator node timed > out waiting for replica nodes' responses] message="Operation timed out - > received only 0 responses." info={'consistency': 'LOCAL_ONE', > 'required_responses': 1, 'received_responses': 0} > {noformat} > Reproduction steps: > {noformat} > # Setup cluster > ccm create -n 3:3 test > for i in {1..6}; do echo 'max_mutation_size_in_kb: 1000' >> > ~/.ccm/test/node$i/conf/cassandra.yaml; done > ccm start > # Create schema > ccm node1 cqlsh > CREATE KEYSPACE test WITH replication = {'class': 'NetworkTopologyStrategy', > 'dc1': 3, 'dc2': 3}; > CREATE TABLE test.test (key int PRIMARY KEY, val blob); > exit; > # Insert data > python > from cassandra.cluster import Cluster > cluster = Cluster() > session = cluster.connect('test') > blob = f = open("2mbBlob", "rb").read().hex() > session.execute("INSERT INTO test (key, val) VALUES (1, textAsBlob('" + blob > + "'))") > {noformat} > Reproduced in 3.0, 3.11, 4.0, trunk. -- This message was sent by Atlassian Jira (v8.3.4#803005) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org