[ 
https://issues.apache.org/jira/browse/CASSANDRA-18963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ekaterina Dimitrova updated CASSANDRA-18963:
--------------------------------------------
    Description: 
Seems flaky 
[https://app.circleci.com/pipelines/github/driftx/cassandra/1342/workflows/9554c7b5-dd60-4f08-8db5-c954febc8ad6/jobs/58957/tests]


 * 
h4. test_abortedcompaction
 
sstableutil_test.TestSSTableUtil
 
 
{code:java}
self = <sstableutil_test.TestSSTableUtil object at 0x7fc099ecea58> def 
test_abortedcompaction(self): """ @jira_ticket CASSANDRA-7066 @jira_ticket 
CASSANDRA-11497 Check that we can cleanup temporary files after a compaction is 
aborted. """ log_file_name = 'debug.log' cluster = self.cluster 
cluster.populate(1).start() node = cluster.nodelist()[0] numrecords = 250000 
self._create_data(node, KeyspaceName, TableName, numrecords) finalfiles, 
tmpfiles = self._check_files(node, KeyspaceName, TableName) assert 
len(finalfiles) > 0, "Expected to find some final files" assert 0 == 
len(tmpfiles), "Expected no tmp files" t = InterruptCompaction(node, TableName, 
filename=log_file_name, delay=2) t.start() try: logger.debug("Compacting...") 
node.compact() except ToolError: pass # expected to fail t.join() finalfiles = 
_normcase_all(self._invoke_sstableutil(KeyspaceName, TableName, type='final')) 
tmpfiles = _normcase_all(self._invoke_sstableutil(KeyspaceName, TableName, 
type='tmp')) # In most cases we should end up with some temporary files to 
clean up, but it may happen # that no temporary files are created if compaction 
finishes too early or starts too late # see CASSANDRA-11497 logger.debug("Got 
{} final files and {} tmp files after compaction was interrupted" 
.format(len(finalfiles), len(tmpfiles))) self._invoke_sstableutil(KeyspaceName, 
TableName, cleanup=True) self._check_files(node, KeyspaceName, TableName, 
finalfiles, []) # restart to make sure not data is lost 
logger.debug("Restarting node...") > node.start(wait_for_binary_proto=True) 
sstableutil_test.py:97: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
_ _ _ _ _ _ _ _ _ _ _ _ 
../env3.6/lib/python3.6/site-packages/ccmlib/node.py:914: in start 
self.wait_for_binary_interface(from_mark=self.mark) 
../env3.6/lib/python3.6/site-packages/ccmlib/node.py:702: in 
wait_for_binary_interface self.watch_log_for("Starting listening for CQL 
clients", **kwargs) ../env3.6/lib/python3.6/site-packages/ccmlib/node.py:599: 
in watch_log_for self.raise_node_error_if_cassandra_process_is_terminated() _ _ 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
self = <ccmlib.node.Node object at 0x7fc08a583be0> def 
raise_node_error_if_cassandra_process_is_terminated(self): if not 
self._is_pid_running(): msg = "C* process with {pid} is 
terminated".format(pid=self.pid) common.debug(msg) > raise NodeError(msg) E 
ccmlib.node.NodeError: C* process with 19530 is terminated 
../env3.6/lib/python3.6/site-packages/ccmlib/node.py:683: NodeError{code}

  was:Seems flaky 
https://app.circleci.com/pipelines/github/driftx/cassandra/1342/workflows/9554c7b5-dd60-4f08-8db5-c954febc8ad6/jobs/58957/tests


> Test Failure: sstableutil_test.TestSSTableUtil
> ----------------------------------------------
>
>                 Key: CASSANDRA-18963
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-18963
>             Project: Cassandra
>          Issue Type: Bug
>          Components: Test/unit
>            Reporter: Berenguer Blasi
>            Priority: Normal
>             Fix For: 5.0.x
>
>
> Seems flaky 
> [https://app.circleci.com/pipelines/github/driftx/cassandra/1342/workflows/9554c7b5-dd60-4f08-8db5-c954febc8ad6/jobs/58957/tests]
>  * 
> h4. test_abortedcompaction
>  
> sstableutil_test.TestSSTableUtil
>  
>  
> {code:java}
> self = <sstableutil_test.TestSSTableUtil object at 0x7fc099ecea58> def 
> test_abortedcompaction(self): """ @jira_ticket CASSANDRA-7066 @jira_ticket 
> CASSANDRA-11497 Check that we can cleanup temporary files after a compaction 
> is aborted. """ log_file_name = 'debug.log' cluster = self.cluster 
> cluster.populate(1).start() node = cluster.nodelist()[0] numrecords = 250000 
> self._create_data(node, KeyspaceName, TableName, numrecords) finalfiles, 
> tmpfiles = self._check_files(node, KeyspaceName, TableName) assert 
> len(finalfiles) > 0, "Expected to find some final files" assert 0 == 
> len(tmpfiles), "Expected no tmp files" t = InterruptCompaction(node, 
> TableName, filename=log_file_name, delay=2) t.start() try: 
> logger.debug("Compacting...") node.compact() except ToolError: pass # 
> expected to fail t.join() finalfiles = 
> _normcase_all(self._invoke_sstableutil(KeyspaceName, TableName, 
> type='final')) tmpfiles = 
> _normcase_all(self._invoke_sstableutil(KeyspaceName, TableName, type='tmp')) 
> # In most cases we should end up with some temporary files to clean up, but 
> it may happen # that no temporary files are created if compaction finishes 
> too early or starts too late # see CASSANDRA-11497 logger.debug("Got {} final 
> files and {} tmp files after compaction was interrupted" 
> .format(len(finalfiles), len(tmpfiles))) 
> self._invoke_sstableutil(KeyspaceName, TableName, cleanup=True) 
> self._check_files(node, KeyspaceName, TableName, finalfiles, []) # restart to 
> make sure not data is lost logger.debug("Restarting node...") > 
> node.start(wait_for_binary_proto=True) sstableutil_test.py:97: _ _ _ _ _ _ _ 
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
> ../env3.6/lib/python3.6/site-packages/ccmlib/node.py:914: in start 
> self.wait_for_binary_interface(from_mark=self.mark) 
> ../env3.6/lib/python3.6/site-packages/ccmlib/node.py:702: in 
> wait_for_binary_interface self.watch_log_for("Starting listening for CQL 
> clients", **kwargs) ../env3.6/lib/python3.6/site-packages/ccmlib/node.py:599: 
> in watch_log_for self.raise_node_error_if_cassandra_process_is_terminated() _ 
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
> self = <ccmlib.node.Node object at 0x7fc08a583be0> def 
> raise_node_error_if_cassandra_process_is_terminated(self): if not 
> self._is_pid_running(): msg = "C* process with {pid} is 
> terminated".format(pid=self.pid) common.debug(msg) > raise NodeError(msg) E 
> ccmlib.node.NodeError: C* process with 19530 is terminated 
> ../env3.6/lib/python3.6/site-packages/ccmlib/node.py:683: NodeError{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org

Reply via email to