[ 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