[jira] [Commented] (CASSANDRA-12457) dtest failure in upgrade_tests.cql_tests.TestCQLNodes2RF1_Upgrade_current_2_1_x_To_indev_2_2_x.bug_5732_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15454370#comment-15454370 ] Stefania commented on CASSANDRA-12457: -- The run based on the unpatched 2.2 had one [failure|http://cassci.datastax.com/view/Dev/view/stef1927/job/stef1927-dtest-multiplex/61/testReport/junit/node_2_iter_011.upgrade_tests.cql_tests/TestCQLNodes2RF1_Upgrade_current_2_2_x_To_indev_3_0_x/bug_5732_test/], so there must be something in my patch that prevents the failure, unless this has become extremely difficult to reproduce and it failed on 2.2 just by chance. I'm launching another build [here|http://cassci.datastax.com/view/Dev/view/stef1927/job/stef1927-dtest-multiplex/62/] with even fewer changes in my patch, specifically I removed the added logs in Ref.java. However, I've added back the logs in the sstable instance tidier, hoping for some more clues. > dtest failure in > upgrade_tests.cql_tests.TestCQLNodes2RF1_Upgrade_current_2_1_x_To_indev_2_2_x.bug_5732_test > > > Key: CASSANDRA-12457 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12457 > Project: Cassandra > Issue Type: Bug >Reporter: Craig Kodman >Assignee: Stefania > Labels: dtest > Fix For: 2.2.x > > Attachments: 12457_2.1_logs_with_allocation_stacks.tar.gz, > 12457_2.2_logs_with_allocation_stacks_1.tar.gz, > 12457_2.2_logs_with_allocation_stacks_2.tar.gz, > 12457_2.2_logs_with_allocation_stacks_3.tar.gz, > 12457_2.2_logs_with_allocation_stacks_4.tar.gz, node1.log, node1_debug.log, > node1_gc.log, node2.log > > > example failure: > http://cassci.datastax.com/job/cassandra-2.2_dtest_upgrade/16/testReport/upgrade_tests.cql_tests/TestCQLNodes2RF1_Upgrade_current_2_1_x_To_indev_2_2_x/bug_5732_test > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 358, in run > self.tearDown() > File "/home/automaton/cassandra-dtest/upgrade_tests/upgrade_base.py", line > 216, in tearDown > super(UpgradeTester, self).tearDown() > File "/home/automaton/cassandra-dtest/dtest.py", line 666, in tearDown > raise AssertionError('Unexpected error in log, see stdout') > "Unexpected error in log, see stdout\n >> begin captured > logging << \ndtest: DEBUG: Upgrade test beginning, > setting CASSANDRA_VERSION to 2.1.15, and jdk to 8. (Prior values will be > restored after test).\ndtest: DEBUG: cluster ccm directory: > /mnt/tmp/dtest-D8UF3i\ndtest: DEBUG: Done setting configuration options:\n{ > 'initial_token': None,\n'num_tokens': '32',\n'phi_convict_threshold': > 5,\n'range_request_timeout_in_ms': 1,\n > 'read_request_timeout_in_ms': 1,\n'request_timeout_in_ms': 1,\n > 'truncate_request_timeout_in_ms': 1,\n'write_request_timeout_in_ms': > 1}\ndtest: DEBUG: [[Row(table_name=u'ks', index_name=u'test.testindex')], > [Row(table_name=u'ks', index_name=u'test.testindex')]]\ndtest: DEBUG: > upgrading node1 to git:91f7387e1f785b18321777311a5c3416af0663c2\nccm: INFO: > Fetching Cassandra updates...\ndtest: DEBUG: Querying upgraded node\ndtest: > DEBUG: Querying old node\ndtest: DEBUG: removing ccm cluster test at: > /mnt/tmp/dtest-D8UF3i\ndtest: DEBUG: clearing ssl stores from > [/mnt/tmp/dtest-D8UF3i] directory\n- >> end captured > logging << -" > {code} > {code} > Standard Output > http://git-wip-us.apache.org/repos/asf/cassandra.git > git:91f7387e1f785b18321777311a5c3416af0663c2 > Unexpected error in node1 log, error: > ERROR [Reference-Reaper:1] 2016-08-13 01:34:34,581 Ref.java:199 - LEAK > DETECTED: a reference > (org.apache.cassandra.utils.concurrent.Ref$State@73deb57f) to class > org.apache.cassandra.io.sstable.SSTableReader$DescriptorTypeTidy@2098812276:/mnt/tmp/dtest-D8UF3i/test/node1/data1/system/schema_columns-296e9c049bec3085827dc17d3df2122a/system-schema_columns-ka-4 > was not released before the reference was garbage collected > Unexpected error in node1 log, error: > ERROR [Reference-Reaper:1] 2016-08-13 01:34:34,581 Ref.java:199 - LEAK > DETECTED: a reference > (org.apache.cassandra.utils.concurrent.Ref$State@7926de0f) to class > org.apache.cassandra.utils.concurrent.WrappedSharedCloseable$1@1009016655:[[OffHeapBitSet]] > was not released before the reference was garbage collected > Unexpected error in node1 log, error: > ERROR [Reference-Reaper:1] 2016-08-13 01:34:34,581 Ref.java:199 - LEAK > DETECTED: a reference > (org.apache.cassandra.utils.concurrent.Ref$State@3a5760f9) to class >
[jira] [Commented] (CASSANDRA-12423) Cells missing from compact storage table after upgrading from 2.1.9 to 3.7
[ https://issues.apache.org/jira/browse/CASSANDRA-12423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15454222#comment-15454222 ] Stefania commented on CASSANDRA-12423: -- I've created a dtest pull request [here|https://github.com/riptano/cassandra-dtest/pull/1297]. > Cells missing from compact storage table after upgrading from 2.1.9 to 3.7 > -- > > Key: CASSANDRA-12423 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12423 > Project: Cassandra > Issue Type: Bug >Reporter: Tomasz Grabiec >Assignee: Stefania > Attachments: 12423.tar.gz > > > Schema: > {code} > create table ks1.test ( id int, c1 text, c2 text, v int, primary key (id, c1, > c2)) with compact storage and compression = {'sstable_compression': ''}; > {code} > sstable2json before upgrading: > {code} > [ > {"key": "1", > "cells": [["","0",1470761440040513], >["a","asd",2470761440040513,"t",1470764842], >["asd:","0",1470761451368658], >["asd:asd","0",1470761449416613]]} > ] > {code} > Query result with 2.1.9: > {code} > cqlsh> select * from ks1.test; > id | c1 | c2 | v > +-+--+--- > 1 | | null | 0 > 1 | asd | | 0 > 1 | asd | asd | 0 > (3 rows) > {code} > Query result with 3.7: > {code} > cqlsh> select * from ks1.test; > id | 6331 | 6332 | v > +--+--+--- > 1 | | null | 0 > (1 rows) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12423) Cells missing from compact storage table after upgrading from 2.1.9 to 3.7
[ https://issues.apache.org/jira/browse/CASSANDRA-12423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15454204#comment-15454204 ] Stefania commented on CASSANDRA-12423: -- I've moved the logic of the patch to {{decodeBound}} and removed {{CompositeComponent}} in the [3.0 patch|https://github.com/stef1927/cassandra/commits/12423-3.0-b], see if it looks better now [~slebresne]. I think we should also split out a new method to decode the bound kind, I did not do it yet because it makes comparing harder. > Cells missing from compact storage table after upgrading from 2.1.9 to 3.7 > -- > > Key: CASSANDRA-12423 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12423 > Project: Cassandra > Issue Type: Bug >Reporter: Tomasz Grabiec >Assignee: Stefania > Attachments: 12423.tar.gz > > > Schema: > {code} > create table ks1.test ( id int, c1 text, c2 text, v int, primary key (id, c1, > c2)) with compact storage and compression = {'sstable_compression': ''}; > {code} > sstable2json before upgrading: > {code} > [ > {"key": "1", > "cells": [["","0",1470761440040513], >["a","asd",2470761440040513,"t",1470764842], >["asd:","0",1470761451368658], >["asd:asd","0",1470761449416613]]} > ] > {code} > Query result with 2.1.9: > {code} > cqlsh> select * from ks1.test; > id | c1 | c2 | v > +-+--+--- > 1 | | null | 0 > 1 | asd | | 0 > 1 | asd | asd | 0 > (3 rows) > {code} > Query result with 3.7: > {code} > cqlsh> select * from ks1.test; > id | 6331 | 6332 | v > +--+--+--- > 1 | | null | 0 > (1 rows) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12457) dtest failure in upgrade_tests.cql_tests.TestCQLNodes2RF1_Upgrade_current_2_1_x_To_indev_2_2_x.bug_5732_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15454087#comment-15454087 ] Stefania commented on CASSANDRA-12457: -- Run [above|http://cassci.datastax.com/view/Dev/view/stef1927/job/stef1927-dtest-multiplex/60/] completed again without failures. So right now I have no idea why we cannot reproduce this any longer. Launching another run [here|http://cassci.datastax.com/view/Dev/view/stef1927/job/stef1927-dtest-multiplex/61] using the unpatched 2.2 branch. > dtest failure in > upgrade_tests.cql_tests.TestCQLNodes2RF1_Upgrade_current_2_1_x_To_indev_2_2_x.bug_5732_test > > > Key: CASSANDRA-12457 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12457 > Project: Cassandra > Issue Type: Bug >Reporter: Craig Kodman >Assignee: Stefania > Labels: dtest > Fix For: 2.2.x > > Attachments: 12457_2.1_logs_with_allocation_stacks.tar.gz, > 12457_2.2_logs_with_allocation_stacks_1.tar.gz, > 12457_2.2_logs_with_allocation_stacks_2.tar.gz, > 12457_2.2_logs_with_allocation_stacks_3.tar.gz, > 12457_2.2_logs_with_allocation_stacks_4.tar.gz, node1.log, node1_debug.log, > node1_gc.log, node2.log > > > example failure: > http://cassci.datastax.com/job/cassandra-2.2_dtest_upgrade/16/testReport/upgrade_tests.cql_tests/TestCQLNodes2RF1_Upgrade_current_2_1_x_To_indev_2_2_x/bug_5732_test > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 358, in run > self.tearDown() > File "/home/automaton/cassandra-dtest/upgrade_tests/upgrade_base.py", line > 216, in tearDown > super(UpgradeTester, self).tearDown() > File "/home/automaton/cassandra-dtest/dtest.py", line 666, in tearDown > raise AssertionError('Unexpected error in log, see stdout') > "Unexpected error in log, see stdout\n >> begin captured > logging << \ndtest: DEBUG: Upgrade test beginning, > setting CASSANDRA_VERSION to 2.1.15, and jdk to 8. (Prior values will be > restored after test).\ndtest: DEBUG: cluster ccm directory: > /mnt/tmp/dtest-D8UF3i\ndtest: DEBUG: Done setting configuration options:\n{ > 'initial_token': None,\n'num_tokens': '32',\n'phi_convict_threshold': > 5,\n'range_request_timeout_in_ms': 1,\n > 'read_request_timeout_in_ms': 1,\n'request_timeout_in_ms': 1,\n > 'truncate_request_timeout_in_ms': 1,\n'write_request_timeout_in_ms': > 1}\ndtest: DEBUG: [[Row(table_name=u'ks', index_name=u'test.testindex')], > [Row(table_name=u'ks', index_name=u'test.testindex')]]\ndtest: DEBUG: > upgrading node1 to git:91f7387e1f785b18321777311a5c3416af0663c2\nccm: INFO: > Fetching Cassandra updates...\ndtest: DEBUG: Querying upgraded node\ndtest: > DEBUG: Querying old node\ndtest: DEBUG: removing ccm cluster test at: > /mnt/tmp/dtest-D8UF3i\ndtest: DEBUG: clearing ssl stores from > [/mnt/tmp/dtest-D8UF3i] directory\n- >> end captured > logging << -" > {code} > {code} > Standard Output > http://git-wip-us.apache.org/repos/asf/cassandra.git > git:91f7387e1f785b18321777311a5c3416af0663c2 > Unexpected error in node1 log, error: > ERROR [Reference-Reaper:1] 2016-08-13 01:34:34,581 Ref.java:199 - LEAK > DETECTED: a reference > (org.apache.cassandra.utils.concurrent.Ref$State@73deb57f) to class > org.apache.cassandra.io.sstable.SSTableReader$DescriptorTypeTidy@2098812276:/mnt/tmp/dtest-D8UF3i/test/node1/data1/system/schema_columns-296e9c049bec3085827dc17d3df2122a/system-schema_columns-ka-4 > was not released before the reference was garbage collected > Unexpected error in node1 log, error: > ERROR [Reference-Reaper:1] 2016-08-13 01:34:34,581 Ref.java:199 - LEAK > DETECTED: a reference > (org.apache.cassandra.utils.concurrent.Ref$State@7926de0f) to class > org.apache.cassandra.utils.concurrent.WrappedSharedCloseable$1@1009016655:[[OffHeapBitSet]] > was not released before the reference was garbage collected > Unexpected error in node1 log, error: > ERROR [Reference-Reaper:1] 2016-08-13 01:34:34,581 Ref.java:199 - LEAK > DETECTED: a reference > (org.apache.cassandra.utils.concurrent.Ref$State@3a5760f9) to class > org.apache.cassandra.io.util.MmappedSegmentedFile$Cleanup@223486002:/mnt/tmp/dtest-D8UF3i/test/node1/data0/system/schema_columns-296e9c049bec3085827dc17d3df2122a/system-schema_columns-ka-3-Index.db > was not released before the reference was garbage collected > Unexpected error in node1 log, error: > ERROR [Reference-Reaper:1] 2016-08-13 01:34:34,582 Ref.java:199 - LEAK > DETECTED: a reference > (org.apache.cassandra.utils.concurrent.Ref$State@42cb4131) to class >
[jira] [Updated] (CASSANDRA-12481) dtest failure in cqlshlib.test.test_cqlsh_output.TestCqlshOutput.test_describe_keyspace_output
[ https://issues.apache.org/jira/browse/CASSANDRA-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefania updated CASSANDRA-12481: - Component/s: Testing > dtest failure in > cqlshlib.test.test_cqlsh_output.TestCqlshOutput.test_describe_keyspace_output > -- > > Key: CASSANDRA-12481 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12481 > Project: Cassandra > Issue Type: Bug > Components: Testing >Reporter: Craig Kodman >Assignee: Stefania > Labels: dtest > Fix For: 2.2.8, 3.0.9, 3.10 > > > example failure: > http://cassci.datastax.com/job/cassandra-3.0_cqlsh_tests/29/testReport/cqlshlib.test.test_cqlsh_output/TestCqlshOutput/test_describe_keyspace_output > {code} > Error Message > errors={'127.0.0.1': 'Client request timeout. See > Session.execute[_async](timeout)'}, last_host=127.0.0.1 > {code} > http://cassci.datastax.com/job/cassandra-3.0_cqlsh_tests/lastCompletedBuild/cython=no,label=ctool-lab/testReport/cqlshlib.test.test_cqlsh_output/TestCqlshOutput/test_describe_keyspace_output/ -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12481) dtest failure in cqlshlib.test.test_cqlsh_output.TestCqlshOutput.test_describe_keyspace_output
[ https://issues.apache.org/jira/browse/CASSANDRA-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefania updated CASSANDRA-12481: - Resolution: Fixed Fix Version/s: 3.10 3.0.9 2.2.8 Status: Resolved (was: Patch Available) > dtest failure in > cqlshlib.test.test_cqlsh_output.TestCqlshOutput.test_describe_keyspace_output > -- > > Key: CASSANDRA-12481 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12481 > Project: Cassandra > Issue Type: Bug > Components: Testing >Reporter: Craig Kodman >Assignee: Stefania > Labels: dtest > Fix For: 2.2.8, 3.0.9, 3.10 > > > example failure: > http://cassci.datastax.com/job/cassandra-3.0_cqlsh_tests/29/testReport/cqlshlib.test.test_cqlsh_output/TestCqlshOutput/test_describe_keyspace_output > {code} > Error Message > errors={'127.0.0.1': 'Client request timeout. See > Session.execute[_async](timeout)'}, last_host=127.0.0.1 > {code} > http://cassci.datastax.com/job/cassandra-3.0_cqlsh_tests/lastCompletedBuild/cython=no,label=ctool-lab/testReport/cqlshlib.test.test_cqlsh_output/TestCqlshOutput/test_describe_keyspace_output/ -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12481) dtest failure in cqlshlib.test.test_cqlsh_output.TestCqlshOutput.test_describe_keyspace_output
[ https://issues.apache.org/jira/browse/CASSANDRA-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15454072#comment-15454072 ] Stefania commented on CASSANDRA-12481: -- Thanks, patch committed to 2.2 as 40c2d45c5ed3828c8f5e3aebec673b81d231d465 and merged into 3.0 and trunk. > dtest failure in > cqlshlib.test.test_cqlsh_output.TestCqlshOutput.test_describe_keyspace_output > -- > > Key: CASSANDRA-12481 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12481 > Project: Cassandra > Issue Type: Bug >Reporter: Craig Kodman >Assignee: Stefania > Labels: dtest > > example failure: > http://cassci.datastax.com/job/cassandra-3.0_cqlsh_tests/29/testReport/cqlshlib.test.test_cqlsh_output/TestCqlshOutput/test_describe_keyspace_output > {code} > Error Message > errors={'127.0.0.1': 'Client request timeout. See > Session.execute[_async](timeout)'}, last_host=127.0.0.1 > {code} > http://cassci.datastax.com/job/cassandra-3.0_cqlsh_tests/lastCompletedBuild/cython=no,label=ctool-lab/testReport/cqlshlib.test.test_cqlsh_output/TestCqlshOutput/test_describe_keyspace_output/ -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[2/6] cassandra git commit: cqlshlib tests: increase default execute timeout
cqlshlib tests: increase default execute timeout Patch by Stefania Alborghetti; reviewed by Philip Thompson for CASSANDRA-12481 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/40c2d45c Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/40c2d45c Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/40c2d45c Branch: refs/heads/cassandra-3.0 Commit: 40c2d45c5ed3828c8f5e3aebec673b81d231d465 Parents: 77924b3 Author: Stefania AlborghettiAuthored: Wed Aug 31 15:13:45 2016 +0800 Committer: Stefania Alborghetti Committed: Thu Sep 1 10:18:35 2016 +0800 -- CHANGES.txt| 1 + pylib/cqlshlib/test/cassconnect.py | 2 ++ 2 files changed, 3 insertions(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/40c2d45c/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index d7e9394..a6a1114 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.2.8 + * cqlshlib tests: increase default execute timeout (CASSANDRA-12481) * Forward writes to replacement node when replace_address != broadcast_address (CASSANDRA-8523) * Enable repair -pr and -local together (fix regression of CASSANDRA-7450) (CASSANDRA-12522) * Fail repair on non-existing table (CASSANDRA-12279) http://git-wip-us.apache.org/repos/asf/cassandra/blob/40c2d45c/pylib/cqlshlib/test/cassconnect.py -- diff --git a/pylib/cqlshlib/test/cassconnect.py b/pylib/cqlshlib/test/cassconnect.py index 4a1311e..71f7565 100644 --- a/pylib/cqlshlib/test/cassconnect.py +++ b/pylib/cqlshlib/test/cassconnect.py @@ -116,6 +116,8 @@ def cassandra_cursor(cql_version=None, ks=''): conn = get_cassandra_connection(cql_version=cql_version) try: c = conn.connect(ks) +# increase default timeout to fix flacky tests, see CASSANDRA-12481 +c.default_timeout = 60.0 # if ks is not None: # c.execute('USE %s;' % quote_name(c, ks)) yield c
[3/6] cassandra git commit: cqlshlib tests: increase default execute timeout
cqlshlib tests: increase default execute timeout Patch by Stefania Alborghetti; reviewed by Philip Thompson for CASSANDRA-12481 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/40c2d45c Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/40c2d45c Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/40c2d45c Branch: refs/heads/trunk Commit: 40c2d45c5ed3828c8f5e3aebec673b81d231d465 Parents: 77924b3 Author: Stefania AlborghettiAuthored: Wed Aug 31 15:13:45 2016 +0800 Committer: Stefania Alborghetti Committed: Thu Sep 1 10:18:35 2016 +0800 -- CHANGES.txt| 1 + pylib/cqlshlib/test/cassconnect.py | 2 ++ 2 files changed, 3 insertions(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/40c2d45c/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index d7e9394..a6a1114 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.2.8 + * cqlshlib tests: increase default execute timeout (CASSANDRA-12481) * Forward writes to replacement node when replace_address != broadcast_address (CASSANDRA-8523) * Enable repair -pr and -local together (fix regression of CASSANDRA-7450) (CASSANDRA-12522) * Fail repair on non-existing table (CASSANDRA-12279) http://git-wip-us.apache.org/repos/asf/cassandra/blob/40c2d45c/pylib/cqlshlib/test/cassconnect.py -- diff --git a/pylib/cqlshlib/test/cassconnect.py b/pylib/cqlshlib/test/cassconnect.py index 4a1311e..71f7565 100644 --- a/pylib/cqlshlib/test/cassconnect.py +++ b/pylib/cqlshlib/test/cassconnect.py @@ -116,6 +116,8 @@ def cassandra_cursor(cql_version=None, ks=''): conn = get_cassandra_connection(cql_version=cql_version) try: c = conn.connect(ks) +# increase default timeout to fix flacky tests, see CASSANDRA-12481 +c.default_timeout = 60.0 # if ks is not None: # c.execute('USE %s;' % quote_name(c, ks)) yield c
[4/6] cassandra git commit: Merge branch 'cassandra-2.2' into cassandra-3.0
Merge branch 'cassandra-2.2' into cassandra-3.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/20dd606e Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/20dd606e Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/20dd606e Branch: refs/heads/trunk Commit: 20dd606e7bf49f3954af85407b65e304401fed7d Parents: a1d9a02 40c2d45 Author: Stefania AlborghettiAuthored: Thu Sep 1 10:19:25 2016 +0800 Committer: Stefania Alborghetti Committed: Thu Sep 1 10:19:25 2016 +0800 -- CHANGES.txt| 1 + pylib/cqlshlib/test/cassconnect.py | 2 ++ 2 files changed, 3 insertions(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/20dd606e/CHANGES.txt -- diff --cc CHANGES.txt index 8fde74e,a6a1114..0d425d6 --- a/CHANGES.txt +++ b/CHANGES.txt @@@ -1,51 -1,5 +1,52 @@@ -2.2.8 +3.0.9 + * Fix legacy regex for temporary files from 2.2 (CASSANDRA-12565) + * Add option to state current gc_grace_seconds to tools/bin/sstablemetadata (CASSANDRA-12208) + * Fix file system race condition that may cause LogAwareFileLister to fail to classify files (CASSANDRA-11889) + * Fix file handle leaks due to simultaneous compaction/repair and + listing snapshots, calculating snapshot sizes, or making schema + changes (CASSANDRA-11594) + * Fix nodetool repair exits with 0 for some errors (CASSANDRA-12508) + * Do not shut down BatchlogManager twice during drain (CASSANDRA-12504) + * Disk failure policy should not be invoked on out of space (CASSANDRA-12385) + * Calculate last compacted key on startup (CASSANDRA-6216) + * Add schema to snapshot manifest, add USING TIMESTAMP clause to ALTER TABLE statements (CASSANDRA-7190) + * Fix clean interval not sent to commit log for empty memtable flush (CASSANDRA-12436) + * Fix potential resource leak in RMIServerSocketFactoryImpl (CASSANDRA-12331) + * Backport CASSANDRA-12002 (CASSANDRA-12177) + * Make sure compaction stats are updated when compaction is interrupted (CASSANDRA-12100) + * Fix potential bad messaging service message for paged range reads + within mixed-version 3.x clusters (CASSANDRA-12249) + * Change commitlog and sstables to track dirty and clean intervals (CASSANDRA-11828) + * NullPointerException during compaction on table with static columns (CASSANDRA-12336) + * Fixed ConcurrentModificationException when reading metrics in GraphiteReporter (CASSANDRA-11823) + * Fix upgrade of super columns on thrift (CASSANDRA-12335) + * Fixed flacky BlacklistingCompactionsTest, switched to fixed size types and increased corruption size (CASSANDRA-12359) + * Rerun ReplicationAwareTokenAllocatorTest on failure to avoid flakiness (CASSANDRA-12277) + * Exception when computing read-repair for range tombstones (CASSANDRA-12263) + * Lost counter writes in compact table and static columns (CASSANDRA-12219) + * AssertionError with MVs on updating a row that isn't indexed due to a null value (CASSANDRA-12247) + * Disable RR and speculative retry with EACH_QUORUM reads (CASSANDRA-11980) + * Add option to override compaction space check (CASSANDRA-12180) + * Faster startup by only scanning each directory for temporary files once (CASSANDRA-12114) + * Respond with v1/v2 protocol header when responding to driver that attempts + to connect with too low of a protocol version (CASSANDRA-11464) + * NullPointerExpception when reading/compacting table (CASSANDRA-11988) + * Fix problem with undeleteable rows on upgrade to new sstable format (CASSANDRA-12144) + * Fix paging logic for deleted partitions with static columns (CASSANDRA-12107) + * Wait until the message is being send to decide which serializer must be used (CASSANDRA-11393) + * Fix migration of static thrift column names with non-text comparators (CASSANDRA-12147) + * Fix upgrading sparse tables that are incorrectly marked as dense (CASSANDRA-11315) + * Fix reverse queries ignoring range tombstones (CASSANDRA-11733) + * Avoid potential race when rebuilding CFMetaData (CASSANDRA-12098) + * Avoid missing sstables when getting the canonical sstables (CASSANDRA-11996) + * Always select the live sstables when getting sstables in bounds (CASSANDRA-11944) + * Fix column ordering of results with static columns for Thrift requests in + a mixed 2.x/3.x cluster, also fix potential non-resolved duplication of + those static columns in query results (CASSANDRA-12123) + * Avoid digest mismatch with empty but static rows (CASSANDRA-12090) + * Fix EOF exception when altering column type (CASSANDRA-11820) +Merged from 2.2: + * cqlshlib tests: increase default execute timeout (CASSANDRA-12481) *
[5/6] cassandra git commit: Merge branch 'cassandra-2.2' into cassandra-3.0
Merge branch 'cassandra-2.2' into cassandra-3.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/20dd606e Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/20dd606e Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/20dd606e Branch: refs/heads/cassandra-3.0 Commit: 20dd606e7bf49f3954af85407b65e304401fed7d Parents: a1d9a02 40c2d45 Author: Stefania AlborghettiAuthored: Thu Sep 1 10:19:25 2016 +0800 Committer: Stefania Alborghetti Committed: Thu Sep 1 10:19:25 2016 +0800 -- CHANGES.txt| 1 + pylib/cqlshlib/test/cassconnect.py | 2 ++ 2 files changed, 3 insertions(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/20dd606e/CHANGES.txt -- diff --cc CHANGES.txt index 8fde74e,a6a1114..0d425d6 --- a/CHANGES.txt +++ b/CHANGES.txt @@@ -1,51 -1,5 +1,52 @@@ -2.2.8 +3.0.9 + * Fix legacy regex for temporary files from 2.2 (CASSANDRA-12565) + * Add option to state current gc_grace_seconds to tools/bin/sstablemetadata (CASSANDRA-12208) + * Fix file system race condition that may cause LogAwareFileLister to fail to classify files (CASSANDRA-11889) + * Fix file handle leaks due to simultaneous compaction/repair and + listing snapshots, calculating snapshot sizes, or making schema + changes (CASSANDRA-11594) + * Fix nodetool repair exits with 0 for some errors (CASSANDRA-12508) + * Do not shut down BatchlogManager twice during drain (CASSANDRA-12504) + * Disk failure policy should not be invoked on out of space (CASSANDRA-12385) + * Calculate last compacted key on startup (CASSANDRA-6216) + * Add schema to snapshot manifest, add USING TIMESTAMP clause to ALTER TABLE statements (CASSANDRA-7190) + * Fix clean interval not sent to commit log for empty memtable flush (CASSANDRA-12436) + * Fix potential resource leak in RMIServerSocketFactoryImpl (CASSANDRA-12331) + * Backport CASSANDRA-12002 (CASSANDRA-12177) + * Make sure compaction stats are updated when compaction is interrupted (CASSANDRA-12100) + * Fix potential bad messaging service message for paged range reads + within mixed-version 3.x clusters (CASSANDRA-12249) + * Change commitlog and sstables to track dirty and clean intervals (CASSANDRA-11828) + * NullPointerException during compaction on table with static columns (CASSANDRA-12336) + * Fixed ConcurrentModificationException when reading metrics in GraphiteReporter (CASSANDRA-11823) + * Fix upgrade of super columns on thrift (CASSANDRA-12335) + * Fixed flacky BlacklistingCompactionsTest, switched to fixed size types and increased corruption size (CASSANDRA-12359) + * Rerun ReplicationAwareTokenAllocatorTest on failure to avoid flakiness (CASSANDRA-12277) + * Exception when computing read-repair for range tombstones (CASSANDRA-12263) + * Lost counter writes in compact table and static columns (CASSANDRA-12219) + * AssertionError with MVs on updating a row that isn't indexed due to a null value (CASSANDRA-12247) + * Disable RR and speculative retry with EACH_QUORUM reads (CASSANDRA-11980) + * Add option to override compaction space check (CASSANDRA-12180) + * Faster startup by only scanning each directory for temporary files once (CASSANDRA-12114) + * Respond with v1/v2 protocol header when responding to driver that attempts + to connect with too low of a protocol version (CASSANDRA-11464) + * NullPointerExpception when reading/compacting table (CASSANDRA-11988) + * Fix problem with undeleteable rows on upgrade to new sstable format (CASSANDRA-12144) + * Fix paging logic for deleted partitions with static columns (CASSANDRA-12107) + * Wait until the message is being send to decide which serializer must be used (CASSANDRA-11393) + * Fix migration of static thrift column names with non-text comparators (CASSANDRA-12147) + * Fix upgrading sparse tables that are incorrectly marked as dense (CASSANDRA-11315) + * Fix reverse queries ignoring range tombstones (CASSANDRA-11733) + * Avoid potential race when rebuilding CFMetaData (CASSANDRA-12098) + * Avoid missing sstables when getting the canonical sstables (CASSANDRA-11996) + * Always select the live sstables when getting sstables in bounds (CASSANDRA-11944) + * Fix column ordering of results with static columns for Thrift requests in + a mixed 2.x/3.x cluster, also fix potential non-resolved duplication of + those static columns in query results (CASSANDRA-12123) + * Avoid digest mismatch with empty but static rows (CASSANDRA-12090) + * Fix EOF exception when altering column type (CASSANDRA-11820) +Merged from 2.2: + * cqlshlib tests: increase default execute timeout (CASSANDRA-12481)
[6/6] cassandra git commit: Merge branch 'cassandra-3.0' into trunk
Merge branch 'cassandra-3.0' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/45f96c86 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/45f96c86 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/45f96c86 Branch: refs/heads/trunk Commit: 45f96c86e640ed9694c4341cb82788e669ae655c Parents: ce84226 20dd606 Author: Stefania AlborghettiAuthored: Thu Sep 1 10:22:01 2016 +0800 Committer: Stefania Alborghetti Committed: Thu Sep 1 10:22:01 2016 +0800 -- CHANGES.txt| 1 + pylib/cqlshlib/test/cassconnect.py | 2 ++ 2 files changed, 3 insertions(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/45f96c86/CHANGES.txt -- diff --cc CHANGES.txt index 66b6d1d,0d425d6..1d26edf --- a/CHANGES.txt +++ b/CHANGES.txt @@@ -66,51 -10,12 +66,52 @@@ Merged from 3.0 * Disk failure policy should not be invoked on out of space (CASSANDRA-12385) * Calculate last compacted key on startup (CASSANDRA-6216) * Add schema to snapshot manifest, add USING TIMESTAMP clause to ALTER TABLE statements (CASSANDRA-7190) +Merged from 2.2: ++ * cqlshlib tests: increase default execute timeout (CASSANDRA-12481) + * Forward writes to replacement node when replace_address != broadcast_address (CASSANDRA-8523) + * Fail repair on non-existing table (CASSANDRA-12279) + * Enable repair -pr and -local together (fix regression of CASSANDRA-7450) (CASSANDRA-12522) + + +3.8, 3.9 + * Fix value skipping with counter columns (CASSANDRA-11726) + * Fix nodetool tablestats miss SSTable count (CASSANDRA-12205) + * Fixed flacky SSTablesIteratedTest (CASSANDRA-12282) + * Fixed flacky SSTableRewriterTest: check file counts before calling validateCFS (CASSANDRA-12348) + * cqlsh: Fix handling of $$-escaped strings (CASSANDRA-12189) + * Fix SSL JMX requiring truststore containing server cert (CASSANDRA-12109) + * RTE from new CDC column breaks in flight queries (CASSANDRA-12236) + * Fix hdr logging for single operation workloads (CASSANDRA-12145) + * Fix SASI PREFIX search in CONTAINS mode with partial terms (CASSANDRA-12073) + * Increase size of flushExecutor thread pool (CASSANDRA-12071) + * Partial revert of CASSANDRA-11971, cannot recycle buffer in SP.sendMessagesToNonlocalDC (CASSANDRA-11950) + * Upgrade netty to 4.0.39 (CASSANDRA-12032, CASSANDRA-12034) + * Improve details in compaction log message (CASSANDRA-12080) + * Allow unset values in CQLSSTableWriter (CASSANDRA-11911) + * Chunk cache to request compressor-compatible buffers if pool space is exhausted (CASSANDRA-11993) + * Remove DatabaseDescriptor dependencies from SequentialWriter (CASSANDRA-11579) + * Move skip_stop_words filter before stemming (CASSANDRA-12078) + * Support seek() in EncryptedFileSegmentInputStream (CASSANDRA-11957) + * SSTable tools mishandling LocalPartitioner (CASSANDRA-12002) + * When SEPWorker assigned work, set thread name to match pool (CASSANDRA-11966) + * Add cross-DC latency metrics (CASSANDRA-11596) + * Allow terms in selection clause (CASSANDRA-10783) + * Add bind variables to trace (CASSANDRA-11719) + * Switch counter shards' clock to timestamps (CASSANDRA-9811) + * Introduce HdrHistogram and response/service/wait separation to stress tool (CASSANDRA-11853) + * entry-weighers in QueryProcessor should respect partitionKeyBindIndexes field (CASSANDRA-11718) + * Support older ant versions (CASSANDRA-11807) + * Estimate compressed on disk size when deciding if sstable size limit reached (CASSANDRA-11623) + * cassandra-stress profiles should support case sensitive schemas (CASSANDRA-11546) + * Remove DatabaseDescriptor dependency from FileUtils (CASSANDRA-11578) + * Faster streaming (CASSANDRA-9766) + * Add prepared query parameter to trace for "Execute CQL3 prepared query" session (CASSANDRA-11425) + * Add repaired percentage metric (CASSANDRA-11503) + * Add Change-Data-Capture (CASSANDRA-8844) +Merged from 3.0: * Fix clean interval not sent to commit log for empty memtable flush (CASSANDRA-12436) * Fix potential resource leak in RMIServerSocketFactoryImpl (CASSANDRA-12331) - * Backport CASSANDRA-12002 (CASSANDRA-12177) * Make sure compaction stats are updated when compaction is interrupted (CASSANDRA-12100) - * Fix potential bad messaging service message for paged range reads - within mixed-version 3.x clusters (CASSANDRA-12249) * Change commitlog and sstables to track dirty and clean intervals (CASSANDRA-11828) * NullPointerException during compaction on table with static columns (CASSANDRA-12336) * Fixed ConcurrentModificationException when reading metrics in
[1/6] cassandra git commit: cqlshlib tests: increase default execute timeout
Repository: cassandra Updated Branches: refs/heads/cassandra-2.2 77924b37c -> 40c2d45c5 refs/heads/cassandra-3.0 a1d9a0295 -> 20dd606e7 refs/heads/trunk ce8422631 -> 45f96c86e cqlshlib tests: increase default execute timeout Patch by Stefania Alborghetti; reviewed by Philip Thompson for CASSANDRA-12481 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/40c2d45c Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/40c2d45c Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/40c2d45c Branch: refs/heads/cassandra-2.2 Commit: 40c2d45c5ed3828c8f5e3aebec673b81d231d465 Parents: 77924b3 Author: Stefania AlborghettiAuthored: Wed Aug 31 15:13:45 2016 +0800 Committer: Stefania Alborghetti Committed: Thu Sep 1 10:18:35 2016 +0800 -- CHANGES.txt| 1 + pylib/cqlshlib/test/cassconnect.py | 2 ++ 2 files changed, 3 insertions(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/40c2d45c/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index d7e9394..a6a1114 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.2.8 + * cqlshlib tests: increase default execute timeout (CASSANDRA-12481) * Forward writes to replacement node when replace_address != broadcast_address (CASSANDRA-8523) * Enable repair -pr and -local together (fix regression of CASSANDRA-7450) (CASSANDRA-12522) * Fail repair on non-existing table (CASSANDRA-12279) http://git-wip-us.apache.org/repos/asf/cassandra/blob/40c2d45c/pylib/cqlshlib/test/cassconnect.py -- diff --git a/pylib/cqlshlib/test/cassconnect.py b/pylib/cqlshlib/test/cassconnect.py index 4a1311e..71f7565 100644 --- a/pylib/cqlshlib/test/cassconnect.py +++ b/pylib/cqlshlib/test/cassconnect.py @@ -116,6 +116,8 @@ def cassandra_cursor(cql_version=None, ks=''): conn = get_cassandra_connection(cql_version=cql_version) try: c = conn.connect(ks) +# increase default timeout to fix flacky tests, see CASSANDRA-12481 +c.default_timeout = 60.0 # if ks is not None: # c.execute('USE %s;' % quote_name(c, ks)) yield c
[jira] [Commented] (CASSANDRA-12525) When adding new nodes to a cluster which has authentication enabled, we end up losing cassandra user's current crendentials and they get reverted back to default c
[ https://issues.apache.org/jira/browse/CASSANDRA-12525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15454064#comment-15454064 ] Atin Sood commented on CASSANDRA-12525: --- Sam, unfortunately don't have these handy ATM, but let me try to get these by next week. We were able to consistently replicate this and have the cluster handy in dev, so let me get you the logs as soon as I free up from my day to day work. Appreciate you looking into this. > When adding new nodes to a cluster which has authentication enabled, we end > up losing cassandra user's current crendentials and they get reverted back to > default cassandra/cassandra crendetials > - > > Key: CASSANDRA-12525 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12525 > Project: Cassandra > Issue Type: Bug > Components: Configuration >Reporter: Atin Sood >Priority: Minor > > Made the following observation: > When adding new nodes to an existing C* cluster with authentication enabled > we end up loosing password information about `cassandra` user. > Initial Setup > - Create a 5 node cluster with system_auth having RF=5 and > NetworkTopologyStrategy > - Enable PasswordAuthenticator on this cluster and update the password for > 'cassandra' user to say 'password' via the alter query > - Make sure you run nodetool repair on all the nodes > Test case > - Now go ahead and add 5 more nodes to this cluster. > - Run nodetool repair on all the 10 nodes now > - Decommission the original 5 nodes such that only the new 5 nodes are in the > cluster now > - Run cqlsh and try to connect to this cluster using old user name and > password, cassandra/password > I was unable to connect to the nodes with the original credentials and was > only able to connect using the default cassandra/cassandra credentials > From the conversation over IIRC > `beobal: sood: that definitely shouldn't happen. The new nodes should only > create the default superuser role if there are 0 roles currently defined > (including that default one)` -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12565) Node may not start when upgrading from 2.2 to 3.0 if drain is not run
[ https://issues.apache.org/jira/browse/CASSANDRA-12565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15454046#comment-15454046 ] Stefania commented on CASSANDRA-12565: -- 2 dtest failures but unrelated to this patch: one failure is a new test that needed a rebase whilst the other one is already happening on unpatched trunk. Committed to 3.0 as a1d9a0295c54aa044eedef7812f8ac89cc62fb2b and merged into trunk. > Node may not start when upgrading from 2.2 to 3.0 if drain is not run > - > > Key: CASSANDRA-12565 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12565 > Project: Cassandra > Issue Type: Bug > Components: Local Write-Read Paths >Reporter: Stefania >Assignee: Stefania > Fix For: 3.0.9, 3.10 > > > Whilst debugging CASSANDRA-12457, I noticed that if we don't stop compactions > when draining the 2.2 node, then we may fail to restart the node after > upgrading to 3.0. > This is because sstable names in 2.2 have been changed from _la_ to _lb_ but > [{{LEGACY_TMP_REGEX_STR}}|https://github.com/apache/cassandra/blob/trunk/src/java/org/apache/cassandra/io/sstable/Descriptor.java#L187] > in Descriptor.java doe not match _lb_ sstables and therefore it won't clean > or ignore temporary files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12565) Node may not start when upgrading from 2.2 to 3.0 if drain is not run
[ https://issues.apache.org/jira/browse/CASSANDRA-12565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefania updated CASSANDRA-12565: - Resolution: Fixed Fix Version/s: (was: 3.0.x) (was: 3.x) 3.10 3.0.9 Status: Resolved (was: Patch Available) > Node may not start when upgrading from 2.2 to 3.0 if drain is not run > - > > Key: CASSANDRA-12565 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12565 > Project: Cassandra > Issue Type: Bug > Components: Local Write-Read Paths >Reporter: Stefania >Assignee: Stefania > Fix For: 3.0.9, 3.10 > > > Whilst debugging CASSANDRA-12457, I noticed that if we don't stop compactions > when draining the 2.2 node, then we may fail to restart the node after > upgrading to 3.0. > This is because sstable names in 2.2 have been changed from _la_ to _lb_ but > [{{LEGACY_TMP_REGEX_STR}}|https://github.com/apache/cassandra/blob/trunk/src/java/org/apache/cassandra/io/sstable/Descriptor.java#L187] > in Descriptor.java doe not match _lb_ sstables and therefore it won't clean > or ignore temporary files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[3/3] cassandra git commit: Merge branch 'cassandra-3.0' into trunk
Merge branch 'cassandra-3.0' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/ce842263 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/ce842263 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/ce842263 Branch: refs/heads/trunk Commit: ce84226318d159b8e2f173aa80f998632446ecc4 Parents: 03a3f95 a1d9a02 Author: Stefania AlborghettiAuthored: Thu Sep 1 10:06:57 2016 +0800 Committer: Stefania Alborghetti Committed: Thu Sep 1 10:06:57 2016 +0800 -- CHANGES.txt | 1 + .../org/apache/cassandra/io/sstable/Descriptor.java | 2 +- .../tmp-lb-3-big-Data.db | Bin 0 -> 93 bytes .../tmp-lb-3-big-Index.db | Bin 0 -> 54 bytes .../org/apache/cassandra/db/SystemKeyspaceTest.java | 8 5 files changed, 6 insertions(+), 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/ce842263/CHANGES.txt -- diff --cc CHANGES.txt index 4919d19,8fde74e..66b6d1d --- a/CHANGES.txt +++ b/CHANGES.txt @@@ -1,60 -1,5 +1,61 @@@ -3.0.9 +3.10 + * Add keep-alive to streaming (CASSANDRA-11841) + * Tracing payload is passed through newSession(..) (CASSANDRA-11706) + * avoid deleting non existing sstable files and improve related log messages (CASSANDRA-12261) + * json/yaml output format for nodetool compactionhistory (CASSANDRA-12486) + * Retry all internode messages once after a connection is + closed and reopened (CASSANDRA-12192) + * Add support to rebuild from targeted replica (CASSANDRA-9875) + * Add sequence distribution type to cassandra stress (CASSANDRA-12490) + * "SELECT * FROM foo LIMIT ;" does not error out (CASSANDRA-12154) + * Define executeLocally() at the ReadQuery Level (CASSANDRA-12474) + * Extend read/write failure messages with a map of replica addresses + to error codes in the v5 native protocol (CASSANDRA-12311) + * Fix rebuild of SASI indexes with existing index files (CASSANDRA-12374) + * Let DatabaseDescriptor not implicitly startup services (CASSANDRA-9054, 12550) + * Fix clustering indexes in presence of static columns in SASI (CASSANDRA-12378) + * Fix queries on columns with reversed type on SASI indexes (CASSANDRA-12223) + * Added slow query log (CASSANDRA-12403) + * Count full coordinated request against timeout (CASSANDRA-12256) + * Allow TTL with null value on insert and update (CASSANDRA-12216) + * Make decommission operation resumable (CASSANDRA-12008) + * Add support to one-way targeted repair (CASSANDRA-9876) + * Remove clientutil jar (CASSANDRA-11635) + * Fix compaction throughput throttle (CASSANDRA-12366) + * Delay releasing Memtable memory on flush until PostFlush has finished running (CASSANDRA-12358) + * Cassandra stress should dump all setting on startup (CASSANDRA-11914) + * Make it possible to compact a given token range (CASSANDRA-10643) + * Allow updating DynamicEndpointSnitch properties via JMX (CASSANDRA-12179) + * Collect metrics on queries by consistency level (CASSANDRA-7384) + * Add support for GROUP BY to SELECT statement (CASSANDRA-10707) + * Deprecate memtable_cleanup_threshold and update default for memtable_flush_writers (CASSANDRA-12228) + * Upgrade to OHC 0.4.4 (CASSANDRA-12133) + * Add version command to cassandra-stress (CASSANDRA-12258) + * Create compaction-stress tool (CASSANDRA-11844) + * Garbage-collecting compaction operation and schema option (CASSANDRA-7019) + * Add beta protocol flag for v5 native protocol (CASSANDRA-12142) + * Support filtering on non-PRIMARY KEY columns in the CREATE + MATERIALIZED VIEW statement's WHERE clause (CASSANDRA-10368) + * Unify STDOUT and SYSTEMLOG logback format (CASSANDRA-12004) + * COPY FROM should raise error for non-existing input files (CASSANDRA-12174) + * Faster write path (CASSANDRA-12269) + * Option to leave omitted columns in INSERT JSON unset (CASSANDRA-11424) + * Support json/yaml output in nodetool tpstats (CASSANDRA-12035) + * Expose metrics for successful/failed authentication attempts (CASSANDRA-10635) + * Prepend snapshot name with "truncated" or "dropped" when a snapshot + is taken before truncating or dropping a table (CASSANDRA-12178) + * Optimize RestrictionSet (CASSANDRA-12153) + * cqlsh does not automatically downgrade CQL version (CASSANDRA-12150) + * Omit (de)serialization of state variable in UDAs (CASSANDRA-9613) + * Create a system table to expose prepared statements (CASSANDRA-8831) + * Reuse DataOutputBuffer from ColumnIndex (CASSANDRA-11970) + * Remove DatabaseDescriptor dependency from SegmentedFile (CASSANDRA-11580) + * Add
[2/3] cassandra git commit: Fix legacy regex for temporary files from 2.2
Fix legacy regex for temporary files from 2.2 Patch by Stefania Alborghetti; reviewed by Robert Stupp for CASSANDRA-12565 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/a1d9a029 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/a1d9a029 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/a1d9a029 Branch: refs/heads/trunk Commit: a1d9a0295c54aa044eedef7812f8ac89cc62fb2b Parents: b56def4 Author: Stefania AlborghettiAuthored: Tue Aug 30 17:09:16 2016 +0800 Committer: Stefania Alborghetti Committed: Thu Sep 1 10:05:37 2016 +0800 -- CHANGES.txt | 1 + .../org/apache/cassandra/io/sstable/Descriptor.java | 2 +- .../tmp-lb-3-big-Data.db | Bin 0 -> 93 bytes .../tmp-lb-3-big-Index.db | Bin 0 -> 54 bytes .../org/apache/cassandra/db/SystemKeyspaceTest.java | 8 5 files changed, 6 insertions(+), 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 30931d3..8fde74e 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 3.0.9 + * Fix legacy regex for temporary files from 2.2 (CASSANDRA-12565) * Add option to state current gc_grace_seconds to tools/bin/sstablemetadata (CASSANDRA-12208) * Fix file system race condition that may cause LogAwareFileLister to fail to classify files (CASSANDRA-11889) * Fix file handle leaks due to simultaneous compaction/repair and http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/src/java/org/apache/cassandra/io/sstable/Descriptor.java -- diff --git a/src/java/org/apache/cassandra/io/sstable/Descriptor.java b/src/java/org/apache/cassandra/io/sstable/Descriptor.java index ff4abfc..e979a7d 100644 --- a/src/java/org/apache/cassandra/io/sstable/Descriptor.java +++ b/src/java/org/apache/cassandra/io/sstable/Descriptor.java @@ -186,7 +186,7 @@ public class Descriptor private final static String LEGACY_COMP_IN_PROG_REGEX_STR = "^compactions_in_progress(\\-[\\d,a-f]{32})?$"; private final static Pattern LEGACY_COMP_IN_PROG_REGEX = Pattern.compile(LEGACY_COMP_IN_PROG_REGEX_STR); -private final static String LEGACY_TMP_REGEX_STR = "^((.*)\\-(.*)\\-)?tmp(link)?\\-(la|ka)\\-(\\d)*\\-(.*)$"; +private final static String LEGACY_TMP_REGEX_STR = "^((.*)\\-(.*)\\-)?tmp(link)?\\-((?:l|k).)\\-(\\d)*\\-(.*)$"; private final static Pattern LEGACY_TMP_REGEX = Pattern.compile(LEGACY_TMP_REGEX_STR); public static boolean isLegacyFile(File file) http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Data.db -- diff --git a/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Data.db b/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Data.db new file mode 100644 index 000..2d5e60a Binary files /dev/null and b/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Data.db differ http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Index.db -- diff --git a/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Index.db b/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Index.db new file mode 100644 index 000..d3923ab Binary files /dev/null and b/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Index.db differ http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java -- diff --git a/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java b/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java index d770610..8e58373 100644 --- a/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java +++ b/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java @@ -178,23 +178,23 @@ public class SystemKeyspaceTest @Test public void testMigrateDataDirs_2_1() throws IOException { -testMigrateDataDirs("2.1"); +testMigrateDataDirs("2.1", 5); // see test
[1/3] cassandra git commit: Fix legacy regex for temporary files from 2.2
Repository: cassandra Updated Branches: refs/heads/cassandra-3.0 b56def49f -> a1d9a0295 refs/heads/trunk 03a3f9552 -> ce8422631 Fix legacy regex for temporary files from 2.2 Patch by Stefania Alborghetti; reviewed by Robert Stupp for CASSANDRA-12565 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/a1d9a029 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/a1d9a029 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/a1d9a029 Branch: refs/heads/cassandra-3.0 Commit: a1d9a0295c54aa044eedef7812f8ac89cc62fb2b Parents: b56def4 Author: Stefania AlborghettiAuthored: Tue Aug 30 17:09:16 2016 +0800 Committer: Stefania Alborghetti Committed: Thu Sep 1 10:05:37 2016 +0800 -- CHANGES.txt | 1 + .../org/apache/cassandra/io/sstable/Descriptor.java | 2 +- .../tmp-lb-3-big-Data.db | Bin 0 -> 93 bytes .../tmp-lb-3-big-Index.db | Bin 0 -> 54 bytes .../org/apache/cassandra/db/SystemKeyspaceTest.java | 8 5 files changed, 6 insertions(+), 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 30931d3..8fde74e 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 3.0.9 + * Fix legacy regex for temporary files from 2.2 (CASSANDRA-12565) * Add option to state current gc_grace_seconds to tools/bin/sstablemetadata (CASSANDRA-12208) * Fix file system race condition that may cause LogAwareFileLister to fail to classify files (CASSANDRA-11889) * Fix file handle leaks due to simultaneous compaction/repair and http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/src/java/org/apache/cassandra/io/sstable/Descriptor.java -- diff --git a/src/java/org/apache/cassandra/io/sstable/Descriptor.java b/src/java/org/apache/cassandra/io/sstable/Descriptor.java index ff4abfc..e979a7d 100644 --- a/src/java/org/apache/cassandra/io/sstable/Descriptor.java +++ b/src/java/org/apache/cassandra/io/sstable/Descriptor.java @@ -186,7 +186,7 @@ public class Descriptor private final static String LEGACY_COMP_IN_PROG_REGEX_STR = "^compactions_in_progress(\\-[\\d,a-f]{32})?$"; private final static Pattern LEGACY_COMP_IN_PROG_REGEX = Pattern.compile(LEGACY_COMP_IN_PROG_REGEX_STR); -private final static String LEGACY_TMP_REGEX_STR = "^((.*)\\-(.*)\\-)?tmp(link)?\\-(la|ka)\\-(\\d)*\\-(.*)$"; +private final static String LEGACY_TMP_REGEX_STR = "^((.*)\\-(.*)\\-)?tmp(link)?\\-((?:l|k).)\\-(\\d)*\\-(.*)$"; private final static Pattern LEGACY_TMP_REGEX = Pattern.compile(LEGACY_TMP_REGEX_STR); public static boolean isLegacyFile(File file) http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Data.db -- diff --git a/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Data.db b/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Data.db new file mode 100644 index 000..2d5e60a Binary files /dev/null and b/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Data.db differ http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Index.db -- diff --git a/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Index.db b/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Index.db new file mode 100644 index 000..d3923ab Binary files /dev/null and b/test/data/migration-sstables/2.2/keyspace1/test-dfcc85801bc811e5aa694b06169f4ffa/tmp-lb-3-big-Index.db differ http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1d9a029/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java -- diff --git a/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java b/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java index d770610..8e58373 100644 --- a/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java +++ b/test/unit/org/apache/cassandra/db/SystemKeyspaceTest.java @@ -178,23 +178,23 @@ public class SystemKeyspaceTest @Test public void
[jira] [Commented] (CASSANDRA-12578) dtest failure in repair_tests.repair_test.TestRepair.nonexistent_table_repair_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453944#comment-15453944 ] Joel Knighton commented on CASSANDRA-12578: --- This is a new test - I think it might just need to be version-gated. > dtest failure in > repair_tests.repair_test.TestRepair.nonexistent_table_repair_test > -- > > Key: CASSANDRA-12578 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12578 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: DS Test Eng > Labels: dtest > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log > > > example failure: > http://cassci.datastax.com/job/cassandra-3.9_dtest/50/testReport/repair_tests.repair_test/TestRepair/nonexistent_table_repair_test > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/repair_tests/repair_test.py", line > 210, in nonexistent_table_repair_test > self.assertFalse(t.isAlive(), 'Repair thread on inexistent table is still > running') > File "/usr/lib/python2.7/unittest/case.py", line 416, in assertFalse > raise self.failureException(msg) > "Repair thread on inexistent table is still running > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12092) dtest failure in consistency_test.TestAccuracy.test_simple_strategy_counters
[ https://issues.apache.org/jira/browse/CASSANDRA-12092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefania updated CASSANDRA-12092: - Component/s: Testing > dtest failure in consistency_test.TestAccuracy.test_simple_strategy_counters > > > Key: CASSANDRA-12092 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12092 > Project: Cassandra > Issue Type: Test > Components: Testing >Reporter: Sean McCarthy >Assignee: Stefania > Labels: dtest > Attachments: jenkins-stef1927-dtest-multiplex-23_logs.000.tar.gz, > node1.log, node2.log, node3.log > > > example failure: > http://cassci.datastax.com/job/cassandra-2.1_dtest/484/testReport/consistency_test/TestAccuracy/test_simple_strategy_counters > Failed on CassCI build cassandra-2.1_dtest #484 > {code} > Standard Error > Traceback (most recent call last): > File "/home/automaton/cassandra-dtest/consistency_test.py", line 514, in run > valid_fcn(v) > File "/home/automaton/cassandra-dtest/consistency_test.py", line 497, in > validate_counters > check_all_sessions(s, n, c) > File "/home/automaton/cassandra-dtest/consistency_test.py", line 490, in > check_all_sessions > "value of %s at key %d, instead got these values: %s" % (write_nodes, > val, n, results) > AssertionError: Failed to read value from sufficient number of nodes, > required 2 nodes to have a counter value of 1 at key 200, instead got these > values: [0, 0, 1] > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12092) dtest failure in consistency_test.TestAccuracy.test_simple_strategy_counters
[ https://issues.apache.org/jira/browse/CASSANDRA-12092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefania updated CASSANDRA-12092: - Resolution: Fixed Status: Resolved (was: Patch Available) Thank you for merging the PR, closing. > dtest failure in consistency_test.TestAccuracy.test_simple_strategy_counters > > > Key: CASSANDRA-12092 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12092 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: Stefania > Labels: dtest > Attachments: jenkins-stef1927-dtest-multiplex-23_logs.000.tar.gz, > node1.log, node2.log, node3.log > > > example failure: > http://cassci.datastax.com/job/cassandra-2.1_dtest/484/testReport/consistency_test/TestAccuracy/test_simple_strategy_counters > Failed on CassCI build cassandra-2.1_dtest #484 > {code} > Standard Error > Traceback (most recent call last): > File "/home/automaton/cassandra-dtest/consistency_test.py", line 514, in run > valid_fcn(v) > File "/home/automaton/cassandra-dtest/consistency_test.py", line 497, in > validate_counters > check_all_sessions(s, n, c) > File "/home/automaton/cassandra-dtest/consistency_test.py", line 490, in > check_all_sessions > "value of %s at key %d, instead got these values: %s" % (write_nodes, > val, n, results) > AssertionError: Failed to read value from sufficient number of nodes, > required 2 nodes to have a counter value of 1 at key 200, instead got these > values: [0, 0, 1] > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12237) Cassandra stress graphing is broken
[ https://issues.apache.org/jira/browse/CASSANDRA-12237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453878#comment-15453878 ] Joel Knighton commented on CASSANDRA-12237: --- +1 after some minor nits. Thanks for the patch! - the test {{delegatesToAdditionalPrintStrams()}} should be {{delegatesToAdditionalPrintStreams()}} - You have a comment starting with "as far as I can tell this is always true". The false branch will be taken when settings.rate.minThreads is less than or equal to 0. While you are correct in the case that minthreads is set, when a fixed thread count is given to the rate option, minthreads will be set to -1 and the false branch will be taken. > Cassandra stress graphing is broken > --- > > Key: CASSANDRA-12237 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12237 > Project: Cassandra > Issue Type: Bug > Components: Tools >Reporter: Christopher Batey >Assignee: Christopher Batey > Fix For: 3.x > > Attachments: 12237-trunk.txt > > > Cassandra stress relies on a tmp file with the stress output so it can parse > it and put it the the graph html. > However the contents of this file is now broken: > {code} > Sleeping 2s...Sleeping 2s... > Sleeping 2s... > Warming up WRITE with 5 iterations...Warming up WRITE with 5 > iterations... > Warming up WRITE with 5 iterations... > Running WRITE with 500 threads 10 secondsRunning WRITE with 500 threads 10 > seconds > Running WRITE with 500 threads 10 seconds > ... > {code} > This is as we create a {code}MultiPrintStream{code} that inherits from > {code}PrintWriter{code} and then delegate the call to super as well as a list > of other PrintWriters > The call to super for println comes back into our print method so every line > gets logged multiple times as we do the for (PrintStream s: newStreams) many > times. > We can change this to use composition and use our own interface if we want to > use a composite for logging the results > This results in the parsing of this file not quite working and the aggregate > stats not working in produced graphs. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12485) Always require replace_address to replace existing token
[ https://issues.apache.org/jira/browse/CASSANDRA-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453785#comment-15453785 ] Paulo Motta commented on CASSANDRA-12485: - bq. is that correct? Hmm, not really. You should add a new check on {{StorageService.checkForEndpointCollision}}, similar to the {{isSafeForStartup}}), but instead of checking if a live node with the same IP exists, this should check if there are live nodes with the same tokens as the new node and prevent bootstrap in this case. > Always require replace_address to replace existing token > > > Key: CASSANDRA-12485 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12485 > Project: Cassandra > Issue Type: Improvement > Components: Distributed Metadata >Reporter: Paulo Motta >Priority: Minor > Labels: lhf > > CASSANDRA-10134 prevented replace an existing node unless > {{\-Dcassandra.replace_address}} or > {{\-Dcassandra.allow_unsafe_replace=true}} is specified. > We should extend this behavior to tokens, preventing a node from joining the > ring if another node with the same token already existing in the ring, unless > {{\-Dcassandra.replace_address}} or > {{\-Dcassandra.allow_unsafe_replace=true}} is specified in order to avoid > catastrophic scenarios. > One scenario where this can easily happen is if you replace a node with > another node with a different IP, and after some time you restart the > original node by mistake. The original node will then take over the tokens of > the replaced node (since it has a newer gossip generation). -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12564) Stress daemon mode no longer works
[ https://issues.apache.org/jira/browse/CASSANDRA-12564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dave Brosius updated CASSANDRA-12564: - Resolution: Fixed Reviewer: Dave Brosius Status: Resolved (was: Patch Available) committed as 03a3f9552c5edd07667c9846578780b4987f114a to trunk > Stress daemon mode no longer works > -- > > Key: CASSANDRA-12564 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12564 > Project: Cassandra > Issue Type: Bug > Components: Tools >Reporter: Christopher Batey >Assignee: Christopher Batey >Priority: Minor > Labels: stress > Fix For: 3.x > > > All of settings are no longer Serializable. > I intend to fix this but if anyone gets there before me feel free to take the > issue. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
cassandra git commit: add Serializable to Stress settings for daemon mode
Repository: cassandra Updated Branches: refs/heads/trunk 42bbe0031 -> 03a3f9552 add Serializable to Stress settings for daemon mode patch by cbatey reviewed by dbrosius for CASSANDRA-12564 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/03a3f955 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/03a3f955 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/03a3f955 Branch: refs/heads/trunk Commit: 03a3f9552c5edd07667c9846578780b4987f114a Parents: 42bbe00 Author: Chris BateyAuthored: Wed Aug 31 19:55:15 2016 -0400 Committer: Dave Brosius Committed: Wed Aug 31 19:55:15 2016 -0400 -- .../stress/settings/GroupedOptions.java | 9 ++--- .../cassandra/stress/settings/Option.java | 3 +- .../stress/settings/SettingsTokenRange.java | 5 ++- .../stress/settings/StressSettingsTest.java | 39 4 files changed, 48 insertions(+), 8 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/03a3f955/tools/stress/src/org/apache/cassandra/stress/settings/GroupedOptions.java -- diff --git a/tools/stress/src/org/apache/cassandra/stress/settings/GroupedOptions.java b/tools/stress/src/org/apache/cassandra/stress/settings/GroupedOptions.java index c0a5d35..403eaac 100644 --- a/tools/stress/src/org/apache/cassandra/stress/settings/GroupedOptions.java +++ b/tools/stress/src/org/apache/cassandra/stress/settings/GroupedOptions.java @@ -22,15 +22,14 @@ package org.apache.cassandra.stress.settings; import java.io.PrintStream; +import java.io.Serializable; import java.util.HashSet; import java.util.List; import java.util.Set; import com.google.common.collect.ImmutableList; -import org.apache.cassandra.stress.util.MultiPrintStream; - -public abstract class GroupedOptions +public abstract class GroupedOptions implements Serializable { int accepted = 0; @@ -142,12 +141,12 @@ public abstract class GroupedOptions return builder.build(); } -public static String formatLong(String longDisplay, String description) +static String formatLong(String longDisplay, String description) { return String.format("%-40s %s", longDisplay, description); } -public static String formatMultiLine(String longDisplay, String description) +static String formatMultiLine(String longDisplay, String description) { return String.format("%-36s %s", longDisplay, description); } http://git-wip-us.apache.org/repos/asf/cassandra/blob/03a3f955/tools/stress/src/org/apache/cassandra/stress/settings/Option.java -- diff --git a/tools/stress/src/org/apache/cassandra/stress/settings/Option.java b/tools/stress/src/org/apache/cassandra/stress/settings/Option.java index 37701d6..24eb33a 100644 --- a/tools/stress/src/org/apache/cassandra/stress/settings/Option.java +++ b/tools/stress/src/org/apache/cassandra/stress/settings/Option.java @@ -21,9 +21,10 @@ package org.apache.cassandra.stress.settings; */ +import java.io.Serializable; import java.util.List; -abstract class Option +abstract class Option implements Serializable { abstract boolean accept(String param); http://git-wip-us.apache.org/repos/asf/cassandra/blob/03a3f955/tools/stress/src/org/apache/cassandra/stress/settings/SettingsTokenRange.java -- diff --git a/tools/stress/src/org/apache/cassandra/stress/settings/SettingsTokenRange.java b/tools/stress/src/org/apache/cassandra/stress/settings/SettingsTokenRange.java index 51db62b..648823b 100644 --- a/tools/stress/src/org/apache/cassandra/stress/settings/SettingsTokenRange.java +++ b/tools/stress/src/org/apache/cassandra/stress/settings/SettingsTokenRange.java @@ -18,6 +18,7 @@ package org.apache.cassandra.stress.settings; +import java.io.Serializable; import java.util.List; import java.util.Map; @@ -26,13 +27,13 @@ import com.google.common.primitives.Ints; import org.apache.cassandra.stress.util.MultiPrintStream; -public class SettingsTokenRange +public class SettingsTokenRange implements Serializable { public final boolean wrap; public final int splitFactor; private final TokenRangeOptions options; -public SettingsTokenRange(TokenRangeOptions options) +private SettingsTokenRange(TokenRangeOptions options) { this.options = options; this.wrap = options.wrap.setByUser(); http://git-wip-us.apache.org/repos/asf/cassandra/blob/03a3f955/tools/stress/test/unit/org/apache/cassandra/stress/settings/StressSettingsTest.java
[jira] [Updated] (CASSANDRA-12040) If a level compaction fails due to no space it should schedule the next one
[ https://issues.apache.org/jira/browse/CASSANDRA-12040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Deng updated CASSANDRA-12040: - Labels: lcs (was: ) > If a level compaction fails due to no space it should schedule the next one > - > > Key: CASSANDRA-12040 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12040 > Project: Cassandra > Issue Type: Improvement >Reporter: sankalp kohli >Assignee: sankalp kohli >Priority: Minor > Labels: lcs > Fix For: 2.1.16, 2.2.8, 3.0.9, 3.8 > > Attachments: CASSANDRA-12040_3.0.diff, CASSANDRA-12040_trunk.txt > > > If a level compaction fails the space check, it aborts but next time the > compactions are scheduled it will attempt the same one. It should skip it and > go to the next so it can find smaller compactions to do. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12510) Decommission process should raise an error flag when nodes in a DC don't have any nodes to stream data to
[ https://issues.apache.org/jira/browse/CASSANDRA-12510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paulo Motta updated CASSANDRA-12510: Labels: lhf (was: ) > Decommission process should raise an error flag when nodes in a DC don't have > any nodes to stream data to > - > > Key: CASSANDRA-12510 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12510 > Project: Cassandra > Issue Type: Bug > Components: Streaming and Messaging > Environment: C* version 3.3 >Reporter: Atin Sood >Priority: Minor > Labels: lhf > > Steps to replicate : > - Create a 3 node cluster in DC1 and create a keyspace test_keyspace with > table test_table with replication strategy NetworkTopologyStrategy , DC1=3 . > Populate some data into this table. > - Add 5 more nodes to this cluster, but in DC2. Also do not alter the > keyspace to add the new DC2 to replication (this is intentional and the > reason why the bug shows up). So the desc keyspace should still list > NetworkTopologyStrategy with DC1=3 as RF > - As expected, this will now be a 8 node cluster with 3 nodes in DC1 and 5 in > DC2 > - Now start decommissioning the nodes in DC1. Note that the decommission runs > fine on all the 3 nodes, but since the new nodes are in DC2 and the RF for > keyspace is restricted to DC1, the new 5 nodes won't get any data. > - You will now end with the 5 node cluster which has no data from the > decommissioned 3 nodes and hence ending up in data loss > I do understand that this problem could have been avoided if we perform an > alter stmt and add DC2 replication before adding the 5 nodes. But the fact > that decommission ran fine on the 3 nodes on DC1 without complaining that > there were no nodes to stream its data seems a little discomforting. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12489) consecutive repairs of same range always finds 'out of sync' in sane cluster
[ https://issues.apache.org/jira/browse/CASSANDRA-12489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453736#comment-15453736 ] Paulo Motta commented on CASSANDRA-12489: - It seems this problem is due to the use of combined incremental and subrange repair. One one hand, subrange incremental repair does not mark original sstables as repaired (CASSANDRA-10422), while incremental repair will mark streamed sstables as repaired. So, in the next execution of subrange incremental repair the mismatch will persist. So, we should either: A) Disable combination of incremental + subrange repair B) Mark sstables originating from incremental subrange repair as unrepaired WDYT [~krummas]? > consecutive repairs of same range always finds 'out of sync' in sane cluster > > > Key: CASSANDRA-12489 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12489 > Project: Cassandra > Issue Type: Bug > Components: Streaming and Messaging >Reporter: Benjamin Roth > Attachments: trace_3_10.1.log.gz, trace_3_10.2.log.gz, > trace_3_10.3.log.gz, trace_3_10.4.log.gz, trace_3_9.1.log.gz, > trace_3_9.2.log.gz > > > No matter how often or when I run the same subrange repair, it ALWAYS tells > me that some ranges are our of sync. Tested in 3.9 + 3.10 (git trunk of > 2016-08-17). The cluster is sane. All nodes are up, cluster is not overloaded. > I guess this is not a desired behaviour. I'd expect that a repair does what > it says and a consecutive repair shouldn't report "out of syncs" any more if > the cluster is sane. > Especially for tables with MVs that puts a lot of pressure during repair as > ranges are repaired over and over again. > See traces of different runs attached. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12584) document SASI functionality
[ https://issues.apache.org/jira/browse/CASSANDRA-12584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453720#comment-15453720 ] Jon Haddad commented on CASSANDRA-12584: Right, I guess I should have said that it's not available in the user docs published here: http://cassandra.apache.org/doc/latest/ > document SASI functionality > --- > > Key: CASSANDRA-12584 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12584 > Project: Cassandra > Issue Type: Improvement >Reporter: Jon Haddad > > It doesn't look like SASI indexes are documented in tree. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12584) document SASI functionality
[ https://issues.apache.org/jira/browse/CASSANDRA-12584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453710#comment-15453710 ] Jason Brown commented on CASSANDRA-12584: - It is documented in-tree: https://github.com/apache/cassandra/blob/trunk/doc/SASI.md. This is developer-level documentation (mostly), and not necessarily tailored for end users. There might be enough content and usage example, though, iirc, in that doc to pull out as a first pass at user-level docs. > document SASI functionality > --- > > Key: CASSANDRA-12584 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12584 > Project: Cassandra > Issue Type: Improvement >Reporter: Jon Haddad > > It doesn't look like SASI indexes are documented in tree. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (CASSANDRA-12584) document SASI functionality
Jon Haddad created CASSANDRA-12584: -- Summary: document SASI functionality Key: CASSANDRA-12584 URL: https://issues.apache.org/jira/browse/CASSANDRA-12584 Project: Cassandra Issue Type: Improvement Reporter: Jon Haddad It doesn't look like SASI indexes are documented in tree. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-11739) Cache key references might cause OOM on incremental repair
[ https://issues.apache.org/jira/browse/CASSANDRA-11739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Deng updated CASSANDRA-11739: - Labels: lcs repair (was: ) > Cache key references might cause OOM on incremental repair > -- > > Key: CASSANDRA-11739 > URL: https://issues.apache.org/jira/browse/CASSANDRA-11739 > Project: Cassandra > Issue Type: Bug >Reporter: Paulo Motta >Assignee: Paulo Motta > Labels: lcs, repair > Fix For: 2.1.15, 2.2.7, 3.0.7, 3.7 > > Attachments: heapdump.png > > > We keep {{SSTableReader}} references for the duration of the repair to > anti-compact later, and their tidier keep references to cache keys to be > invalidated which are only cleaned up by GC after repair is finished. These > cache keys can accumulate while repair is being executed leading to OOM for > large tables/keyspaces. > Heap dump attached. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-11906) Unstable JVM due too many files when anticompacting big LCS tables
[ https://issues.apache.org/jira/browse/CASSANDRA-11906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Deng updated CASSANDRA-11906: - Labels: lcs (was: ) > Unstable JVM due too many files when anticompacting big LCS tables > -- > > Key: CASSANDRA-11906 > URL: https://issues.apache.org/jira/browse/CASSANDRA-11906 > Project: Cassandra > Issue Type: Bug >Reporter: Stefano Ortolani >Assignee: Sean McCarthy > Labels: lcs > Fix For: 3.0.x > > > I have recently moved from C* 2.1.x to C* 3.0.6. The setup is quite > heavy: > - 13 nodes with spinning disks > - ~120 GB of data per node > - 50% of CFs are LCS and have quite wide rows. > - 2/3 CFs with LCS have more than 200 SStables > Incremental repairs do not seem to play really well with that. > I have been running some tests node by node by using the -pr option: > {code:xml} > nodetool -h localhost repair -pr keyscheme > {code} > and to my surprise the whole process takes quite some time (1 hour > minimum, 8 hours if I haven't been repairing for 5/6 days). > Yesterday I tried to run the command with the -seq option so to > decrease the number of simultanoues compactions. After a while > the node on which I was running the repair simply died during > the anticompaction phase with the following > exception in the logs. > {code:xml} > ERROR [metrics-graphite-reporter-1-thread-1] 2016-05-25 21:54:21,868 > ScheduledReporter.java:119 - RuntimeException thrown from > GraphiteReporter#report. Exception was suppressed. > java.lang.RuntimeException: Failed to list files in > /data/cassandra/data/keyschema/columnfamily-3996ce80b7ac11e48a9b6776bf484396 > at > org.apache.cassandra.db.lifecycle.LogAwareFileLister.list(LogAwareFileLister.java:57) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > org.apache.cassandra.db.lifecycle.LifecycleTransaction.getFiles(LifecycleTransaction.java:547) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > org.apache.cassandra.db.Directories$SSTableLister.filter(Directories.java:691) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > org.apache.cassandra.db.Directories$SSTableLister.listFiles(Directories.java:662) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > org.apache.cassandra.db.Directories$TrueFilesSizeVisitor.(Directories.java:981) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > org.apache.cassandra.db.Directories.getTrueAllocatedSizeIn(Directories.java:893) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > org.apache.cassandra.db.Directories.trueSnapshotsSize(Directories.java:883) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > org.apache.cassandra.db.ColumnFamilyStore.trueSnapshotsSize(ColumnFamilyStore.java:2332) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > org.apache.cassandra.metrics.TableMetrics$32.getValue(TableMetrics.java:637) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > org.apache.cassandra.metrics.TableMetrics$32.getValue(TableMetrics.java:634) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at > com.codahale.metrics.graphite.GraphiteReporter.reportGauge(GraphiteReporter.java:281) > ~[metrics-graphite-3.1.0.jar:3.1.0] > at > com.codahale.metrics.graphite.GraphiteReporter.report(GraphiteReporter.java:158) > ~[metrics-graphite-3.1.0.jar:3.1.0] > at > com.codahale.metrics.ScheduledReporter.report(ScheduledReporter.java:162) > ~[metrics-core-3.1.0.jar:3.1.0] > at > com.codahale.metrics.ScheduledReporter$1.run(ScheduledReporter.java:117) > ~[metrics-core-3.1.0.jar:3.1.0] > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > [na:1.8.0_91] > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) > [na:1.8.0_91] > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) > [na:1.8.0_91] > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) > [na:1.8.0_91] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > [na:1.8.0_91] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > [na:1.8.0_91] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91] > Caused by: java.lang.RuntimeException: java.nio.file.FileSystemException: > /data/cassandra/data/keyschema/columnfamily-3996ce80b7ac11e48a9b6776bf484396/ma_txn_anticompactionafterrepair_f20b50d0-22bd-11e6-970f-6f22464f4624.log: > Too many open files > at org.apache.cassandra.io.util.FileUtils.readLines(FileUtils.java:622) > ~[apache-cassandra-3.0.6.jar:3.0.6] > at java.util.stream.Collectors.lambda$toMap$58(Collectors.java:1321) > ~[na:1.8.0_91] > at
[jira] [Comment Edited] (CASSANDRA-12580) Fix merkle tree size calculation
[ https://issues.apache.org/jira/browse/CASSANDRA-12580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452820#comment-15452820 ] Paulo Motta edited comment on CASSANDRA-12580 at 8/31/16 10:49 PM: --- Attaching patch to fix the calculation formula to: {{int depth = numPartitions > 0 ? (int) Math.min(Math.ceil(Math.log(numPartitions) / Math.log(2)), 20) : 0;}} Besides fixing from {{ln}} to {{lg}}, this also changes the rounding formula from {{floor}} to {{ceil}}, so we overestimate the depth rather than underestimate. I added a new test on {{ValidationTest}} that runs a validation compaction with N=128 and N=1500 keys and expect the merkle tree depth to be {{ceil(lg(N))}}. I also modified the other tests on this class to use a {{ListenableFuture}} ({{CompletableFuture}} on 3.0+) instead of {{SimpleCondition}}, since the JUnit assertions are not enforced in other threads. Patch and tests available below: ||2.1||2.2||3.0||trunk|| |[branch|https://github.com/apache/cassandra/compare/cassandra-2.1...pauloricardomg:2.1-12580]|[branch|https://github.com/apache/cassandra/compare/cassandra-2.2...pauloricardomg:2.2-12580]|[branch|https://github.com/apache/cassandra/compare/cassandra-3.0...pauloricardomg:3.0-12580]|[branch|https://github.com/apache/cassandra/compare/trunk...pauloricardomg:trunk-12580]| |[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.1-12580-testall/lastCompletedBuild/testReport/]|[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.2-12580-testall/lastCompletedBuild/testReport/]|[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-3.0-12580-testall/lastCompletedBuild/testReport/]|[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-trunk-12580-testall/lastCompletedBuild/testReport/]| |[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.1-12580-dtest/lastCompletedBuild/testReport/]|[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.2-12580-dtest/lastCompletedBuild/testReport/]|[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-3.0-12580-dtest/lastCompletedBuild/testReport/]|[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-trunk-12580-dtest/lastCompletedBuild/testReport/]| was (Author: pauloricardomg): Attaching patch to fix the calculation formula to: {{int depth = numPartitions > 0 ? (int) Math.min(Math.ceil(Math.log(numPartitions) / Math.log(2)), 20) : 0;}} Besides fixing from {{ln}} to {{lg}}, this also changes the rounding formula from {{floor}} to {{ceil}}, so we overestimate the depth rather than underestimate. I added a new test on {{ValidationTest}} that runs a validation compaction with N=128 and N=1500 keys and expect the merkle tree depth to be {{ceil(lg(N))}}. I also modified the other tests on this class to use a {{ListenableFuture}} ({{CompletableFuture}} on 3.0+) instead of {{SimpleCondition}}, since the JUnit assertions are not enforced in other threads. Patch and tests available below: ||2.1||2.2||3.0||trunk|| |[branch|https://github.com/apache/cassandra/compare/cassandra-2.1...pauloricardomg:2.1-CASSANDRA-12580]|[branch|https://github.com/apache/cassandra/compare/cassandra-2.2...pauloricardomg:2.2-CASSANDRA-12580]|[branch|https://github.com/apache/cassandra/compare/cassandra-3.0...pauloricardomg:3.0-CASSANDRA-12580]|[branch|https://github.com/apache/cassandra/compare/trunk...pauloricardomg:trunk-CASSANDRA-12580]| |[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.1-CASSANDRA-12580-testall/lastCompletedBuild/testReport/]|[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.2-CASSANDRA-12580-testall/lastCompletedBuild/testReport/]|[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-3.0-CASSANDRA-12580-testall/lastCompletedBuild/testReport/]|[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-trunk-CASSANDRA-12580-testall/lastCompletedBuild/testReport/]| |[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.1-CASSANDRA-12580-dtest/lastCompletedBuild/testReport/]|[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.2-CASSANDRA-12580-dtest/lastCompletedBuild/testReport/]|[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-3.0-CASSANDRA-12580-dtest/lastCompletedBuild/testReport/]|[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-trunk-CASSANDRA-12580-dtest/lastCompletedBuild/testReport/]| > Fix merkle tree size calculation > > > Key: CASSANDRA-12580 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12580 > Project: Cassandra >
[jira] [Commented] (CASSANDRA-12152) Unknown exception caught while attempting to update MaterializedView: AssertionError: Flags = 128
[ https://issues.apache.org/jira/browse/CASSANDRA-12152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453615#comment-15453615 ] Jeff Johnson commented on CASSANDRA-12152: -- Cassandra 3.7 on RHEL 6. A 7 node cluster We see a similar error occasionally. This occurs on restart of a stopped node. In this particular case the node was shutdown with 'service cassandra stop' Posting here because this appears to be related to replaying the logs on start up, the general message is the same and the stack trace has some overlaps at: at org.apache.cassandra.db.view.TableViews.pushViewReplicaUpdates(TableViews.java:140) ~[apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.Keyspace.apply(Keyspace.java:514) [apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.Keyspace.applyFromCommitLog(Keyspace.java:409) [apache-cassandra-3.7.0.jar:3.7.0] Deleting the log files allows the node to start. This is the only way I've been able to get the node to start.node. Are there any other known work arounds? Would you recommend this be a separate issue since the rest of the stack trace is different? What other info could I provide to help? ERROR 22:03:54 Unknown exception caught while attempting to update MaterializedView! webtrader.documents_by_mailbox_and_folder java.lang.AssertionError: We shouldn't have got there is the base row had no associated entry at org.apache.cassandra.db.view.ViewUpdateGenerator.computeLivenessInfoForEntry(ViewUpdateGenerator.java:455) ~[apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.view.ViewUpdateGenerator.updateEntry(ViewUpdateGenerator.java:273) ~[apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.view.ViewUpdateGenerator.addBaseTableUpdate(ViewUpdateGenerator.java:127) ~[apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.view.TableViews.addToViewUpdateGenerators(TableViews.java:403) ~[apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.view.TableViews.generateViewUpdates(TableViews.java:236) ~[apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.view.TableViews.pushViewReplicaUpdates(TableViews.java:140) ~[apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.Keyspace.apply(Keyspace.java:514) [apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.Keyspace.applyFromCommitLog(Keyspace.java:409) [apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.runMayThrow(CommitLogReplayer.java:152) [apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) [apache-cassandra-3.7.0.jar:3.7.0] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_101] at org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164) [apache-cassandra-3.7.0.jar:3.7.0] at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105) [apache-cassandra-3.7.0.jar:3.7.0] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_101] > Unknown exception caught while attempting to update MaterializedView: > AssertionError: Flags = 128 > - > > Key: CASSANDRA-12152 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12152 > Project: Cassandra > Issue Type: Bug >Reporter: Nilson Pontello > > I have a single DC with 3 cassandra nodes. After a restart today, none of > them were capable of processing the commitlog while starting up. The > exception doesn't contains enough information about what is going on, please > check bellow: > {code} > ERROR [SharedPool-Worker-21] 2016-07-08 12:42:12,866 Keyspace.java:521 - > Unknown exception caught while attempting to update MaterializedView! > data_monitor.user_timeline > java.lang.AssertionError: Flags = 128 > at > org.apache.cassandra.db.ClusteringPrefix$Deserializer.prepare(ClusteringPrefix.java:421) > ~[apache-cassandra-3.5.jar:3.5] > at > org.apache.cassandra.db.UnfilteredDeserializer$CurrentDeserializer.prepareNext(UnfilteredDeserializer.java:172) > ~[apache-cassandra-3.5.jar:3.5] > at > org.apache.cassandra.db.UnfilteredDeserializer$CurrentDeserializer.hasNext(UnfilteredDeserializer.java:153) > ~[apache-cassandra-3.5.jar:3.5] > at > org.apache.cassandra.db.columniterator.SSTableIterator$ForwardReader.handlePreSliceData(SSTableIterator.java:96) > ~[apache-cassandra-3.5.jar:3.5] > at > org.apache.cassandra.db.columniterator.SSTableIterator$ForwardReader.hasNextInternal(SSTableIterator.java:141) > ~[apache-cassandra-3.5.jar:3.5] > at >
[jira] [Updated] (CASSANDRA-12561) LCS compaction going into infinite loop due to non-existent sstables
[ https://issues.apache.org/jira/browse/CASSANDRA-12561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Deng updated CASSANDRA-12561: - Labels: lcs (was: ) > LCS compaction going into infinite loop due to non-existent sstables > > > Key: CASSANDRA-12561 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12561 > Project: Cassandra > Issue Type: Bug >Reporter: Nimi Wariboko Jr. > Labels: lcs > > I believe this is related/similar to CASSANDRA-11373, but I'm running 3.5 and > I still have this issue. > AFAICT, this happens when getCompactionCandidates in LeveledManifest.java > returns a candidate that does not exist on disk. > Eventually, all the compaction threads back up, garbage collections start > taking an upwards of 20 seconds and messages start being dropped. > To get around this, I patched my instance with the following code in > LeveledManifest.java > {code:java} > Set removeCandidates = new HashSet<>(); > for (SSTableReader sstable : candidates) > { > if (!(new java.io.File(sstable.getFilename())).exists()) { > removeCandidates.add(sstable); > logger.warn("Not compating candidate {} because it does > not exist ({}).", sstable.getFilename(), sstable.openReason); > } > } > candidates.removeAll(removeCandidates); > if (candidates.size() < 2) > return Collections.emptyList(); > else > return candidates; > {code} > This just removes any candidate that doesn't exist on disk - however I'm not > sure what the side effects of this are. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12582) Removing static column results in ReadFailure due to CorruptSSTableException
[ https://issues.apache.org/jira/browse/CASSANDRA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Prothro updated CASSANDRA-12582: - Summary: Removing static column results in ReadFailure due to CorruptSSTableException (was: ReadFailure from CorruptSSTableException after static column removed) > Removing static column results in ReadFailure due to CorruptSSTableException > > > Key: CASSANDRA-12582 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12582 > Project: Cassandra > Issue Type: Bug > Environment: Cassandra 3.0.8 >Reporter: Evan Prothro > Labels: compaction, corruption, drop, read, static > Fix For: 3.0.9 > > Attachments: 12582.cdl, 12582_reproduce.sh > > > We ran into an issue on production where reads began to fail for certain > queries, depending on the range within the relation for those queries. > Cassandra system log showed an unhandled {{CorruptSSTableException}} > exception. > CQL read failure: > {code} > ReadFailure: code=1300 [Replica(s) failed to execute read] message="Operation > failed - received 0 responses and 1 failures" info={'failures': 1, > 'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'} > {code} > Cassandra exception: > {code} > WARN [SharedPool-Worker-2] 2016-08-31 12:49:27,979 > AbstractLocalAwareExecutorService.java:169 - Uncaught exception on thread > Thread[SharedPool-Worker-2,5,main]: {} > java.lang.RuntimeException: > org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2453) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > ~[na:1.8.0_72] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$LocalSessionFutureTask.run(AbstractLocalAwareExecutorService.java:136) > [apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105) > [apache-cassandra-3.0.8.jar:3.0.8] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.io.sstable.format.big.BigTableScanner$KeyScanningIterator$1.initializeIterator(BigTableScanner.java:343) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.maybeInit(LazilyInitializedUnfilteredRowIterator.java:48) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:66) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:62) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:24) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$Serializer.serialize(UnfilteredPartitionIterators.java:295) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.build(ReadResponse.java:134) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:127) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:123) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse.createDataResponse(ReadResponse.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.db.ReadCommand.createResponse(ReadCommand.java:289) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:1796) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at >
[jira] [Updated] (CASSANDRA-12141) dtest failure in consistency_test.TestConsistency.short_read_reversed_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuki Morishita updated CASSANDRA-12141: --- Assignee: (was: Yuki Morishita) > dtest failure in consistency_test.TestConsistency.short_read_reversed_test > -- > > Key: CASSANDRA-12141 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12141 > Project: Cassandra > Issue Type: Bug >Reporter: Sean McCarthy > Labels: dtest > Fix For: 3.x > > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log, node3.log, node3_debug.log, node3_gc.log > > > example failure: > http://cassci.datastax.com/job/trunk_offheap_dtest/280/testReport/consistency_test/TestConsistency/short_read_reversed_test > Failed on CassCI build trunk_offheap_dtest #280 > {code} > Standard Output > Unexpected error in node2 log, error: > ERROR [epollEventLoopGroup-2-5] 2016-06-27 19:14:54,412 Slf4JLogger.java:176 > - LEAK: ByteBuf.release() was not called before it's garbage-collected. > Enable advanced leak reporting to find out where the leak occurred. To enable > advanced leak reporting, specify the JVM option > '-Dio.netty.leakDetection.level=advanced' or call > ResourceLeakDetector.setLevel() See > http://netty.io/wiki/reference-counted-objects.html for more information. > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[7/7] cassandra git commit: Merge branch 'cassandra-3.0' into trunk
Merge branch 'cassandra-3.0' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/42bbe003 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/42bbe003 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/42bbe003 Branch: refs/heads/trunk Commit: 42bbe0031396f563fad857d736bb9e08c9a5fc2c Parents: 8af61ac b56def4 Author: Yuki MorishitaAuthored: Wed Aug 31 16:07:53 2016 -0500 Committer: Yuki Morishita Committed: Wed Aug 31 16:07:53 2016 -0500 -- --
[5/7] cassandra git commit: Merge branch 'cassandra-2.2' into cassandra-3.0
Merge branch 'cassandra-2.2' into cassandra-3.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b56def49 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b56def49 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b56def49 Branch: refs/heads/trunk Commit: b56def49f575c5bc7e15f6cb947f02589b5544f2 Parents: e4a53f4 77924b3 Author: Yuki MorishitaAuthored: Wed Aug 31 16:06:28 2016 -0500 Committer: Yuki Morishita Committed: Wed Aug 31 16:06:28 2016 -0500 -- .../org/apache/cassandra/net/IncomingStreamingConnection.java | 5 ++--- src/java/org/apache/cassandra/net/MessagingService.java | 4 ++-- 2 files changed, 4 insertions(+), 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b56def49/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b56def49/src/java/org/apache/cassandra/net/MessagingService.java --
[4/7] cassandra git commit: Cleanup MessagingService socket after catching Throwable (ninja #11841)
Cleanup MessagingService socket after catching Throwable (ninja #11841) Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/77924b37 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/77924b37 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/77924b37 Branch: refs/heads/cassandra-3.0 Commit: 77924b37c9bd28af8bfdc77edc9c7d6717c8085d Parents: b39d984 Author: Paulo MottaAuthored: Mon Aug 15 17:19:38 2016 -0300 Committer: Yuki Morishita Committed: Wed Aug 31 16:04:32 2016 -0500 -- .../org/apache/cassandra/net/IncomingStreamingConnection.java | 5 ++--- src/java/org/apache/cassandra/net/MessagingService.java | 4 ++-- 2 files changed, 4 insertions(+), 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/77924b37/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java -- diff --git a/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java b/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java index ab262c7..f7dc240 100644 --- a/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java +++ b/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java @@ -74,10 +74,9 @@ public class IncomingStreamingConnection extends Thread implements Closeable // parallelize said streams and the socket is blocking, so we might deadlock. StreamResultFuture.initReceivingSide(init.sessionIndex, init.planId, init.description, init.from, this, init.isForOutgoing, version, init.keepSSTableLevel, init.isIncremental); } -catch (IOException e) +catch (Throwable t) { -logger.error(String.format("IOException while reading from socket from %s, closing: %s", - socket.getRemoteSocketAddress(), e)); +logger.error("Error while reading from socket from {}.", socket.getRemoteSocketAddress(), t); close(); } } http://git-wip-us.apache.org/repos/asf/cassandra/blob/77924b37/src/java/org/apache/cassandra/net/MessagingService.java -- diff --git a/src/java/org/apache/cassandra/net/MessagingService.java b/src/java/org/apache/cassandra/net/MessagingService.java index 8c8a333..fb0c9ca 100644 --- a/src/java/org/apache/cassandra/net/MessagingService.java +++ b/src/java/org/apache/cassandra/net/MessagingService.java @@ -1034,9 +1034,9 @@ public final class MessagingService implements MessagingServiceMBean logger.error("SSL handshake error for inbound connection from " + socket, e); FileUtils.closeQuietly(socket); } -catch (IOException e) +catch (Throwable t) { -logger.trace("Error reading the socket " + socket, e); +logger.trace("Error reading the socket {}", socket, t); FileUtils.closeQuietly(socket); } }
[1/7] cassandra git commit: Add keep-alive to streaming
Repository: cassandra Updated Branches: refs/heads/cassandra-2.2 b39d984f7 -> 77924b37c refs/heads/cassandra-3.0 e4a53f4d3 -> b56def49f refs/heads/trunk 0cd48f76d -> 42bbe0031 Add keep-alive to streaming patch by Paulo Motta; reviewed by Yuki Morishita for CASSANDRA-11841 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/8af61ac3 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/8af61ac3 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/8af61ac3 Branch: refs/heads/trunk Commit: 8af61ac311b8b6e8bbff410f5f0e29bc73ca8daa Parents: 0cd48f7 Author: Paulo MottaAuthored: Wed Aug 31 16:03:00 2016 -0500 Committer: Yuki Morishita Committed: Wed Aug 31 16:03:00 2016 -0500 -- CHANGES.txt | 1 + NEWS.txt| 3 + conf/cassandra.yaml | 14 +-- .../org/apache/cassandra/config/Config.java | 6 ++ .../cassandra/config/DatabaseDescriptor.java| 10 ++ src/java/org/apache/cassandra/gms/Gossiper.java | 13 +++ .../net/IncomingStreamingConnection.java| 5 +- .../apache/cassandra/net/MessagingService.java | 4 +- .../cassandra/streaming/ConnectionHandler.java | 59 --- .../cassandra/streaming/StreamReader.java | 2 +- .../cassandra/streaming/StreamSession.java | 103 +-- .../streaming/messages/KeepAliveMessage.java| 49 + .../streaming/messages/StreamMessage.java | 15 ++- .../cassandra/utils/CassandraVersion.java | 2 +- .../cassandra/utils/CassandraVersionTest.java | 17 +++ 15 files changed, 263 insertions(+), 40 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/8af61ac3/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 0edfc76..4919d19 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 3.10 + * Add keep-alive to streaming (CASSANDRA-11841) * Tracing payload is passed through newSession(..) (CASSANDRA-11706) * avoid deleting non existing sstable files and improve related log messages (CASSANDRA-12261) * json/yaml output format for nodetool compactionhistory (CASSANDRA-12486) http://git-wip-us.apache.org/repos/asf/cassandra/blob/8af61ac3/NEWS.txt -- diff --git a/NEWS.txt b/NEWS.txt index bb21c3c..ddb1263 100644 --- a/NEWS.txt +++ b/NEWS.txt @@ -89,6 +89,9 @@ Upgrading snitch, encryption context. Client initialization just applies the configuration but does not setup anything. Instead of using Config.setClientMode() or Config.isClientMode(), which are deprecated now, use one of the appropiate new methods in DatabaseDescriptor. +- Application layer keep-alives were added to the streaming protocol to prevent idle incoming connections from + timing out and failing the stream session (CASSANDRA-11839). This effectively deprecates the streaming_socket_timeout_in_ms + property in favor of streaming_keep_alive_period_in_secs. See cassandra.yaml for more details about this property. 3.8 === http://git-wip-us.apache.org/repos/asf/cassandra/blob/8af61ac3/conf/cassandra.yaml -- diff --git a/conf/cassandra.yaml b/conf/cassandra.yaml index 5fb44cf..a25e084 100644 --- a/conf/cassandra.yaml +++ b/conf/cassandra.yaml @@ -870,13 +870,13 @@ slow_query_log_timeout_in_ms: 500 # and the times are synchronized between the nodes. cross_node_timeout: false -# Set socket timeout for streaming operation. -# The stream session is failed if no data/ack is received by any of the participants -# within that period, which means this should also be sufficient to stream a large -# sstable or rebuild table indexes. -# Default value is 8640ms, which means stale streams timeout after 24 hours. -# A value of zero means stream sockets should never time out. -# streaming_socket_timeout_in_ms: 8640 +# Set keep-alive period for streaming +# This node will send a keep-alive message periodically with this period. +# If the node does not receive a keep-alive message from the peer for +# 2 keep-alive cycles the stream session times out and fail +# Default value is 300s (5 minutes), which means stalled stream +# times out in 10 minutes by default +# streaming_keep_alive_period_in_secs: 300 # phi value that must be reached for a host to be marked down. # most users should never need to adjust this. http://git-wip-us.apache.org/repos/asf/cassandra/blob/8af61ac3/src/java/org/apache/cassandra/config/Config.java
[jira] [Updated] (CASSANDRA-11841) Add keep-alive to stream protocol
[ https://issues.apache.org/jira/browse/CASSANDRA-11841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuki Morishita updated CASSANDRA-11841: --- Labels: docs-impacting (was: ) > Add keep-alive to stream protocol > - > > Key: CASSANDRA-11841 > URL: https://issues.apache.org/jira/browse/CASSANDRA-11841 > Project: Cassandra > Issue Type: Sub-task >Reporter: Paulo Motta >Assignee: Paulo Motta > Labels: docs-impacting > Fix For: 3.10 > > -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12573) SASI index. Incorrect results for '%foo%bar%'-like search pattern.
[ https://issues.apache.org/jira/browse/CASSANDRA-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Krupitskiy updated CASSANDRA-12573: --- Priority: Critical (was: Major) > SASI index. Incorrect results for '%foo%bar%'-like search pattern. > --- > > Key: CASSANDRA-12573 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12573 > Project: Cassandra > Issue Type: Bug >Reporter: Mikhail Krupitskiy >Assignee: Arunkumar M >Priority: Critical > > We use Cassandra 3.7 and have faced a strange behaviour of SELECT requests > with 'LIKE '%foo%bar%'' constraints on a column with SASI index. > Below are few experiments that shows this behaviour. > Experiment 1: > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: no rows. > Experiment 2 (NOTE: definition of index is changed): > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS', > 'analyzer_class': > 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', > 'analyzed': 'true' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: 1qwe. > Experiment 3 (NOTE: primary key is compound now): > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, > c1)); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS', > 'analyzer_class': > 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', > 'analyzed': 'true' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: qwe, qweasd, qwea1, 1qwe. > Experiment 4 (NOTE: search criteria is changed): > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, > c1)); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS', > 'analyzer_class': > 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', > 'analyzed': 'true' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w22%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: qweasd, qwea1. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-11839) Active streams fail with SocketTimeoutException
[ https://issues.apache.org/jira/browse/CASSANDRA-11839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuki Morishita updated CASSANDRA-11839: --- Resolution: Fixed Reproduced In: 3.5, 3.0.6, 2.2.6, 2.1.14 (was: 2.1.14, 2.2.6, 3.0.6, 3.5) Status: Resolved (was: Patch Available) Closing as all sub tasks completed. > Active streams fail with SocketTimeoutException > --- > > Key: CASSANDRA-11839 > URL: https://issues.apache.org/jira/browse/CASSANDRA-11839 > Project: Cassandra > Issue Type: Bug >Reporter: Paulo Motta >Assignee: Paulo Motta > > The original reasoning behind {{streaming_socket_timeout_in_ms}} was to kill > one-sided hanging streams (CASSANDRA-3838). This was never much of a problem > when the default was zero (never timeout). > On CASSANDRA-8611 we changed the default to 1 hour, but it was never enforced > due to CASSANDRA-11286, which was fixed recently. > On recent releases we've been receiving reports of stream failures when > streaming large files, because the sender incoming socket becomes inactive, > times out after 1 hour, and the stream session fails with > {{SocketTimeoutException}} (CASSANDRA-11345, CASSANDRA-11826), even though > the stream session is still active. The session also fails if 2i/MV rebuild > takes longer than 1 hour on the receiver (CASSANDRA-8343). > The definitive fix on trunk is to add a {{KeepAlive}} message to the stream > protocol to detect broken connections and retire > {{streaming_socket_timeout_in_ms}}. But we must also increase the default > {{streaming_socket_timeout_in_ms}} in older versions to a more conservative > value, so it is still able to detect long hanging streams. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Resolved] (CASSANDRA-11841) Add keep-alive to stream protocol
[ https://issues.apache.org/jira/browse/CASSANDRA-11841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuki Morishita resolved CASSANDRA-11841. Resolution: Fixed Fix Version/s: (was: 3.x) 3.10 Thanks, committed as {{8af61ac311b8b6e8bbff410f5f0e29bc73ca8daa}} to trunk, and ninja fix as {{77924b37c9bd28af8bfdc77edc9c7d6717c8085d}}. TIL http://slf4j.org/faq.html#paramException ;) > Add keep-alive to stream protocol > - > > Key: CASSANDRA-11841 > URL: https://issues.apache.org/jira/browse/CASSANDRA-11841 > Project: Cassandra > Issue Type: Sub-task >Reporter: Paulo Motta >Assignee: Paulo Motta > Fix For: 3.10 > > -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12573) SASI index. Incorrect results for '%foo%bar%'-like search pattern.
[ https://issues.apache.org/jira/browse/CASSANDRA-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Krupitskiy updated CASSANDRA-12573: --- Description: We use Cassandra 3.7 and have faced a strange behaviour of SELECT requests with "LIKE '%foo%bar%'" constraints on a column with SASI index. Below are few experiments that show this behaviour. Experiment 1: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: no rows. Experiment 2 (NOTE: definition of index is changed): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: 1qwe. Experiment 3 (NOTE: primary key is compound now): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, c1)); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: qwe, qweasd, qwea1, 1qwe. Experiment 4 (NOTE: search criteria is changed): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, c1)); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w22%a%'; {noformat} Expected result: no rows. Actual result: qweasd, qwea1. was: We use Cassandra 3.7 and have faced a strange behaviour of SELECT requests with 'LIKE '%foo%bar%'' constraints on a column with SASI index. Below are few experiments that shows this behaviour. Experiment 1: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: no rows. Experiment 2 (NOTE: definition of index is changed): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text);
[jira] [Updated] (CASSANDRA-12573) SASI index. Incorrect results for '%foo%bar%'-like search pattern.
[ https://issues.apache.org/jira/browse/CASSANDRA-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Krupitskiy updated CASSANDRA-12573: --- Description: We use Cassandra 3.7 and have faced a strange behaviour of SELECT requests with 'LIKE '%foo%bar%'' constraints on a column with SASI index. Below are few experiments that shows this behaviour. Experiment 1: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: no rows. Experiment 2 (NOTE: definition of index is changed): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: 1qwe. Experiment 3 (NOTE: primary key is compound now): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, c1)); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: qwe, qweasd, qwea1, 1qwe. Experiment 4 (NOTE: search criteria is changed): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, c1)); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w22%a%'; {noformat} Expected result: no rows. Actual result: qweasd, qwea1. was: We use Cassandra 3.7 and have faced a strange behaviour of SELECT requests with 'LIKE '%foo%bar%'' constraints on a column with SASI index. Below are few experiments that shows this behaviour. Experiment 1: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: no rows. Experiment 2 (NOTE: definition of index is changed): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text);
[3/7] cassandra git commit: Cleanup MessagingService socket after catching Throwable (ninja #11841)
Cleanup MessagingService socket after catching Throwable (ninja #11841) Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/77924b37 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/77924b37 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/77924b37 Branch: refs/heads/trunk Commit: 77924b37c9bd28af8bfdc77edc9c7d6717c8085d Parents: b39d984 Author: Paulo MottaAuthored: Mon Aug 15 17:19:38 2016 -0300 Committer: Yuki Morishita Committed: Wed Aug 31 16:04:32 2016 -0500 -- .../org/apache/cassandra/net/IncomingStreamingConnection.java | 5 ++--- src/java/org/apache/cassandra/net/MessagingService.java | 4 ++-- 2 files changed, 4 insertions(+), 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/77924b37/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java -- diff --git a/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java b/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java index ab262c7..f7dc240 100644 --- a/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java +++ b/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java @@ -74,10 +74,9 @@ public class IncomingStreamingConnection extends Thread implements Closeable // parallelize said streams and the socket is blocking, so we might deadlock. StreamResultFuture.initReceivingSide(init.sessionIndex, init.planId, init.description, init.from, this, init.isForOutgoing, version, init.keepSSTableLevel, init.isIncremental); } -catch (IOException e) +catch (Throwable t) { -logger.error(String.format("IOException while reading from socket from %s, closing: %s", - socket.getRemoteSocketAddress(), e)); +logger.error("Error while reading from socket from {}.", socket.getRemoteSocketAddress(), t); close(); } } http://git-wip-us.apache.org/repos/asf/cassandra/blob/77924b37/src/java/org/apache/cassandra/net/MessagingService.java -- diff --git a/src/java/org/apache/cassandra/net/MessagingService.java b/src/java/org/apache/cassandra/net/MessagingService.java index 8c8a333..fb0c9ca 100644 --- a/src/java/org/apache/cassandra/net/MessagingService.java +++ b/src/java/org/apache/cassandra/net/MessagingService.java @@ -1034,9 +1034,9 @@ public final class MessagingService implements MessagingServiceMBean logger.error("SSL handshake error for inbound connection from " + socket, e); FileUtils.closeQuietly(socket); } -catch (IOException e) +catch (Throwable t) { -logger.trace("Error reading the socket " + socket, e); +logger.trace("Error reading the socket {}", socket, t); FileUtils.closeQuietly(socket); } }
[2/7] cassandra git commit: Cleanup MessagingService socket after catching Throwable (ninja #11841)
Cleanup MessagingService socket after catching Throwable (ninja #11841) Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/77924b37 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/77924b37 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/77924b37 Branch: refs/heads/cassandra-2.2 Commit: 77924b37c9bd28af8bfdc77edc9c7d6717c8085d Parents: b39d984 Author: Paulo MottaAuthored: Mon Aug 15 17:19:38 2016 -0300 Committer: Yuki Morishita Committed: Wed Aug 31 16:04:32 2016 -0500 -- .../org/apache/cassandra/net/IncomingStreamingConnection.java | 5 ++--- src/java/org/apache/cassandra/net/MessagingService.java | 4 ++-- 2 files changed, 4 insertions(+), 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/77924b37/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java -- diff --git a/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java b/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java index ab262c7..f7dc240 100644 --- a/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java +++ b/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java @@ -74,10 +74,9 @@ public class IncomingStreamingConnection extends Thread implements Closeable // parallelize said streams and the socket is blocking, so we might deadlock. StreamResultFuture.initReceivingSide(init.sessionIndex, init.planId, init.description, init.from, this, init.isForOutgoing, version, init.keepSSTableLevel, init.isIncremental); } -catch (IOException e) +catch (Throwable t) { -logger.error(String.format("IOException while reading from socket from %s, closing: %s", - socket.getRemoteSocketAddress(), e)); +logger.error("Error while reading from socket from {}.", socket.getRemoteSocketAddress(), t); close(); } } http://git-wip-us.apache.org/repos/asf/cassandra/blob/77924b37/src/java/org/apache/cassandra/net/MessagingService.java -- diff --git a/src/java/org/apache/cassandra/net/MessagingService.java b/src/java/org/apache/cassandra/net/MessagingService.java index 8c8a333..fb0c9ca 100644 --- a/src/java/org/apache/cassandra/net/MessagingService.java +++ b/src/java/org/apache/cassandra/net/MessagingService.java @@ -1034,9 +1034,9 @@ public final class MessagingService implements MessagingServiceMBean logger.error("SSL handshake error for inbound connection from " + socket, e); FileUtils.closeQuietly(socket); } -catch (IOException e) +catch (Throwable t) { -logger.trace("Error reading the socket " + socket, e); +logger.trace("Error reading the socket {}", socket, t); FileUtils.closeQuietly(socket); } }
[6/7] cassandra git commit: Merge branch 'cassandra-2.2' into cassandra-3.0
Merge branch 'cassandra-2.2' into cassandra-3.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b56def49 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b56def49 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b56def49 Branch: refs/heads/cassandra-3.0 Commit: b56def49f575c5bc7e15f6cb947f02589b5544f2 Parents: e4a53f4 77924b3 Author: Yuki MorishitaAuthored: Wed Aug 31 16:06:28 2016 -0500 Committer: Yuki Morishita Committed: Wed Aug 31 16:06:28 2016 -0500 -- .../org/apache/cassandra/net/IncomingStreamingConnection.java | 5 ++--- src/java/org/apache/cassandra/net/MessagingService.java | 4 ++-- 2 files changed, 4 insertions(+), 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b56def49/src/java/org/apache/cassandra/net/IncomingStreamingConnection.java -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b56def49/src/java/org/apache/cassandra/net/MessagingService.java --
[jira] [Updated] (CASSANDRA-12573) SASI index. No results for '%foo%bar%'-like search pattern.
[ https://issues.apache.org/jira/browse/CASSANDRA-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Krupitskiy updated CASSANDRA-12573: --- Description: We use Cassandra 3.7 and have faced a strange behaviour of SELECT requests with 'LIKE '%foo%bar%'' constraints on a column with SASI index. Below are few experiments that shows this behaviour. Experiment 1: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: no rows. Experiment 2 (NOTE: definition of index is changed): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: 1qwe. Experiment 3 (NOTE: primary key is compound now): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, c1)); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: qwe, qweasd, qwea1, 1qwe. Experiment 4 (NOTE: search criteria is changed): {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, c1)); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w22%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: qweasd, qwea1. was: We use Cassandra 3.7 and have faced a strange behaviour of SELECT requests with 'LIKE '%foo%bar%'' constraints on a column with SASI index. Below are few experiments Experiment 1: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: no rows. Experiment 2: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING
[jira] [Updated] (CASSANDRA-12573) SASI index. Incorrect results for '%foo%bar%'-like search pattern.
[ https://issues.apache.org/jira/browse/CASSANDRA-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Krupitskiy updated CASSANDRA-12573: --- Summary: SASI index. Incorrect results for '%foo%bar%'-like search pattern. (was: SASI index. No results for '%foo%bar%'-like search pattern. ) > SASI index. Incorrect results for '%foo%bar%'-like search pattern. > --- > > Key: CASSANDRA-12573 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12573 > Project: Cassandra > Issue Type: Bug >Reporter: Mikhail Krupitskiy >Assignee: Arunkumar M > > We use Cassandra 3.7 and have faced a strange behaviour of SELECT requests > with 'LIKE '%foo%bar%'' constraints on a column with SASI index. > Below are few experiments that shows this behaviour. > Experiment 1: > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: no rows. > Experiment 2 (NOTE: definition of index is changed): > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS', > 'analyzer_class': > 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', > 'analyzed': 'true' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: 1qwe. > Experiment 3 (NOTE: primary key is compound now): > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, > c1)); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS', > 'analyzer_class': > 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', > 'analyzed': 'true' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: qwe, qweasd, qwea1, 1qwe. > Experiment 4 (NOTE: search criteria is changed): > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, > c1)); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS', > 'analyzer_class': > 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', > 'analyzed': 'true' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w22%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: qweasd, qwea1. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12573) SASI index. No results for '%foo%bar%'-like search pattern.
[ https://issues.apache.org/jira/browse/CASSANDRA-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Krupitskiy updated CASSANDRA-12573: --- Description: We use Cassandra 3.7 and have faced a strange behaviour of SELECT requests with 'LIKE '%foo%bar%'' constraints on a column with SASI index. Below are few experiments Experiment 1: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: no rows. Experiment 2: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: 1qwe. Experiment 3: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, c1)); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: qwe, qweasd, qwea1, 1qwe. Experiment 4: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int, c1 text, c2 text, PRIMARY KEY(id, c1)); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w22%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: qweasd, qwea1. was: Cassandra 3.7. Experiment 1: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: no rows. Experiment 2: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ;
[jira] [Updated] (CASSANDRA-12573) SASI index. No results for '%foo%bar%'-like search pattern.
[ https://issues.apache.org/jira/browse/CASSANDRA-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Krupitskiy updated CASSANDRA-12573: --- Description: Cassandra 3.7. Experiment 1: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: no rows. Experiment 2: {noformat} drop keyspace if exists kmv; create keyspace if not exists kmv WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor':'1'} ; use kmv; CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { 'mode': 'CONTAINS', 'analyzer_class': 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', 'analyzed': 'true' }; insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; select c2 from kmv.kmv where c2 like '%w%a%'; {noformat} Expected result: qweasd, qwea1. Actual result: 1qwe. was: Cassandra 3.7. 1) Create index for String column: {noformat} CREATE CUSTOM INDEX index_name ON Table (Column) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = {'mode': 'CONTAINS'}; {noformat} 2) Insert some rows where Column contains 'foo' and 'bar'. E.g. '1foo2bar3'. 3) Try to query rows where Column contains 'foo' and 'bar'. Request {noformat}select * from Table where Column like '%foo%bar%'{noformat} returns *no* rows. > SASI index. No results for '%foo%bar%'-like search pattern. > > > Key: CASSANDRA-12573 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12573 > Project: Cassandra > Issue Type: Bug >Reporter: Mikhail Krupitskiy >Assignee: Arunkumar M > > Cassandra 3.7. > Experiment 1: > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: no rows. > Experiment 2: > {noformat} > drop keyspace if exists kmv; > create keyspace if not exists kmv WITH REPLICATION = { 'class' : > 'SimpleStrategy', 'replication_factor':'1'} ; > use kmv; > CREATE TABLE if not exists kmv (id int primary key, c1 text, c2 text); > CREATE CUSTOM INDEX ON kmv.kmv ( c2 ) USING > 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = { > 'mode': 'CONTAINS', > 'analyzer_class': > 'org.apache.cassandra.index.sasi.analyzer.StandardAnalyzer', > 'analyzed': 'true' > }; > insert into kmv (id, c1, c2) values (1, 'f21', 'qwe') ; > insert into kmv (id, c1, c2) values (1, 'f22', 'qweasd') ; > insert into kmv (id, c1, c2) values (1, 'f23', 'qwea1') ; > insert into kmv (id, c1, c2) values (1, 'f24', '1qwe') ; > select c2 from kmv.kmv where c2 like '%w%a%'; > {noformat} > Expected result: qweasd, qwea1. > Actual result: 1qwe. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12583) Code Analysis got a problem
[ https://issues.apache.org/jira/browse/CASSANDRA-12583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453268#comment-15453268 ] Edward Capriolo commented on CASSANDRA-12583: - https://github.com/edwardcapriolo/cassandra/tree/CASSANDRA-12583 > Code Analysis got a problem > --- > > Key: CASSANDRA-12583 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12583 > Project: Cassandra > Issue Type: Improvement >Reporter: Edward Capriolo >Assignee: Edward Capriolo >Priority: Minor > > {noformat} > eclipse-warnings: > [mkdir] Created dir: /home/edward/Documents/java/cassandra/build/ecj > [echo] Running Eclipse Code Analysis. Output logged to > /home/edward/Documents/java/cassandra/build/ecj/eclipse_compiler_checks.txt > [java] -- > [java] 1. ERROR in > /home/edward/Documents/java/cassandra/src/java/org/apache/cassandra/db/lifecycle/LogTransaction.java > (at line 211) > [java] PrintStream ps = new PrintStream(baos); > [java] ^^ > [java] Resource 'ps' should be managed by try-with-resource > [java] -- > [java] 1 problem (1 error) > {noformat} > Yo, ill solve it. Check out my patch while my spinning disks revolve it. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (CASSANDRA-12583) Code Analysis got a problem
Edward Capriolo created CASSANDRA-12583: --- Summary: Code Analysis got a problem Key: CASSANDRA-12583 URL: https://issues.apache.org/jira/browse/CASSANDRA-12583 Project: Cassandra Issue Type: Improvement Reporter: Edward Capriolo Assignee: Edward Capriolo Priority: Minor {noformat} eclipse-warnings: [mkdir] Created dir: /home/edward/Documents/java/cassandra/build/ecj [echo] Running Eclipse Code Analysis. Output logged to /home/edward/Documents/java/cassandra/build/ecj/eclipse_compiler_checks.txt [java] -- [java] 1. ERROR in /home/edward/Documents/java/cassandra/src/java/org/apache/cassandra/db/lifecycle/LogTransaction.java (at line 211) [java] PrintStream ps = new PrintStream(baos); [java] ^^ [java] Resource 'ps' should be managed by try-with-resource [java] -- [java] 1 problem (1 error) {noformat} Yo, ill solve it. Check out my patch while my spinning disks revolve it. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-8523) Writes should be sent to a replacement node while it is streaming in data
[ https://issues.apache.org/jira/browse/CASSANDRA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453146#comment-15453146 ] Aleksey Yeschenko commented on CASSANDRA-8523: -- Committed as [b39d984f7bd682c7638415d65dcc4ac9bcb74e5f|https://github.com/apache/cassandra/commit/b39d984f7bd682c7638415d65dcc4ac9bcb74e5f] to 2.2, merged with 3.0 and trunk. Thanks. > Writes should be sent to a replacement node while it is streaming in data > - > > Key: CASSANDRA-8523 > URL: https://issues.apache.org/jira/browse/CASSANDRA-8523 > Project: Cassandra > Issue Type: Bug >Reporter: Richard Wagner >Assignee: Paulo Motta > Fix For: 2.2.8, 3.0.9, 3.10 > > > In our operations, we make heavy use of replace_address (or > replace_address_first_boot) in order to replace broken nodes. We now realize > that writes are not sent to the replacement nodes while they are in hibernate > state and streaming in data. This runs counter to what our expectations were, > especially since we know that writes ARE sent to nodes when they are > bootstrapped into the ring. > It seems like cassandra should arrange to send writes to a node that is in > the process of replacing another node, just like it does for a nodes that are > bootstraping. I hesitate to phrase this as "we should send writes to a node > in hibernate" because the concept of hibernate may be useful in other > contexts, as per CASSANDRA-8336. Maybe a new state is needed here? > Among other things, the fact that we don't get writes during this period > makes subsequent repairs more expensive, proportional to the number of writes > that we miss (and depending on the amount of data that needs to be streamed > during replacement and the time it may take to rebuild secondary indexes, we > could miss many many hours worth of writes). It also leaves us more exposed > to consistency violations. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-8523) Writes should be sent to a replacement node while it is streaming in data
[ https://issues.apache.org/jira/browse/CASSANDRA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksey Yeschenko updated CASSANDRA-8523: - Fix Version/s: (was: 2.1.x) 3.10 3.0.9 2.2.8 > Writes should be sent to a replacement node while it is streaming in data > - > > Key: CASSANDRA-8523 > URL: https://issues.apache.org/jira/browse/CASSANDRA-8523 > Project: Cassandra > Issue Type: Bug >Reporter: Richard Wagner >Assignee: Paulo Motta > Fix For: 2.2.8, 3.0.9, 3.10 > > > In our operations, we make heavy use of replace_address (or > replace_address_first_boot) in order to replace broken nodes. We now realize > that writes are not sent to the replacement nodes while they are in hibernate > state and streaming in data. This runs counter to what our expectations were, > especially since we know that writes ARE sent to nodes when they are > bootstrapped into the ring. > It seems like cassandra should arrange to send writes to a node that is in > the process of replacing another node, just like it does for a nodes that are > bootstraping. I hesitate to phrase this as "we should send writes to a node > in hibernate" because the concept of hibernate may be useful in other > contexts, as per CASSANDRA-8336. Maybe a new state is needed here? > Among other things, the fact that we don't get writes during this period > makes subsequent repairs more expensive, proportional to the number of writes > that we miss (and depending on the amount of data that needs to be streamed > during replacement and the time it may take to rebuild secondary indexes, we > could miss many many hours worth of writes). It also leaves us more exposed > to consistency violations. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-8523) Writes should be sent to a replacement node while it is streaming in data
[ https://issues.apache.org/jira/browse/CASSANDRA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksey Yeschenko updated CASSANDRA-8523: - Resolution: Fixed Status: Resolved (was: Ready to Commit) > Writes should be sent to a replacement node while it is streaming in data > - > > Key: CASSANDRA-8523 > URL: https://issues.apache.org/jira/browse/CASSANDRA-8523 > Project: Cassandra > Issue Type: Bug >Reporter: Richard Wagner >Assignee: Paulo Motta > Fix For: 2.2.8, 3.0.9, 3.10 > > > In our operations, we make heavy use of replace_address (or > replace_address_first_boot) in order to replace broken nodes. We now realize > that writes are not sent to the replacement nodes while they are in hibernate > state and streaming in data. This runs counter to what our expectations were, > especially since we know that writes ARE sent to nodes when they are > bootstrapped into the ring. > It seems like cassandra should arrange to send writes to a node that is in > the process of replacing another node, just like it does for a nodes that are > bootstraping. I hesitate to phrase this as "we should send writes to a node > in hibernate" because the concept of hibernate may be useful in other > contexts, as per CASSANDRA-8336. Maybe a new state is needed here? > Among other things, the fact that we don't get writes during this period > makes subsequent repairs more expensive, proportional to the number of writes > that we miss (and depending on the amount of data that needs to be streamed > during replacement and the time it may take to rebuild secondary indexes, we > could miss many many hours worth of writes). It also leaves us more exposed > to consistency violations. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[1/6] cassandra git commit: Forward writes to replacement node when replace_address != broadcast_address
Repository: cassandra Updated Branches: refs/heads/cassandra-2.2 6eff0829d -> b39d984f7 refs/heads/cassandra-3.0 ab98b1151 -> e4a53f4d3 refs/heads/trunk 8a3f0e11f -> 0cd48f76d Forward writes to replacement node when replace_address != broadcast_address Patch by Paulo Motta; reviewed by Richard Low for CASSANDRA-8523 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b39d984f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b39d984f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b39d984f Branch: refs/heads/cassandra-2.2 Commit: b39d984f7bd682c7638415d65dcc4ac9bcb74e5f Parents: 6eff082 Author: Paulo MottaAuthored: Fri Jun 17 21:09:31 2016 -0300 Committer: Aleksey Yeschenko Committed: Wed Aug 31 20:21:30 2016 +0100 -- CHANGES.txt | 1 + src/java/org/apache/cassandra/gms/Gossiper.java | 5 +- .../apache/cassandra/gms/VersionedValue.java| 6 + .../apache/cassandra/locator/TokenMetadata.java | 54 ++- .../cassandra/service/LoadBroadcaster.java | 2 +- .../cassandra/service/StorageService.java | 139 +++ 6 files changed, 177 insertions(+), 30 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 0f7cf0e..d7e9394 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.2.8 + * Forward writes to replacement node when replace_address != broadcast_address (CASSANDRA-8523) * Enable repair -pr and -local together (fix regression of CASSANDRA-7450) (CASSANDRA-12522) * Fail repair on non-existing table (CASSANDRA-12279) * cqlsh copy: fix missing counter values (CASSANDRA-12476) http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/src/java/org/apache/cassandra/gms/Gossiper.java -- diff --git a/src/java/org/apache/cassandra/gms/Gossiper.java b/src/java/org/apache/cassandra/gms/Gossiper.java index 00e3da8..a8f9524 100644 --- a/src/java/org/apache/cassandra/gms/Gossiper.java +++ b/src/java/org/apache/cassandra/gms/Gossiper.java @@ -76,6 +76,7 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean static { SILENT_SHUTDOWN_STATES.addAll(DEAD_STATES); SILENT_SHUTDOWN_STATES.add(VersionedValue.STATUS_BOOTSTRAPPING); + SILENT_SHUTDOWN_STATES.add(VersionedValue.STATUS_BOOTSTRAPPING_REPLACE); } private volatile ScheduledFuture scheduledGossipTask; @@ -333,10 +334,12 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean if (epState == null) return; -logger.debug("Convicting {} with status {} - alive {}", endpoint, getGossipStatus(epState), epState.isAlive()); if (!epState.isAlive()) return; +logger.debug("Convicting {} with status {} - alive {}", endpoint, getGossipStatus(epState), epState.isAlive()); + + if (isShutdown(endpoint)) { markAsShutdown(endpoint); http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/src/java/org/apache/cassandra/gms/VersionedValue.java -- diff --git a/src/java/org/apache/cassandra/gms/VersionedValue.java b/src/java/org/apache/cassandra/gms/VersionedValue.java index 3ea7bb4..661d3ba 100644 --- a/src/java/org/apache/cassandra/gms/VersionedValue.java +++ b/src/java/org/apache/cassandra/gms/VersionedValue.java @@ -65,6 +65,7 @@ public class VersionedValue implements Comparable // values for ApplicationState.STATUS public final static String STATUS_BOOTSTRAPPING = "BOOT"; +public final static String STATUS_BOOTSTRAPPING_REPLACE = "BOOT_REPLACE"; public final static String STATUS_NORMAL = "NORMAL"; public final static String STATUS_LEAVING = "LEAVING"; public final static String STATUS_LEFT = "LEFT"; @@ -133,6 +134,11 @@ public class VersionedValue implements Comparable return new VersionedValue(value.value); } +public VersionedValue bootReplacing(InetAddress oldNode) +{ +return new VersionedValue(versionString(VersionedValue.STATUS_BOOTSTRAPPING_REPLACE, oldNode.getHostAddress())); +} + public VersionedValue bootstrapping(Collection tokens) { return new VersionedValue(versionString(VersionedValue.STATUS_BOOTSTRAPPING, http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/src/java/org/apache/cassandra/locator/TokenMetadata.java
[5/6] cassandra git commit: Merge branch 'cassandra-2.2' into cassandra-3.0
Merge branch 'cassandra-2.2' into cassandra-3.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e4a53f4d Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e4a53f4d Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e4a53f4d Branch: refs/heads/cassandra-3.0 Commit: e4a53f4d3160833af3ea7917a35e7e35ae02786d Parents: ab98b11 b39d984 Author: Aleksey YeschenkoAuthored: Wed Aug 31 20:24:03 2016 +0100 Committer: Aleksey Yeschenko Committed: Wed Aug 31 20:25:24 2016 +0100 -- CHANGES.txt | 1 + src/java/org/apache/cassandra/gms/Gossiper.java | 5 +- .../apache/cassandra/gms/VersionedValue.java| 6 + .../apache/cassandra/locator/TokenMetadata.java | 52 ++- .../cassandra/service/LoadBroadcaster.java | 2 +- .../cassandra/service/StorageService.java | 136 +++ 6 files changed, 173 insertions(+), 29 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/e4a53f4d/CHANGES.txt -- diff --cc CHANGES.txt index 4b77e4d,d7e9394..30931d3 --- a/CHANGES.txt +++ b/CHANGES.txt @@@ -1,50 -1,5 +1,51 @@@ -2.2.8 +3.0.9 + * Add option to state current gc_grace_seconds to tools/bin/sstablemetadata (CASSANDRA-12208) + * Fix file system race condition that may cause LogAwareFileLister to fail to classify files (CASSANDRA-11889) + * Fix file handle leaks due to simultaneous compaction/repair and + listing snapshots, calculating snapshot sizes, or making schema + changes (CASSANDRA-11594) + * Fix nodetool repair exits with 0 for some errors (CASSANDRA-12508) + * Do not shut down BatchlogManager twice during drain (CASSANDRA-12504) + * Disk failure policy should not be invoked on out of space (CASSANDRA-12385) + * Calculate last compacted key on startup (CASSANDRA-6216) + * Add schema to snapshot manifest, add USING TIMESTAMP clause to ALTER TABLE statements (CASSANDRA-7190) + * Fix clean interval not sent to commit log for empty memtable flush (CASSANDRA-12436) + * Fix potential resource leak in RMIServerSocketFactoryImpl (CASSANDRA-12331) + * Backport CASSANDRA-12002 (CASSANDRA-12177) + * Make sure compaction stats are updated when compaction is interrupted (CASSANDRA-12100) + * Fix potential bad messaging service message for paged range reads + within mixed-version 3.x clusters (CASSANDRA-12249) + * Change commitlog and sstables to track dirty and clean intervals (CASSANDRA-11828) + * NullPointerException during compaction on table with static columns (CASSANDRA-12336) + * Fixed ConcurrentModificationException when reading metrics in GraphiteReporter (CASSANDRA-11823) + * Fix upgrade of super columns on thrift (CASSANDRA-12335) + * Fixed flacky BlacklistingCompactionsTest, switched to fixed size types and increased corruption size (CASSANDRA-12359) + * Rerun ReplicationAwareTokenAllocatorTest on failure to avoid flakiness (CASSANDRA-12277) + * Exception when computing read-repair for range tombstones (CASSANDRA-12263) + * Lost counter writes in compact table and static columns (CASSANDRA-12219) + * AssertionError with MVs on updating a row that isn't indexed due to a null value (CASSANDRA-12247) + * Disable RR and speculative retry with EACH_QUORUM reads (CASSANDRA-11980) + * Add option to override compaction space check (CASSANDRA-12180) + * Faster startup by only scanning each directory for temporary files once (CASSANDRA-12114) + * Respond with v1/v2 protocol header when responding to driver that attempts + to connect with too low of a protocol version (CASSANDRA-11464) + * NullPointerExpception when reading/compacting table (CASSANDRA-11988) + * Fix problem with undeleteable rows on upgrade to new sstable format (CASSANDRA-12144) + * Fix paging logic for deleted partitions with static columns (CASSANDRA-12107) + * Wait until the message is being send to decide which serializer must be used (CASSANDRA-11393) + * Fix migration of static thrift column names with non-text comparators (CASSANDRA-12147) + * Fix upgrading sparse tables that are incorrectly marked as dense (CASSANDRA-11315) + * Fix reverse queries ignoring range tombstones (CASSANDRA-11733) + * Avoid potential race when rebuilding CFMetaData (CASSANDRA-12098) + * Avoid missing sstables when getting the canonical sstables (CASSANDRA-11996) + * Always select the live sstables when getting sstables in bounds (CASSANDRA-11944) + * Fix column ordering of results with static columns for Thrift requests in + a mixed 2.x/3.x cluster, also fix potential non-resolved duplication of + those static columns in query results (CASSANDRA-12123) + * Avoid digest mismatch with
[6/6] cassandra git commit: Merge branch 'cassandra-3.0' into trunk
Merge branch 'cassandra-3.0' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/0cd48f76 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/0cd48f76 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/0cd48f76 Branch: refs/heads/trunk Commit: 0cd48f76d8744d9bdabc65b6218bb82ff9014cb3 Parents: 8a3f0e1 e4a53f4 Author: Aleksey YeschenkoAuthored: Wed Aug 31 20:26:39 2016 +0100 Committer: Aleksey Yeschenko Committed: Wed Aug 31 20:27:53 2016 +0100 -- CHANGES.txt | 1 + src/java/org/apache/cassandra/gms/Gossiper.java | 5 +- .../apache/cassandra/gms/VersionedValue.java| 6 + .../apache/cassandra/locator/TokenMetadata.java | 52 +- .../cassandra/service/LoadBroadcaster.java | 2 +- .../cassandra/service/StorageService.java | 182 ++- 6 files changed, 197 insertions(+), 51 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/0cd48f76/CHANGES.txt -- diff --cc CHANGES.txt index a0f6055,30931d3..0edfc76 --- a/CHANGES.txt +++ b/CHANGES.txt @@@ -64,50 -9,12 +64,51 @@@ Merged from 3.0 * Disk failure policy should not be invoked on out of space (CASSANDRA-12385) * Calculate last compacted key on startup (CASSANDRA-6216) * Add schema to snapshot manifest, add USING TIMESTAMP clause to ALTER TABLE statements (CASSANDRA-7190) +Merged from 2.2: ++ * Forward writes to replacement node when replace_address != broadcast_address (CASSANDRA-8523) + * Fail repair on non-existing table (CASSANDRA-12279) + * Enable repair -pr and -local together (fix regression of CASSANDRA-7450) (CASSANDRA-12522) + + +3.8, 3.9 + * Fix value skipping with counter columns (CASSANDRA-11726) + * Fix nodetool tablestats miss SSTable count (CASSANDRA-12205) + * Fixed flacky SSTablesIteratedTest (CASSANDRA-12282) + * Fixed flacky SSTableRewriterTest: check file counts before calling validateCFS (CASSANDRA-12348) + * cqlsh: Fix handling of $$-escaped strings (CASSANDRA-12189) + * Fix SSL JMX requiring truststore containing server cert (CASSANDRA-12109) + * RTE from new CDC column breaks in flight queries (CASSANDRA-12236) + * Fix hdr logging for single operation workloads (CASSANDRA-12145) + * Fix SASI PREFIX search in CONTAINS mode with partial terms (CASSANDRA-12073) + * Increase size of flushExecutor thread pool (CASSANDRA-12071) + * Partial revert of CASSANDRA-11971, cannot recycle buffer in SP.sendMessagesToNonlocalDC (CASSANDRA-11950) + * Upgrade netty to 4.0.39 (CASSANDRA-12032, CASSANDRA-12034) + * Improve details in compaction log message (CASSANDRA-12080) + * Allow unset values in CQLSSTableWriter (CASSANDRA-11911) + * Chunk cache to request compressor-compatible buffers if pool space is exhausted (CASSANDRA-11993) + * Remove DatabaseDescriptor dependencies from SequentialWriter (CASSANDRA-11579) + * Move skip_stop_words filter before stemming (CASSANDRA-12078) + * Support seek() in EncryptedFileSegmentInputStream (CASSANDRA-11957) + * SSTable tools mishandling LocalPartitioner (CASSANDRA-12002) + * When SEPWorker assigned work, set thread name to match pool (CASSANDRA-11966) + * Add cross-DC latency metrics (CASSANDRA-11596) + * Allow terms in selection clause (CASSANDRA-10783) + * Add bind variables to trace (CASSANDRA-11719) + * Switch counter shards' clock to timestamps (CASSANDRA-9811) + * Introduce HdrHistogram and response/service/wait separation to stress tool (CASSANDRA-11853) + * entry-weighers in QueryProcessor should respect partitionKeyBindIndexes field (CASSANDRA-11718) + * Support older ant versions (CASSANDRA-11807) + * Estimate compressed on disk size when deciding if sstable size limit reached (CASSANDRA-11623) + * cassandra-stress profiles should support case sensitive schemas (CASSANDRA-11546) + * Remove DatabaseDescriptor dependency from FileUtils (CASSANDRA-11578) + * Faster streaming (CASSANDRA-9766) + * Add prepared query parameter to trace for "Execute CQL3 prepared query" session (CASSANDRA-11425) + * Add repaired percentage metric (CASSANDRA-11503) + * Add Change-Data-Capture (CASSANDRA-8844) +Merged from 3.0: * Fix clean interval not sent to commit log for empty memtable flush (CASSANDRA-12436) * Fix potential resource leak in RMIServerSocketFactoryImpl (CASSANDRA-12331) - * Backport CASSANDRA-12002 (CASSANDRA-12177) * Make sure compaction stats are updated when compaction is interrupted (CASSANDRA-12100) - * Fix potential bad messaging service message for paged range reads - within mixed-version 3.x clusters (CASSANDRA-12249) * Change commitlog and sstables to track dirty and clean
[3/6] cassandra git commit: Forward writes to replacement node when replace_address != broadcast_address
Forward writes to replacement node when replace_address != broadcast_address Patch by Paulo Motta; reviewed by Richard Low for CASSANDRA-8523 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b39d984f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b39d984f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b39d984f Branch: refs/heads/trunk Commit: b39d984f7bd682c7638415d65dcc4ac9bcb74e5f Parents: 6eff082 Author: Paulo MottaAuthored: Fri Jun 17 21:09:31 2016 -0300 Committer: Aleksey Yeschenko Committed: Wed Aug 31 20:21:30 2016 +0100 -- CHANGES.txt | 1 + src/java/org/apache/cassandra/gms/Gossiper.java | 5 +- .../apache/cassandra/gms/VersionedValue.java| 6 + .../apache/cassandra/locator/TokenMetadata.java | 54 ++- .../cassandra/service/LoadBroadcaster.java | 2 +- .../cassandra/service/StorageService.java | 139 +++ 6 files changed, 177 insertions(+), 30 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 0f7cf0e..d7e9394 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.2.8 + * Forward writes to replacement node when replace_address != broadcast_address (CASSANDRA-8523) * Enable repair -pr and -local together (fix regression of CASSANDRA-7450) (CASSANDRA-12522) * Fail repair on non-existing table (CASSANDRA-12279) * cqlsh copy: fix missing counter values (CASSANDRA-12476) http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/src/java/org/apache/cassandra/gms/Gossiper.java -- diff --git a/src/java/org/apache/cassandra/gms/Gossiper.java b/src/java/org/apache/cassandra/gms/Gossiper.java index 00e3da8..a8f9524 100644 --- a/src/java/org/apache/cassandra/gms/Gossiper.java +++ b/src/java/org/apache/cassandra/gms/Gossiper.java @@ -76,6 +76,7 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean static { SILENT_SHUTDOWN_STATES.addAll(DEAD_STATES); SILENT_SHUTDOWN_STATES.add(VersionedValue.STATUS_BOOTSTRAPPING); + SILENT_SHUTDOWN_STATES.add(VersionedValue.STATUS_BOOTSTRAPPING_REPLACE); } private volatile ScheduledFuture scheduledGossipTask; @@ -333,10 +334,12 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean if (epState == null) return; -logger.debug("Convicting {} with status {} - alive {}", endpoint, getGossipStatus(epState), epState.isAlive()); if (!epState.isAlive()) return; +logger.debug("Convicting {} with status {} - alive {}", endpoint, getGossipStatus(epState), epState.isAlive()); + + if (isShutdown(endpoint)) { markAsShutdown(endpoint); http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/src/java/org/apache/cassandra/gms/VersionedValue.java -- diff --git a/src/java/org/apache/cassandra/gms/VersionedValue.java b/src/java/org/apache/cassandra/gms/VersionedValue.java index 3ea7bb4..661d3ba 100644 --- a/src/java/org/apache/cassandra/gms/VersionedValue.java +++ b/src/java/org/apache/cassandra/gms/VersionedValue.java @@ -65,6 +65,7 @@ public class VersionedValue implements Comparable // values for ApplicationState.STATUS public final static String STATUS_BOOTSTRAPPING = "BOOT"; +public final static String STATUS_BOOTSTRAPPING_REPLACE = "BOOT_REPLACE"; public final static String STATUS_NORMAL = "NORMAL"; public final static String STATUS_LEAVING = "LEAVING"; public final static String STATUS_LEFT = "LEFT"; @@ -133,6 +134,11 @@ public class VersionedValue implements Comparable return new VersionedValue(value.value); } +public VersionedValue bootReplacing(InetAddress oldNode) +{ +return new VersionedValue(versionString(VersionedValue.STATUS_BOOTSTRAPPING_REPLACE, oldNode.getHostAddress())); +} + public VersionedValue bootstrapping(Collection tokens) { return new VersionedValue(versionString(VersionedValue.STATUS_BOOTSTRAPPING, http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/src/java/org/apache/cassandra/locator/TokenMetadata.java -- diff --git a/src/java/org/apache/cassandra/locator/TokenMetadata.java b/src/java/org/apache/cassandra/locator/TokenMetadata.java index de16fda..b06c9c8 100644 ---
[4/6] cassandra git commit: Merge branch 'cassandra-2.2' into cassandra-3.0
Merge branch 'cassandra-2.2' into cassandra-3.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e4a53f4d Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e4a53f4d Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e4a53f4d Branch: refs/heads/trunk Commit: e4a53f4d3160833af3ea7917a35e7e35ae02786d Parents: ab98b11 b39d984 Author: Aleksey YeschenkoAuthored: Wed Aug 31 20:24:03 2016 +0100 Committer: Aleksey Yeschenko Committed: Wed Aug 31 20:25:24 2016 +0100 -- CHANGES.txt | 1 + src/java/org/apache/cassandra/gms/Gossiper.java | 5 +- .../apache/cassandra/gms/VersionedValue.java| 6 + .../apache/cassandra/locator/TokenMetadata.java | 52 ++- .../cassandra/service/LoadBroadcaster.java | 2 +- .../cassandra/service/StorageService.java | 136 +++ 6 files changed, 173 insertions(+), 29 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/e4a53f4d/CHANGES.txt -- diff --cc CHANGES.txt index 4b77e4d,d7e9394..30931d3 --- a/CHANGES.txt +++ b/CHANGES.txt @@@ -1,50 -1,5 +1,51 @@@ -2.2.8 +3.0.9 + * Add option to state current gc_grace_seconds to tools/bin/sstablemetadata (CASSANDRA-12208) + * Fix file system race condition that may cause LogAwareFileLister to fail to classify files (CASSANDRA-11889) + * Fix file handle leaks due to simultaneous compaction/repair and + listing snapshots, calculating snapshot sizes, or making schema + changes (CASSANDRA-11594) + * Fix nodetool repair exits with 0 for some errors (CASSANDRA-12508) + * Do not shut down BatchlogManager twice during drain (CASSANDRA-12504) + * Disk failure policy should not be invoked on out of space (CASSANDRA-12385) + * Calculate last compacted key on startup (CASSANDRA-6216) + * Add schema to snapshot manifest, add USING TIMESTAMP clause to ALTER TABLE statements (CASSANDRA-7190) + * Fix clean interval not sent to commit log for empty memtable flush (CASSANDRA-12436) + * Fix potential resource leak in RMIServerSocketFactoryImpl (CASSANDRA-12331) + * Backport CASSANDRA-12002 (CASSANDRA-12177) + * Make sure compaction stats are updated when compaction is interrupted (CASSANDRA-12100) + * Fix potential bad messaging service message for paged range reads + within mixed-version 3.x clusters (CASSANDRA-12249) + * Change commitlog and sstables to track dirty and clean intervals (CASSANDRA-11828) + * NullPointerException during compaction on table with static columns (CASSANDRA-12336) + * Fixed ConcurrentModificationException when reading metrics in GraphiteReporter (CASSANDRA-11823) + * Fix upgrade of super columns on thrift (CASSANDRA-12335) + * Fixed flacky BlacklistingCompactionsTest, switched to fixed size types and increased corruption size (CASSANDRA-12359) + * Rerun ReplicationAwareTokenAllocatorTest on failure to avoid flakiness (CASSANDRA-12277) + * Exception when computing read-repair for range tombstones (CASSANDRA-12263) + * Lost counter writes in compact table and static columns (CASSANDRA-12219) + * AssertionError with MVs on updating a row that isn't indexed due to a null value (CASSANDRA-12247) + * Disable RR and speculative retry with EACH_QUORUM reads (CASSANDRA-11980) + * Add option to override compaction space check (CASSANDRA-12180) + * Faster startup by only scanning each directory for temporary files once (CASSANDRA-12114) + * Respond with v1/v2 protocol header when responding to driver that attempts + to connect with too low of a protocol version (CASSANDRA-11464) + * NullPointerExpception when reading/compacting table (CASSANDRA-11988) + * Fix problem with undeleteable rows on upgrade to new sstable format (CASSANDRA-12144) + * Fix paging logic for deleted partitions with static columns (CASSANDRA-12107) + * Wait until the message is being send to decide which serializer must be used (CASSANDRA-11393) + * Fix migration of static thrift column names with non-text comparators (CASSANDRA-12147) + * Fix upgrading sparse tables that are incorrectly marked as dense (CASSANDRA-11315) + * Fix reverse queries ignoring range tombstones (CASSANDRA-11733) + * Avoid potential race when rebuilding CFMetaData (CASSANDRA-12098) + * Avoid missing sstables when getting the canonical sstables (CASSANDRA-11996) + * Always select the live sstables when getting sstables in bounds (CASSANDRA-11944) + * Fix column ordering of results with static columns for Thrift requests in + a mixed 2.x/3.x cluster, also fix potential non-resolved duplication of + those static columns in query results (CASSANDRA-12123) + * Avoid digest mismatch with empty but
[2/6] cassandra git commit: Forward writes to replacement node when replace_address != broadcast_address
Forward writes to replacement node when replace_address != broadcast_address Patch by Paulo Motta; reviewed by Richard Low for CASSANDRA-8523 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b39d984f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b39d984f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b39d984f Branch: refs/heads/cassandra-3.0 Commit: b39d984f7bd682c7638415d65dcc4ac9bcb74e5f Parents: 6eff082 Author: Paulo MottaAuthored: Fri Jun 17 21:09:31 2016 -0300 Committer: Aleksey Yeschenko Committed: Wed Aug 31 20:21:30 2016 +0100 -- CHANGES.txt | 1 + src/java/org/apache/cassandra/gms/Gossiper.java | 5 +- .../apache/cassandra/gms/VersionedValue.java| 6 + .../apache/cassandra/locator/TokenMetadata.java | 54 ++- .../cassandra/service/LoadBroadcaster.java | 2 +- .../cassandra/service/StorageService.java | 139 +++ 6 files changed, 177 insertions(+), 30 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 0f7cf0e..d7e9394 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.2.8 + * Forward writes to replacement node when replace_address != broadcast_address (CASSANDRA-8523) * Enable repair -pr and -local together (fix regression of CASSANDRA-7450) (CASSANDRA-12522) * Fail repair on non-existing table (CASSANDRA-12279) * cqlsh copy: fix missing counter values (CASSANDRA-12476) http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/src/java/org/apache/cassandra/gms/Gossiper.java -- diff --git a/src/java/org/apache/cassandra/gms/Gossiper.java b/src/java/org/apache/cassandra/gms/Gossiper.java index 00e3da8..a8f9524 100644 --- a/src/java/org/apache/cassandra/gms/Gossiper.java +++ b/src/java/org/apache/cassandra/gms/Gossiper.java @@ -76,6 +76,7 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean static { SILENT_SHUTDOWN_STATES.addAll(DEAD_STATES); SILENT_SHUTDOWN_STATES.add(VersionedValue.STATUS_BOOTSTRAPPING); + SILENT_SHUTDOWN_STATES.add(VersionedValue.STATUS_BOOTSTRAPPING_REPLACE); } private volatile ScheduledFuture scheduledGossipTask; @@ -333,10 +334,12 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean if (epState == null) return; -logger.debug("Convicting {} with status {} - alive {}", endpoint, getGossipStatus(epState), epState.isAlive()); if (!epState.isAlive()) return; +logger.debug("Convicting {} with status {} - alive {}", endpoint, getGossipStatus(epState), epState.isAlive()); + + if (isShutdown(endpoint)) { markAsShutdown(endpoint); http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/src/java/org/apache/cassandra/gms/VersionedValue.java -- diff --git a/src/java/org/apache/cassandra/gms/VersionedValue.java b/src/java/org/apache/cassandra/gms/VersionedValue.java index 3ea7bb4..661d3ba 100644 --- a/src/java/org/apache/cassandra/gms/VersionedValue.java +++ b/src/java/org/apache/cassandra/gms/VersionedValue.java @@ -65,6 +65,7 @@ public class VersionedValue implements Comparable // values for ApplicationState.STATUS public final static String STATUS_BOOTSTRAPPING = "BOOT"; +public final static String STATUS_BOOTSTRAPPING_REPLACE = "BOOT_REPLACE"; public final static String STATUS_NORMAL = "NORMAL"; public final static String STATUS_LEAVING = "LEAVING"; public final static String STATUS_LEFT = "LEFT"; @@ -133,6 +134,11 @@ public class VersionedValue implements Comparable return new VersionedValue(value.value); } +public VersionedValue bootReplacing(InetAddress oldNode) +{ +return new VersionedValue(versionString(VersionedValue.STATUS_BOOTSTRAPPING_REPLACE, oldNode.getHostAddress())); +} + public VersionedValue bootstrapping(Collection tokens) { return new VersionedValue(versionString(VersionedValue.STATUS_BOOTSTRAPPING, http://git-wip-us.apache.org/repos/asf/cassandra/blob/b39d984f/src/java/org/apache/cassandra/locator/TokenMetadata.java -- diff --git a/src/java/org/apache/cassandra/locator/TokenMetadata.java b/src/java/org/apache/cassandra/locator/TokenMetadata.java index de16fda..b06c9c8 100644 ---
[jira] [Updated] (CASSANDRA-12582) ReadFailure from CorruptSSTableException after static column removed
[ https://issues.apache.org/jira/browse/CASSANDRA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Prothro updated CASSANDRA-12582: - Attachment: 12582.cdl 12582_reproduce.sh > ReadFailure from CorruptSSTableException after static column removed > > > Key: CASSANDRA-12582 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12582 > Project: Cassandra > Issue Type: Bug > Environment: Cassandra 3.0.8 >Reporter: Evan Prothro > Labels: compaction, corruption, drop, read, static > Fix For: 3.0.9 > > Attachments: 12582.cdl, 12582_reproduce.sh > > > We ran into an issue on production where reads began to fail for certain > queries, depending on the range within the relation for those queries. > Cassandra system log showed an unhandled {{CorruptSSTableException}} > exception. > CQL read failure: > {code} > ReadFailure: code=1300 [Replica(s) failed to execute read] message="Operation > failed - received 0 responses and 1 failures" info={'failures': 1, > 'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'} > {code} > Cassandra exception: > {code} > WARN [SharedPool-Worker-2] 2016-08-31 12:49:27,979 > AbstractLocalAwareExecutorService.java:169 - Uncaught exception on thread > Thread[SharedPool-Worker-2,5,main]: {} > java.lang.RuntimeException: > org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2453) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > ~[na:1.8.0_72] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$LocalSessionFutureTask.run(AbstractLocalAwareExecutorService.java:136) > [apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105) > [apache-cassandra-3.0.8.jar:3.0.8] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.io.sstable.format.big.BigTableScanner$KeyScanningIterator$1.initializeIterator(BigTableScanner.java:343) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.maybeInit(LazilyInitializedUnfilteredRowIterator.java:48) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:66) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:62) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:24) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$Serializer.serialize(UnfilteredPartitionIterators.java:295) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.build(ReadResponse.java:134) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:127) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:123) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse.createDataResponse(ReadResponse.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.db.ReadCommand.createResponse(ReadCommand.java:289) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:1796) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2449) > ~[apache-cassandra-3.0.8.jar:3.0.8] > ... 5 common frames omitted > Caused by:
[jira] [Updated] (CASSANDRA-12582) ReadFailure from CorruptSSTableException after static column removed
[ https://issues.apache.org/jira/browse/CASSANDRA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Prothro updated CASSANDRA-12582: - Attachment: (was: 309issue_reproduce.sh) > ReadFailure from CorruptSSTableException after static column removed > > > Key: CASSANDRA-12582 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12582 > Project: Cassandra > Issue Type: Bug > Environment: Cassandra 3.0.8 >Reporter: Evan Prothro > Labels: compaction, corruption, drop, read, static > Fix For: 3.0.9 > > > We ran into an issue on production where reads began to fail for certain > queries, depending on the range within the relation for those queries. > Cassandra system log showed an unhandled {{CorruptSSTableException}} > exception. > CQL read failure: > {code} > ReadFailure: code=1300 [Replica(s) failed to execute read] message="Operation > failed - received 0 responses and 1 failures" info={'failures': 1, > 'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'} > {code} > Cassandra exception: > {code} > WARN [SharedPool-Worker-2] 2016-08-31 12:49:27,979 > AbstractLocalAwareExecutorService.java:169 - Uncaught exception on thread > Thread[SharedPool-Worker-2,5,main]: {} > java.lang.RuntimeException: > org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2453) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > ~[na:1.8.0_72] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$LocalSessionFutureTask.run(AbstractLocalAwareExecutorService.java:136) > [apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105) > [apache-cassandra-3.0.8.jar:3.0.8] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.io.sstable.format.big.BigTableScanner$KeyScanningIterator$1.initializeIterator(BigTableScanner.java:343) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.maybeInit(LazilyInitializedUnfilteredRowIterator.java:48) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:66) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:62) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:24) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$Serializer.serialize(UnfilteredPartitionIterators.java:295) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.build(ReadResponse.java:134) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:127) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:123) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse.createDataResponse(ReadResponse.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.db.ReadCommand.createResponse(ReadCommand.java:289) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:1796) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2449) > ~[apache-cassandra-3.0.8.jar:3.0.8] > ... 5 common frames omitted > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: >
[jira] [Updated] (CASSANDRA-12582) ReadFailure from CorruptSSTableException after static column removed
[ https://issues.apache.org/jira/browse/CASSANDRA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Prothro updated CASSANDRA-12582: - Attachment: (was: 309issue.cdl) > ReadFailure from CorruptSSTableException after static column removed > > > Key: CASSANDRA-12582 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12582 > Project: Cassandra > Issue Type: Bug > Environment: Cassandra 3.0.8 >Reporter: Evan Prothro > Labels: compaction, corruption, drop, read, static > Fix For: 3.0.9 > > > We ran into an issue on production where reads began to fail for certain > queries, depending on the range within the relation for those queries. > Cassandra system log showed an unhandled {{CorruptSSTableException}} > exception. > CQL read failure: > {code} > ReadFailure: code=1300 [Replica(s) failed to execute read] message="Operation > failed - received 0 responses and 1 failures" info={'failures': 1, > 'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'} > {code} > Cassandra exception: > {code} > WARN [SharedPool-Worker-2] 2016-08-31 12:49:27,979 > AbstractLocalAwareExecutorService.java:169 - Uncaught exception on thread > Thread[SharedPool-Worker-2,5,main]: {} > java.lang.RuntimeException: > org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2453) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > ~[na:1.8.0_72] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$LocalSessionFutureTask.run(AbstractLocalAwareExecutorService.java:136) > [apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105) > [apache-cassandra-3.0.8.jar:3.0.8] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.io.sstable.format.big.BigTableScanner$KeyScanningIterator$1.initializeIterator(BigTableScanner.java:343) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.maybeInit(LazilyInitializedUnfilteredRowIterator.java:48) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:66) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:62) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:24) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$Serializer.serialize(UnfilteredPartitionIterators.java:295) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.build(ReadResponse.java:134) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:127) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:123) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse.createDataResponse(ReadResponse.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.db.ReadCommand.createResponse(ReadCommand.java:289) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:1796) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2449) > ~[apache-cassandra-3.0.8.jar:3.0.8] > ... 5 common frames omitted > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: >
[jira] [Updated] (CASSANDRA-12582) ReadFailure from CorruptSSTableException after static column removed
[ https://issues.apache.org/jira/browse/CASSANDRA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Prothro updated CASSANDRA-12582: - Attachment: 309issue.cdl 309issue_reproduce.sh > ReadFailure from CorruptSSTableException after static column removed > > > Key: CASSANDRA-12582 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12582 > Project: Cassandra > Issue Type: Bug > Environment: Cassandra 3.0.8 >Reporter: Evan Prothro > Labels: compaction, corruption, drop, read, static > Fix For: 3.0.9 > > Attachments: 309issue.cdl, 309issue_reproduce.sh > > > We ran into an issue on production where reads began to fail for certain > queries, depending on the range within the relation for those queries. > Cassandra system log showed an unhandled {{CorruptSSTableException}} > exception. > CQL read failure: > {code} > ReadFailure: code=1300 [Replica(s) failed to execute read] message="Operation > failed - received 0 responses and 1 failures" info={'failures': 1, > 'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'} > {code} > Cassandra exception: > {code} > WARN [SharedPool-Worker-2] 2016-08-31 12:49:27,979 > AbstractLocalAwareExecutorService.java:169 - Uncaught exception on thread > Thread[SharedPool-Worker-2,5,main]: {} > java.lang.RuntimeException: > org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2453) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > ~[na:1.8.0_72] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$LocalSessionFutureTask.run(AbstractLocalAwareExecutorService.java:136) > [apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105) > [apache-cassandra-3.0.8.jar:3.0.8] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.io.sstable.format.big.BigTableScanner$KeyScanningIterator$1.initializeIterator(BigTableScanner.java:343) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.maybeInit(LazilyInitializedUnfilteredRowIterator.java:48) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:66) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:62) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:24) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$Serializer.serialize(UnfilteredPartitionIterators.java:295) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.build(ReadResponse.java:134) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:127) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:123) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse.createDataResponse(ReadResponse.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.db.ReadCommand.createResponse(ReadCommand.java:289) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:1796) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2449) > ~[apache-cassandra-3.0.8.jar:3.0.8] > ... 5 common frames omitted > Caused by:
[jira] [Updated] (CASSANDRA-12582) ReadFailure from CorruptSSTableException after static column removed
[ https://issues.apache.org/jira/browse/CASSANDRA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Prothro updated CASSANDRA-12582: - Attachment: (was: 309issue_reproduce.sh) > ReadFailure from CorruptSSTableException after static column removed > > > Key: CASSANDRA-12582 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12582 > Project: Cassandra > Issue Type: Bug > Environment: Cassandra 3.0.8 >Reporter: Evan Prothro > Labels: compaction, corruption, drop, read, static > Fix For: 3.0.9 > > > We ran into an issue on production where reads began to fail for certain > queries, depending on the range within the relation for those queries. > Cassandra system log showed an unhandled {{CorruptSSTableException}} > exception. > CQL read failure: > {code} > ReadFailure: code=1300 [Replica(s) failed to execute read] message="Operation > failed - received 0 responses and 1 failures" info={'failures': 1, > 'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'} > {code} > Cassandra exception: > {code} > WARN [SharedPool-Worker-2] 2016-08-31 12:49:27,979 > AbstractLocalAwareExecutorService.java:169 - Uncaught exception on thread > Thread[SharedPool-Worker-2,5,main]: {} > java.lang.RuntimeException: > org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2453) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > ~[na:1.8.0_72] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$LocalSessionFutureTask.run(AbstractLocalAwareExecutorService.java:136) > [apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105) > [apache-cassandra-3.0.8.jar:3.0.8] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.io.sstable.format.big.BigTableScanner$KeyScanningIterator$1.initializeIterator(BigTableScanner.java:343) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.maybeInit(LazilyInitializedUnfilteredRowIterator.java:48) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:66) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:62) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:24) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$Serializer.serialize(UnfilteredPartitionIterators.java:295) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.build(ReadResponse.java:134) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:127) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:123) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse.createDataResponse(ReadResponse.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.db.ReadCommand.createResponse(ReadCommand.java:289) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:1796) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2449) > ~[apache-cassandra-3.0.8.jar:3.0.8] > ... 5 common frames omitted > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: >
[jira] [Updated] (CASSANDRA-12582) ReadFailure from CorruptSSTableException after static column removed
[ https://issues.apache.org/jira/browse/CASSANDRA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Prothro updated CASSANDRA-12582: - Attachment: (was: 309issue.cdl) > ReadFailure from CorruptSSTableException after static column removed > > > Key: CASSANDRA-12582 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12582 > Project: Cassandra > Issue Type: Bug > Environment: Cassandra 3.0.8 >Reporter: Evan Prothro > Labels: compaction, corruption, drop, read, static > Fix For: 3.0.9 > > > We ran into an issue on production where reads began to fail for certain > queries, depending on the range within the relation for those queries. > Cassandra system log showed an unhandled {{CorruptSSTableException}} > exception. > CQL read failure: > {code} > ReadFailure: code=1300 [Replica(s) failed to execute read] message="Operation > failed - received 0 responses and 1 failures" info={'failures': 1, > 'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'} > {code} > Cassandra exception: > {code} > WARN [SharedPool-Worker-2] 2016-08-31 12:49:27,979 > AbstractLocalAwareExecutorService.java:169 - Uncaught exception on thread > Thread[SharedPool-Worker-2,5,main]: {} > java.lang.RuntimeException: > org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2453) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > ~[na:1.8.0_72] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$LocalSessionFutureTask.run(AbstractLocalAwareExecutorService.java:136) > [apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105) > [apache-cassandra-3.0.8.jar:3.0.8] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: > /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db > at > org.apache.cassandra.io.sstable.format.big.BigTableScanner$KeyScanningIterator$1.initializeIterator(BigTableScanner.java:343) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.maybeInit(LazilyInitializedUnfilteredRowIterator.java:48) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:66) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:62) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:24) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$Serializer.serialize(UnfilteredPartitionIterators.java:295) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.build(ReadResponse.java:134) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:127) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:123) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.ReadResponse.createDataResponse(ReadResponse.java:65) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at org.apache.cassandra.db.ReadCommand.createResponse(ReadCommand.java:289) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:1796) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2449) > ~[apache-cassandra-3.0.8.jar:3.0.8] > ... 5 common frames omitted > Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: > Corrupted: >
[jira] [Created] (CASSANDRA-12582) ReadFailure from CorruptSSTableException after static column removed
Evan Prothro created CASSANDRA-12582: Summary: ReadFailure from CorruptSSTableException after static column removed Key: CASSANDRA-12582 URL: https://issues.apache.org/jira/browse/CASSANDRA-12582 Project: Cassandra Issue Type: Bug Environment: Cassandra 3.0.8 Reporter: Evan Prothro Fix For: 3.0.9 Attachments: 309issue.cdl, 309issue_reproduce.sh We ran into an issue on production where reads began to fail for certain queries, depending on the range within the relation for those queries. Cassandra system log showed an unhandled {{CorruptSSTableException}} exception. CQL read failure: {code} ReadFailure: code=1300 [Replica(s) failed to execute read] message="Operation failed - received 0 responses and 1 failures" info={'failures': 1, 'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'} {code} Cassandra exception: {code} WARN [SharedPool-Worker-2] 2016-08-31 12:49:27,979 AbstractLocalAwareExecutorService.java:169 - Uncaught exception on thread Thread[SharedPool-Worker-2,5,main]: {} java.lang.RuntimeException: org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db at org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2453) ~[apache-cassandra-3.0.8.jar:3.0.8] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_72] at org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$LocalSessionFutureTask.run(AbstractLocalAwareExecutorService.java:136) [apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105) [apache-cassandra-3.0.8.jar:3.0.8] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db at org.apache.cassandra.io.sstable.format.big.BigTableScanner$KeyScanningIterator$1.initializeIterator(BigTableScanner.java:343) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.maybeInit(LazilyInitializedUnfilteredRowIterator.java:48) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:65) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.isReverseOrder(LazilyInitializedUnfilteredRowIterator.java:66) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:62) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:24) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$Serializer.serialize(UnfilteredPartitionIterators.java:295) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.ReadResponse$LocalDataResponse.build(ReadResponse.java:134) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:127) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.ReadResponse$LocalDataResponse.(ReadResponse.java:123) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.ReadResponse.createDataResponse(ReadResponse.java:65) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.ReadCommand.createResponse(ReadCommand.java:289) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:1796) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2449) ~[apache-cassandra-3.0.8.jar:3.0.8] ... 5 common frames omitted Caused by: org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: /usr/local/apache-cassandra-3.0.8/data/data/issue309/apples_by_tree-006748a06fa311e6a7f8ef8b642e977b/mb-1-big-Data.db at org.apache.cassandra.db.columniterator.AbstractSSTableIterator.(AbstractSSTableIterator.java:130) ~[apache-cassandra-3.0.8.jar:3.0.8] at org.apache.cassandra.db.columniterator.SSTableIterator.(SSTableIterator.java:46) ~[apache-cassandra-3.0.8.jar:3.0.8] at
[jira] [Updated] (CASSANDRA-12365) Document cassandra stress
[ https://issues.apache.org/jira/browse/CASSANDRA-12365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Batey updated CASSANDRA-12365: -- Fix Version/s: 3.x Status: Patch Available (was: Open) I've done some initial docs. Branch here: https://github.com/chbatey/cassandra-1/tree/stress-docs or happy to provide a patch. > Document cassandra stress > - > > Key: CASSANDRA-12365 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12365 > Project: Cassandra > Issue Type: Improvement > Components: Documentation and Website >Reporter: Christopher Batey >Assignee: Christopher Batey >Priority: Minor > Labels: stress > Fix For: 3.x > > > I've started on this so creating a ticket to avoid duplicate work. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12365) Document cassandra stress
[ https://issues.apache.org/jira/browse/CASSANDRA-12365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Batey updated CASSANDRA-12365: -- Labels: stress (was: ) > Document cassandra stress > - > > Key: CASSANDRA-12365 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12365 > Project: Cassandra > Issue Type: Improvement > Components: Documentation and Website >Reporter: Christopher Batey >Assignee: Christopher Batey >Priority: Minor > Labels: stress > > I've started on this so creating a ticket to avoid duplicate work. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (CASSANDRA-12581) Publish test-jar to maven central
Edward Capriolo created CASSANDRA-12581: --- Summary: Publish test-jar to maven central Key: CASSANDRA-12581 URL: https://issues.apache.org/jira/browse/CASSANDRA-12581 Project: Cassandra Issue Type: New Feature Reporter: Edward Capriolo Assignee: Edward Capriolo The test-jar is not published to maven central. A tool which I am testing uses schema-loader and other bits inside the test jar. Having it in maven-central would ease the process. It seems fairly common for test-jar to be in central. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12577) dtest failure in materialized_views_test.TestMaterializedViews.add_dc_after_mv_simple_replication_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Thompson updated CASSANDRA-12577: Resolution: Fixed Status: Resolved (was: Patch Available) > dtest failure in > materialized_views_test.TestMaterializedViews.add_dc_after_mv_simple_replication_test > -- > > Key: CASSANDRA-12577 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12577 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: Philip Thompson > Labels: dtest > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log, node3.log, node3_debug.log, node3_gc.log, > node4.log, node4_debug.log, node4_gc.log > > > example failure: > http://cassci.datastax.com/job/cassandra-3.0_novnode_dtest/301/testReport/materialized_views_test/TestMaterializedViews/add_dc_after_mv_simple_replication_test/ > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/materialized_views_test.py", line > 389, in add_dc_after_mv_simple_replication_test > self._add_dc_after_mv_test(1) > File "/home/automaton/cassandra-dtest/materialized_views_test.py", line > 363, in _add_dc_after_mv_test > > node5.start(jvm_args=["-Dcassandra.migration_task_wait_in_seconds={}".format(MIGRATION_WAIT)]) > File "/home/automaton/ccm/ccmlib/node.py", line 636, in start > self._update_pid(process) > File "/home/automaton/ccm/ccmlib/node.py", line 1770, in _update_pid > raise NodeError('Problem starting node %s due to %s' % (self.name, e), > process) > "Problem starting node node5 due to [Errno 2] No such file or directory: > '/tmp/dtest-S4bmF0/test/node5/cassandra.pid' > {code} > Related failure: > http://cassci.datastax.com/job/cassandra-3.0_novnode_dtest/301/testReport/materialized_views_test/TestMaterializedViews/add_dc_after_mv_network_replication_test/ -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Resolved] (CASSANDRA-12340) dtest failure in upgrade_supercolumns_test.TestSCUpgrade.upgrade_with_counters_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Witschey resolved CASSANDRA-12340. -- Resolution: Fixed Thanks, closing > dtest failure in > upgrade_supercolumns_test.TestSCUpgrade.upgrade_with_counters_test > --- > > Key: CASSANDRA-12340 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12340 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: Jim Witschey > Labels: dtest > Attachments: node1.log, node2.log, node3.log > > > example failure: > http://cassci.datastax.com/job/cassandra-2.1_dtest_jdk8/249/testReport/upgrade_supercolumns_test/TestSCUpgrade/upgrade_with_counters_test > {code} > Standard Output > Unexpected error in node3 log, error: > ERROR [CompactionExecutor:1] 2016-07-28 15:34:19,533 CassandraDaemon.java > (line 191) Exception in thread Thread[CompactionExecutor:1,1,main] > java.util.concurrent.RejectedExecutionException: Task > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@5fb8b2bf > rejected from > org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor@1ae851ad[Terminated, > pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 8] > at > java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047) > at > java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823) > at > java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:326) > at > java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) > at > java.util.concurrent.ScheduledThreadPoolExecutor.submit(ScheduledThreadPoolExecutor.java:632) > at > org.apache.cassandra.io.sstable.SSTableDeletingTask.schedule(SSTableDeletingTask.java:65) > at > org.apache.cassandra.io.sstable.SSTableReader.releaseReference(SSTableReader.java:976) > at > org.apache.cassandra.db.DataTracker.removeOldSSTablesSize(DataTracker.java:383) > at org.apache.cassandra.db.DataTracker.postReplace(DataTracker.java:348) > at org.apache.cassandra.db.DataTracker.replace(DataTracker.java:342) > at > org.apache.cassandra.db.DataTracker.replaceCompactedSSTables(DataTracker.java:245) > at > org.apache.cassandra.db.ColumnFamilyStore.replaceCompactedSSTables(ColumnFamilyStore.java:995) > at > org.apache.cassandra.db.compaction.CompactionTask.replaceCompactedSSTables(CompactionTask.java:270) > at > org.apache.cassandra.db.compaction.CompactionTask.runWith(CompactionTask.java:230) > at > org.apache.cassandra.io.util.DiskAwareRunnable.runMayThrow(DiskAwareRunnable.java:48) > at > org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) > at > org.apache.cassandra.db.compaction.CompactionTask.executeInternal(CompactionTask.java:58) > at > org.apache.cassandra.db.compaction.AbstractCompactionTask.execute(AbstractCompactionTask.java:60) > at > org.apache.cassandra.db.compaction.CompactionManager$BackgroundCompactionTask.run(CompactionManager.java:208) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Comment Edited] (CASSANDRA-12572) CQL query size bound to 64Kb
[ https://issues.apache.org/jira/browse/CASSANDRA-12572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452921#comment-15452921 ] Caleb Rackliffe edited comment on CASSANDRA-12572 at 8/31/16 6:16 PM: -- Is this in reference to the check in {{RowFilter.Expression#validateForIndexing()}}? In 2.1, I think it lives in {{SelectStatement#validateIndexedValue()}}. was (Author: maedhroz): Is this in reference to the check in {{RowFilter.Expression#validateForIndexing()}}? > CQL query size bound to 64Kb > > > Key: CASSANDRA-12572 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12572 > Project: Cassandra > Issue Type: Improvement > Components: Core > Environment: Cassandra 2.1.14.1346 > Cassandra 3.0.8.1284 >Reporter: Jose Martinez Poblete >Priority: Minor > > Currently, a query is bound to a 64Kb text limit > In some edge scenarios, the query text could go over that limit > Can we make that a configurable parameter? -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12572) CQL query size bound to 64Kb
[ https://issues.apache.org/jira/browse/CASSANDRA-12572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452921#comment-15452921 ] Caleb Rackliffe commented on CASSANDRA-12572: - Is this in reference to the check in {{RowFilter.Expression#validateForIndexing()}}? > CQL query size bound to 64Kb > > > Key: CASSANDRA-12572 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12572 > Project: Cassandra > Issue Type: Improvement > Components: Core > Environment: Cassandra 2.1.14.1346 > Cassandra 3.0.8.1284 >Reporter: Jose Martinez Poblete >Priority: Minor > > Currently, a query is bound to a 64Kb text limit > In some edge scenarios, the query text could go over that limit > Can we make that a configurable parameter? -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Comment Edited] (CASSANDRA-12579) dtest failure in cql_tracing_test.TestCqlTracing.tracing_default_impl_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452903#comment-15452903 ] Philip Thompson edited comment on CASSANDRA-12579 at 8/31/16 5:59 PM: -- http://cassci.datastax.com/view/Parameterized/job/parameterized_dtest_multiplexer/298 was (Author: philipthompson): cassci.datastax.com/view/Parameterized/job/parameterized_dtest_multiplexer/298 > dtest failure in cql_tracing_test.TestCqlTracing.tracing_default_impl_test > -- > > Key: CASSANDRA-12579 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12579 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: DS Test Eng > Labels: dtest > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log, node3.log, node3_debug.log, node3_gc.log > > > example failure: > http://cassci.datastax.com/job/cassandra-3.9_dtest/50/testReport/cql_tracing_test/TestCqlTracing/tracing_default_impl_test > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/tools/decorators.py", line 48, in > wrapped > f(obj) > File "/home/automaton/cassandra-dtest/cql_tracing_test.py", line 163, in > tracing_default_impl_test > errs[0][1]) > 'list index out of range > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12579) dtest failure in cql_tracing_test.TestCqlTracing.tracing_default_impl_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452903#comment-15452903 ] Philip Thompson commented on CASSANDRA-12579: - cassci.datastax.com/view/Parameterized/job/parameterized_dtest_multiplexer/298 > dtest failure in cql_tracing_test.TestCqlTracing.tracing_default_impl_test > -- > > Key: CASSANDRA-12579 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12579 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: DS Test Eng > Labels: dtest > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log, node3.log, node3_debug.log, node3_gc.log > > > example failure: > http://cassci.datastax.com/job/cassandra-3.9_dtest/50/testReport/cql_tracing_test/TestCqlTracing/tracing_default_impl_test > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/tools/decorators.py", line 48, in > wrapped > f(obj) > File "/home/automaton/cassandra-dtest/cql_tracing_test.py", line 163, in > tracing_default_impl_test > errs[0][1]) > 'list index out of range > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12578) dtest failure in repair_tests.repair_test.TestRepair.nonexistent_table_repair_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452900#comment-15452900 ] Philip Thompson commented on CASSANDRA-12578: - http://cassci.datastax.com/view/Parameterized/job/parameterized_dtest_multiplexer/297/ > dtest failure in > repair_tests.repair_test.TestRepair.nonexistent_table_repair_test > -- > > Key: CASSANDRA-12578 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12578 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: DS Test Eng > Labels: dtest > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log > > > example failure: > http://cassci.datastax.com/job/cassandra-3.9_dtest/50/testReport/repair_tests.repair_test/TestRepair/nonexistent_table_repair_test > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/repair_tests/repair_test.py", line > 210, in nonexistent_table_repair_test > self.assertFalse(t.isAlive(), 'Repair thread on inexistent table is still > running') > File "/usr/lib/python2.7/unittest/case.py", line 416, in assertFalse > raise self.failureException(msg) > "Repair thread on inexistent table is still running > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12559) dtest failure in cqlsh_tests.cqlsh_copy_tests.CqlshCopyTest.test_bulk_round_trip_with_backoff
[ https://issues.apache.org/jira/browse/CASSANDRA-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452896#comment-15452896 ] Philip Thompson commented on CASSANDRA-12559: - http://cassci.datastax.com/view/Parameterized/job/parameterized_dtest_multiplexer/296/ > dtest failure in > cqlsh_tests.cqlsh_copy_tests.CqlshCopyTest.test_bulk_round_trip_with_backoff > - > > Key: CASSANDRA-12559 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12559 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: DS Test Eng > Labels: dtest > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log, node3.log, node3_debug.log, node3_gc.log > > > example failure: > http://cassci.datastax.com/job/trunk_offheap_dtest/385/testReport/cqlsh_tests.cqlsh_copy_tests/CqlshCopyTest/test_bulk_round_trip_with_backoff > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/dtest.py", line 1123, in wrapped > f(obj) > File "/home/automaton/cassandra-dtest/tools/decorators.py", line 48, in > wrapped > f(obj) > File "/home/automaton/cassandra-dtest/cqlsh_tests/cqlsh_copy_tests.py", > line 2565, in test_bulk_round_trip_with_backoff > copy_from_options={'MAXINFLIGHTMESSAGES': 64, 'MAXPENDINGCHUNKS': 1}) > File "/home/automaton/cassandra-dtest/cqlsh_tests/cqlsh_copy_tests.py", > line 2454, in _test_bulk_round_trip > sum(1 for _ in open(tempfile2.name))) > File "/usr/lib/python2.7/unittest/case.py", line 513, in assertEqual > assertion_func(first, second, msg=msg) > File "/usr/lib/python2.7/unittest/case.py", line 506, in _baseAssertEqual > raise self.failureException(msg) > "25 != 249714 > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12340) dtest failure in upgrade_supercolumns_test.TestSCUpgrade.upgrade_with_counters_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452886#comment-15452886 ] Joel Knighton commented on CASSANDRA-12340: --- Sounds good to me. > dtest failure in > upgrade_supercolumns_test.TestSCUpgrade.upgrade_with_counters_test > --- > > Key: CASSANDRA-12340 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12340 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: Jim Witschey > Labels: dtest > Attachments: node1.log, node2.log, node3.log > > > example failure: > http://cassci.datastax.com/job/cassandra-2.1_dtest_jdk8/249/testReport/upgrade_supercolumns_test/TestSCUpgrade/upgrade_with_counters_test > {code} > Standard Output > Unexpected error in node3 log, error: > ERROR [CompactionExecutor:1] 2016-07-28 15:34:19,533 CassandraDaemon.java > (line 191) Exception in thread Thread[CompactionExecutor:1,1,main] > java.util.concurrent.RejectedExecutionException: Task > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@5fb8b2bf > rejected from > org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor@1ae851ad[Terminated, > pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 8] > at > java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047) > at > java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823) > at > java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:326) > at > java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) > at > java.util.concurrent.ScheduledThreadPoolExecutor.submit(ScheduledThreadPoolExecutor.java:632) > at > org.apache.cassandra.io.sstable.SSTableDeletingTask.schedule(SSTableDeletingTask.java:65) > at > org.apache.cassandra.io.sstable.SSTableReader.releaseReference(SSTableReader.java:976) > at > org.apache.cassandra.db.DataTracker.removeOldSSTablesSize(DataTracker.java:383) > at org.apache.cassandra.db.DataTracker.postReplace(DataTracker.java:348) > at org.apache.cassandra.db.DataTracker.replace(DataTracker.java:342) > at > org.apache.cassandra.db.DataTracker.replaceCompactedSSTables(DataTracker.java:245) > at > org.apache.cassandra.db.ColumnFamilyStore.replaceCompactedSSTables(ColumnFamilyStore.java:995) > at > org.apache.cassandra.db.compaction.CompactionTask.replaceCompactedSSTables(CompactionTask.java:270) > at > org.apache.cassandra.db.compaction.CompactionTask.runWith(CompactionTask.java:230) > at > org.apache.cassandra.io.util.DiskAwareRunnable.runMayThrow(DiskAwareRunnable.java:48) > at > org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) > at > org.apache.cassandra.db.compaction.CompactionTask.executeInternal(CompactionTask.java:58) > at > org.apache.cassandra.db.compaction.AbstractCompactionTask.execute(AbstractCompactionTask.java:60) > at > org.apache.cassandra.db.compaction.CompactionManager$BackgroundCompactionTask.run(CompactionManager.java:208) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12577) dtest failure in materialized_views_test.TestMaterializedViews.add_dc_after_mv_simple_replication_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Thompson updated CASSANDRA-12577: Reviewer: Russ Hatch Status: Patch Available (was: Open) https://github.com/riptano/cassandra-dtest/pull/1292 > dtest failure in > materialized_views_test.TestMaterializedViews.add_dc_after_mv_simple_replication_test > -- > > Key: CASSANDRA-12577 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12577 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: Philip Thompson > Labels: dtest > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log, node3.log, node3_debug.log, node3_gc.log, > node4.log, node4_debug.log, node4_gc.log > > > example failure: > http://cassci.datastax.com/job/cassandra-3.0_novnode_dtest/301/testReport/materialized_views_test/TestMaterializedViews/add_dc_after_mv_simple_replication_test/ > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/materialized_views_test.py", line > 389, in add_dc_after_mv_simple_replication_test > self._add_dc_after_mv_test(1) > File "/home/automaton/cassandra-dtest/materialized_views_test.py", line > 363, in _add_dc_after_mv_test > > node5.start(jvm_args=["-Dcassandra.migration_task_wait_in_seconds={}".format(MIGRATION_WAIT)]) > File "/home/automaton/ccm/ccmlib/node.py", line 636, in start > self._update_pid(process) > File "/home/automaton/ccm/ccmlib/node.py", line 1770, in _update_pid > raise NodeError('Problem starting node %s due to %s' % (self.name, e), > process) > "Problem starting node node5 due to [Errno 2] No such file or directory: > '/tmp/dtest-S4bmF0/test/node5/cassandra.pid' > {code} > Related failure: > http://cassci.datastax.com/job/cassandra-3.0_novnode_dtest/301/testReport/materialized_views_test/TestMaterializedViews/add_dc_after_mv_network_replication_test/ -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Assigned] (CASSANDRA-12577) dtest failure in materialized_views_test.TestMaterializedViews.add_dc_after_mv_simple_replication_test
[ https://issues.apache.org/jira/browse/CASSANDRA-12577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Thompson reassigned CASSANDRA-12577: --- Assignee: Philip Thompson (was: DS Test Eng) > dtest failure in > materialized_views_test.TestMaterializedViews.add_dc_after_mv_simple_replication_test > -- > > Key: CASSANDRA-12577 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12577 > Project: Cassandra > Issue Type: Test >Reporter: Sean McCarthy >Assignee: Philip Thompson > Labels: dtest > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log, node3.log, node3_debug.log, node3_gc.log, > node4.log, node4_debug.log, node4_gc.log > > > example failure: > http://cassci.datastax.com/job/cassandra-3.0_novnode_dtest/301/testReport/materialized_views_test/TestMaterializedViews/add_dc_after_mv_simple_replication_test/ > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/materialized_views_test.py", line > 389, in add_dc_after_mv_simple_replication_test > self._add_dc_after_mv_test(1) > File "/home/automaton/cassandra-dtest/materialized_views_test.py", line > 363, in _add_dc_after_mv_test > > node5.start(jvm_args=["-Dcassandra.migration_task_wait_in_seconds={}".format(MIGRATION_WAIT)]) > File "/home/automaton/ccm/ccmlib/node.py", line 636, in start > self._update_pid(process) > File "/home/automaton/ccm/ccmlib/node.py", line 1770, in _update_pid > raise NodeError('Problem starting node %s due to %s' % (self.name, e), > process) > "Problem starting node node5 due to [Errno 2] No such file or directory: > '/tmp/dtest-S4bmF0/test/node5/cassandra.pid' > {code} > Related failure: > http://cassci.datastax.com/job/cassandra-3.0_novnode_dtest/301/testReport/materialized_views_test/TestMaterializedViews/add_dc_after_mv_network_replication_test/ -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Resolved] (CASSANDRA-12556) dtest failure in paging_test.TestPagingDatasetChanges.test_cell_TTL_expiry_during_paging
[ https://issues.apache.org/jira/browse/CASSANDRA-12556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Thompson resolved CASSANDRA-12556. - Resolution: Cannot Reproduce Ran 300 times, no repro > dtest failure in > paging_test.TestPagingDatasetChanges.test_cell_TTL_expiry_during_paging > > > Key: CASSANDRA-12556 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12556 > Project: Cassandra > Issue Type: Test >Reporter: Craig Kodman >Assignee: DS Test Eng > Labels: dtest > > example failure: > http://cassci.datastax.com/job/cassandra-3.9_dtest/49/testReport/paging_test/TestPagingDatasetChanges/test_cell_TTL_expiry_during_paging > {code} > Error Message > Error from server: code=2200 [Invalid query] message="unconfigured table > paging_test" > >> begin captured logging << > dtest: DEBUG: cluster ccm directory: /tmp/dtest-V_YoOr > dtest: DEBUG: Done setting configuration options: > { 'initial_token': None, > 'num_tokens': '32', > 'phi_convict_threshold': 5, > 'range_request_timeout_in_ms': 1, > 'read_request_timeout_in_ms': 1, > 'request_timeout_in_ms': 1, > 'truncate_request_timeout_in_ms': 1, > 'write_request_timeout_in_ms': 1} > - >> end captured logging << - > {code} > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/paging_test.py", line 2660, in > test_cell_TTL_expiry_during_paging > session, 'paging_test', cl=CL.ALL, format_funcs={'id': int, 'mytext': > random_txt} > File "/home/automaton/cassandra-dtest/datahelp.py", line 130, in create_rows > vals=', '.join('?' for k in dicts[0].keys()), postfix=postfix) > File "cassandra/cluster.py", line 2162, in > cassandra.cluster.Session.prepare (cassandra/cluster.c:37231) > raise > File "cassandra/cluster.py", line 2159, in > cassandra.cluster.Session.prepare (cassandra/cluster.c:37087) > query_id, bind_metadata, pk_indexes, result_metadata = future.result() > File "cassandra/cluster.py", line 3665, in > cassandra.cluster.ResponseFuture.result (cassandra/cluster.c:70216) > raise self._final_exception > 'Error from server: code=2200 [Invalid query] message="unconfigured table > paging_test"\n >> begin captured logging << > \ndtest: DEBUG: cluster ccm directory: > /tmp/dtest-V_YoOr\ndtest: DEBUG: Done setting configuration options:\n{ > \'initial_token\': None,\n\'num_tokens\': \'32\',\n > \'phi_convict_threshold\': 5,\n\'range_request_timeout_in_ms\': 1,\n > \'read_request_timeout_in_ms\': 1,\n\'request_timeout_in_ms\': > 1,\n\'truncate_request_timeout_in_ms\': 1,\n > \'write_request_timeout_in_ms\': 1}\n- >> end > captured logging << -' > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Resolved] (CASSANDRA-12537) dtest failure in cdc_test.TestCDC.test_cdc_data_available_in_cdc_raw
[ https://issues.apache.org/jira/browse/CASSANDRA-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Thompson resolved CASSANDRA-12537. - Resolution: Duplicate > dtest failure in cdc_test.TestCDC.test_cdc_data_available_in_cdc_raw > > > Key: CASSANDRA-12537 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12537 > Project: Cassandra > Issue Type: Bug >Reporter: Sean McCarthy >Assignee: DS Test Eng > Labels: dtest > Attachments: node1.log, node1_debug.log, node1_gc.log, node2.log, > node2_debug.log, node2_gc.log > > > example failure: > http://cassci.datastax.com/job/trunk_dtest/1350/testReport/cdc_test/TestCDC/test_cdc_data_available_in_cdc_raw/ > {code} > Error Message > 25 Aug 2016 04:01:25 [node2] Missing: ['Starting listening for CQL clients']: > INFO [main] 2016-08-25 03:51:25,259 YamlConfigura. > See system.log for remainder > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/cdc_test.py", line 515, in > test_cdc_data_available_in_cdc_raw > loading_node.start(wait_for_binary_proto=True) > File "/home/automaton/ccm/ccmlib/node.py", line 655, in start > self.wait_for_binary_interface(from_mark=self.mark) > File "/home/automaton/ccm/ccmlib/node.py", line 493, in > wait_for_binary_interface > self.watch_log_for("Starting listening for CQL clients", **kwargs) > File "/home/automaton/ccm/ccmlib/node.py", line 450, in watch_log_for > raise TimeoutError(time.strftime("%d %b %Y %H:%M:%S", time.gmtime()) + " > [" + self.name + "] Missing: " + str([e.pattern for e in tofind]) + ":\n" + > reads[:50] + ".\nSee {} for remainder".format(filename)) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12531) dtest failure in read_failures_test.TestReadFailures.test_tombstone_failure_v3
[ https://issues.apache.org/jira/browse/CASSANDRA-12531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Thompson updated CASSANDRA-12531: Assignee: (was: Philip Thompson) Fix Version/s: 2.2.x Issue Type: Bug (was: Test) It seems pretty clear from the test that these queries should fail, and yet they are having no trouble. > dtest failure in read_failures_test.TestReadFailures.test_tombstone_failure_v3 > -- > > Key: CASSANDRA-12531 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12531 > Project: Cassandra > Issue Type: Bug >Reporter: Craig Kodman > Labels: dtest > Fix For: 2.2.x > > > example failure: > http://cassci.datastax.com/job/cassandra-2.2_dtest/682/testReport/read_failures_test/TestReadFailures/test_tombstone_failure_v3 > http://cassci.datastax.com/job/cassandra-2.2_dtest/682/testReport/read_failures_test/TestReadFailures/test_tombstone_failure_v4 > {code} > Error Message > ReadTimeout not raised > >> begin captured logging << > dtest: DEBUG: cluster ccm directory: /tmp/dtest-swJYMH > dtest: DEBUG: Done setting configuration options: > { 'initial_token': None, > 'num_tokens': '32', > 'phi_convict_threshold': 5, > 'range_request_timeout_in_ms': 1, > 'read_request_timeout_in_ms': 1, > 'request_timeout_in_ms': 1, > 'truncate_request_timeout_in_ms': 1, > 'write_request_timeout_in_ms': 1} > - >> end captured logging << - > {code} > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/tools.py", line 290, in wrapped > f(obj) > File "/home/automaton/cassandra-dtest/read_failures_test.py", line 90, in > test_tombstone_failure_v3 > self._perform_cql_statement(session, "SELECT value FROM tombstonefailure") > File "/home/automaton/cassandra-dtest/read_failures_test.py", line 63, in > _perform_cql_statement > session.execute(statement) > File "/usr/lib/python2.7/unittest/case.py", line 116, in __exit__ > "{0} not raised".format(exc_name)) > "ReadTimeout not raised\n >> begin captured logging << > \ndtest: DEBUG: cluster ccm directory: > /tmp/dtest-swJYMH\ndtest: DEBUG: Done setting configuration options:\n{ > 'initial_token': None,\n'num_tokens': '32',\n'phi_convict_threshold': > 5,\n'range_request_timeout_in_ms': 1,\n > 'read_request_timeout_in_ms': 1,\n'request_timeout_in_ms': 1,\n > 'truncate_request_timeout_in_ms': 1,\n'write_request_timeout_in_ms': > 1}\n- >> end captured logging << > -" > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Assigned] (CASSANDRA-12531) dtest failure in read_failures_test.TestReadFailures.test_tombstone_failure_v3
[ https://issues.apache.org/jira/browse/CASSANDRA-12531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Thompson reassigned CASSANDRA-12531: --- Assignee: Philip Thompson (was: DS Test Eng) > dtest failure in read_failures_test.TestReadFailures.test_tombstone_failure_v3 > -- > > Key: CASSANDRA-12531 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12531 > Project: Cassandra > Issue Type: Test >Reporter: Craig Kodman >Assignee: Philip Thompson > Labels: dtest > > example failure: > http://cassci.datastax.com/job/cassandra-2.2_dtest/682/testReport/read_failures_test/TestReadFailures/test_tombstone_failure_v3 > http://cassci.datastax.com/job/cassandra-2.2_dtest/682/testReport/read_failures_test/TestReadFailures/test_tombstone_failure_v4 > {code} > Error Message > ReadTimeout not raised > >> begin captured logging << > dtest: DEBUG: cluster ccm directory: /tmp/dtest-swJYMH > dtest: DEBUG: Done setting configuration options: > { 'initial_token': None, > 'num_tokens': '32', > 'phi_convict_threshold': 5, > 'range_request_timeout_in_ms': 1, > 'read_request_timeout_in_ms': 1, > 'request_timeout_in_ms': 1, > 'truncate_request_timeout_in_ms': 1, > 'write_request_timeout_in_ms': 1} > - >> end captured logging << - > {code} > {code} > Stacktrace > File "/usr/lib/python2.7/unittest/case.py", line 329, in run > testMethod() > File "/home/automaton/cassandra-dtest/tools.py", line 290, in wrapped > f(obj) > File "/home/automaton/cassandra-dtest/read_failures_test.py", line 90, in > test_tombstone_failure_v3 > self._perform_cql_statement(session, "SELECT value FROM tombstonefailure") > File "/home/automaton/cassandra-dtest/read_failures_test.py", line 63, in > _perform_cql_statement > session.execute(statement) > File "/usr/lib/python2.7/unittest/case.py", line 116, in __exit__ > "{0} not raised".format(exc_name)) > "ReadTimeout not raised\n >> begin captured logging << > \ndtest: DEBUG: cluster ccm directory: > /tmp/dtest-swJYMH\ndtest: DEBUG: Done setting configuration options:\n{ > 'initial_token': None,\n'num_tokens': '32',\n'phi_convict_threshold': > 5,\n'range_request_timeout_in_ms': 1,\n > 'read_request_timeout_in_ms': 1,\n'request_timeout_in_ms': 1,\n > 'truncate_request_timeout_in_ms': 1,\n'write_request_timeout_in_ms': > 1}\n- >> end captured logging << > -" > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12580) Fix merkle tree size calculation
[ https://issues.apache.org/jira/browse/CASSANDRA-12580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452820#comment-15452820 ] Paulo Motta commented on CASSANDRA-12580: - Attaching patch to fix the calculation formula to: {{int depth = numPartitions > 0 ? (int) Math.min(Math.ceil(Math.log(numPartitions) / Math.log(2)), 20) : 0;}} Besides fixing from {{ln}} to {{lg}}, this also changes the rounding formula from {{floor}} to {{ceil}}, so we overestimate the depth rather than underestimate. I added a new test on {{ValidationTest}} that runs a validation compaction with N=128 and N=1500 keys and expect the merkle tree depth to be {{ceil(lg(N))}}. I also modified the other tests on this class to use a {{ListenableFuture}} ({{CompletableFuture}} on 3.0+) instead of {{SimpleCondition}}, since the JUnit assertions are not enforced in other threads. Patch and tests available below: ||2.1||2.2||3.0||trunk|| |[branch|https://github.com/apache/cassandra/compare/cassandra-2.1...pauloricardomg:2.1-CASSANDRA-12580]|[branch|https://github.com/apache/cassandra/compare/cassandra-2.2...pauloricardomg:2.2-CASSANDRA-12580]|[branch|https://github.com/apache/cassandra/compare/cassandra-3.0...pauloricardomg:3.0-CASSANDRA-12580]|[branch|https://github.com/apache/cassandra/compare/trunk...pauloricardomg:trunk-CASSANDRA-12580]| |[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.1-CASSANDRA-12580-testall/lastCompletedBuild/testReport/]|[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.2-CASSANDRA-12580-testall/lastCompletedBuild/testReport/]|[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-3.0-CASSANDRA-12580-testall/lastCompletedBuild/testReport/]|[testall|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-trunk-CASSANDRA-12580-testall/lastCompletedBuild/testReport/]| |[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.1-CASSANDRA-12580-dtest/lastCompletedBuild/testReport/]|[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-2.2-CASSANDRA-12580-dtest/lastCompletedBuild/testReport/]|[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-3.0-CASSANDRA-12580-dtest/lastCompletedBuild/testReport/]|[dtest|http://cassci.datastax.com/view/Dev/view/paulomotta/job/pauloricardomg-trunk-CASSANDRA-12580-dtest/lastCompletedBuild/testReport/]| > Fix merkle tree size calculation > > > Key: CASSANDRA-12580 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12580 > Project: Cassandra > Issue Type: Bug >Reporter: Paulo Motta >Assignee: Paulo Motta > > On CASSANDRA-5263 it was introduced dynamic merkle tree sizing based on > estimated number of partitions as {{estimatedDepth = lg(numPartitions)}}, but > on > [CompactionManager.doValidationCompaction|https://github.com/apache/cassandra/blob/cassandra-2.1/src/java/org/apache/cassandra/db/compaction/CompactionManager.java#L1052] > this is being calculated as: > {{int depth = numPartitions > 0 ? (int) > Math.min(Math.floor(Math.log(numPartitions)), 20) : 0;}} > This is actually calculating {{ln(numPartitions)}} (base-e) instead of > {{lg(numPartitions)}} (base-2), which causes merkle trees to lose resolution, > what may result in overstreaming. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (CASSANDRA-12580) Fix merkle tree size calculation
[ https://issues.apache.org/jira/browse/CASSANDRA-12580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paulo Motta updated CASSANDRA-12580: Status: Patch Available (was: Open) > Fix merkle tree size calculation > > > Key: CASSANDRA-12580 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12580 > Project: Cassandra > Issue Type: Bug >Reporter: Paulo Motta >Assignee: Paulo Motta > > On CASSANDRA-5263 it was introduced dynamic merkle tree sizing based on > estimated number of partitions as {{estimatedDepth = lg(numPartitions)}}, but > on > [CompactionManager.doValidationCompaction|https://github.com/apache/cassandra/blob/cassandra-2.1/src/java/org/apache/cassandra/db/compaction/CompactionManager.java#L1052] > this is being calculated as: > {{int depth = numPartitions > 0 ? (int) > Math.min(Math.floor(Math.log(numPartitions)), 20) : 0;}} > This is actually calculating {{ln(numPartitions)}} (base-e) instead of > {{lg(numPartitions)}} (base-2), which causes merkle trees to lose resolution, > what may result in overstreaming. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-11195) paging may returns incomplete results on small page size
[ https://issues.apache.org/jira/browse/CASSANDRA-11195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452803#comment-15452803 ] Russ Hatch commented on CASSANDRA-11195: Ah, interesting -- let me know if I can help out! > paging may returns incomplete results on small page size > > > Key: CASSANDRA-11195 > URL: https://issues.apache.org/jira/browse/CASSANDRA-11195 > Project: Cassandra > Issue Type: Bug >Reporter: Jim Witschey >Assignee: Benjamin Lerer > Labels: dtest > Attachments: allfiles.tar.gz, node1.log, node1_debug.log, node2.log, > node2_debug.log > > > This was found through a flapping test, and running that test is still the > easiest way to repro the issue. On CI we're seeing a 40-50% failure rate, but > locally this test fails much less frequently. > If I attach a python debugger and re-query the "bad" query, it continues to > return incomplete data indefinitely. If I go directly to cqlsh I can see all > rows just fine. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (CASSANDRA-12580) Fix merkle tree size calculation
Paulo Motta created CASSANDRA-12580: --- Summary: Fix merkle tree size calculation Key: CASSANDRA-12580 URL: https://issues.apache.org/jira/browse/CASSANDRA-12580 Project: Cassandra Issue Type: Bug Reporter: Paulo Motta Assignee: Paulo Motta On CASSANDRA-5263 it was introduced dynamic merkle tree sizing based on estimated number of partitions as {{estimatedDepth = lg(numPartitions)}}, but on [CompactionManager.doValidationCompaction|https://github.com/apache/cassandra/blob/cassandra-2.1/src/java/org/apache/cassandra/db/compaction/CompactionManager.java#L1052] this is being calculated as: {{int depth = numPartitions > 0 ? (int) Math.min(Math.floor(Math.log(numPartitions)), 20) : 0;}} This is actually calculating {{ln(numPartitions)}} (base-e) instead of {{lg(numPartitions)}} (base-2), which causes merkle trees to lose resolution, what may result in overstreaming. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12481) dtest failure in cqlshlib.test.test_cqlsh_output.TestCqlshOutput.test_describe_keyspace_output
[ https://issues.apache.org/jira/browse/CASSANDRA-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452724#comment-15452724 ] Philip Thompson commented on CASSANDRA-12481: - +1 on the patch. I'll see what I can do about the logs > dtest failure in > cqlshlib.test.test_cqlsh_output.TestCqlshOutput.test_describe_keyspace_output > -- > > Key: CASSANDRA-12481 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12481 > Project: Cassandra > Issue Type: Bug >Reporter: Craig Kodman >Assignee: Stefania > Labels: dtest > > example failure: > http://cassci.datastax.com/job/cassandra-3.0_cqlsh_tests/29/testReport/cqlshlib.test.test_cqlsh_output/TestCqlshOutput/test_describe_keyspace_output > {code} > Error Message > errors={'127.0.0.1': 'Client request timeout. See > Session.execute[_async](timeout)'}, last_host=127.0.0.1 > {code} > http://cassci.datastax.com/job/cassandra-3.0_cqlsh_tests/lastCompletedBuild/cython=no,label=ctool-lab/testReport/cqlshlib.test.test_cqlsh_output/TestCqlshOutput/test_describe_keyspace_output/ -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (CASSANDRA-12527) Stack Overflow returned to queries while upgrading
[ https://issues.apache.org/jira/browse/CASSANDRA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452687#comment-15452687 ] Tyler Hobbs commented on CASSANDRA-12527: - +1, assuming the test runs look good. > Stack Overflow returned to queries while upgrading > -- > > Key: CASSANDRA-12527 > URL: https://issues.apache.org/jira/browse/CASSANDRA-12527 > Project: Cassandra > Issue Type: Bug > Environment: Centos 7 x64 >Reporter: Steve Severance >Assignee: Sylvain Lebresne > Fix For: 3.0.x, 3.x > > > I am currently upgrading our cluster from 2.2.5 to 3.0.8. > Some queries (not sure which) appear to be triggering a stack overflow: > ERROR [SharedPool-Worker-2] 2016-08-24 04:34:52,464 Message.java:611 - > Unexpected exception during request; channel = [id: 0x5ccb2627, > /10.0.2.5:42925 => /10.0.2.10:9042] > java.lang.StackOverflowError: null > at > org.apache.cassandra.db.ClusteringComparator.compare(ClusteringComparator.java:131) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$LegacyBoundComparator.compare(LegacyLayout.java:1761) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$LegacyRangeTombstoneList.add(LegacyLayout.java:1835) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$LegacyRangeTombstoneList.addAll(LegacyLayout.java:1900) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:709) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) > ~[apache-cassandra-3.0.8.jar:3.0.8] > at > org.apache.cassandra.db.LegacyLayout$3.computeNext(LegacyLayout.java:711) >
[jira] [Commented] (CASSANDRA-10145) Change protocol to allow sending key space independent of query string
[ https://issues.apache.org/jira/browse/CASSANDRA-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452650#comment-15452650 ] Sandeep Tamhankar commented on CASSANDRA-10145: --- This is particularly onerous on "gateway" apps like DataStax Studio, which act on behalf of many users and currently have to open many connections. This is also an annoyance to driver developers. This separation of keyspace from the connection itself will have the net effect that the drivers no longer need to create separate connection pools for different sessions. In CASSANDRA-12574, I had proposed leveraging custom-payload to transmit this info, but Sylvain countered {quote} Custom payloads haven't been added for this, they are for use by third party extensions and we should not use them for anything C* as we could ever guarantee this wouldn't conflict with those third party. So this will require a protocol change. And to be honest, I think it's a good thing: using a custom payload would mean drivers and users won't have a clean and easy way to know if the server is going to know and use the payload. A protocol change makes that very clear. {quote} Since we're still in the midst of implementing the v5 protocol, can we add this in then? I'd advocate that this change be additive; a USE command in C* should still bind the keyspace to the connection for backward-compatibility. When speaking v5, drivers would no longer send USE statements themselves, but would rather send the keyspace in each request. Also, specifying the keyspace in requests in v5 should be optional since for statements where keyspace is specified in the cql, there is no "bound keyspace". > Change protocol to allow sending key space independent of query string > -- > > Key: CASSANDRA-10145 > URL: https://issues.apache.org/jira/browse/CASSANDRA-10145 > Project: Cassandra > Issue Type: Improvement >Reporter: Vishy Kasar > > Currently keyspace is either embedded in the query string or set through "use > keyspace" on a connection by client driver. > There are practical use cases where client user has query and keyspace > independently. In order for that scenario to work, they will have to create > one client session per keyspace or have to resort to some string replace > hackery. > It will be nice if protocol allowed sending keyspace separately from the > query. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Reopened] (CASSANDRA-10145) Change protocol to allow sending key space independent of query string
[ https://issues.apache.org/jira/browse/CASSANDRA-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep Tamhankar reopened CASSANDRA-10145: --- Hadn't realized this ticket existed when I created 12574; I'm horrible at Where's Waldo and had given up after 10 minutes of searching. Re-opening this one, moving the gist of 12574 to this one. Thanks, Sylvain! > Change protocol to allow sending key space independent of query string > -- > > Key: CASSANDRA-10145 > URL: https://issues.apache.org/jira/browse/CASSANDRA-10145 > Project: Cassandra > Issue Type: Improvement >Reporter: Vishy Kasar > > Currently keyspace is either embedded in the query string or set through "use > keyspace" on a connection by client driver. > There are practical use cases where client user has query and keyspace > independently. In order for that scenario to work, they will have to create > one client session per keyspace or have to resort to some string replace > hackery. > It will be nice if protocol allowed sending keyspace separately from the > query. -- This message was sent by Atlassian JIRA (v6.3.4#6332)