accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ctubb...@apache.org
Subject [23/50] [abbrv] ACCUMULO-1537 completed the conversion of functional tests to IT; also converted ShellServerTest to an IT
Date Wed, 17 Jul 2013 02:33:25 GMT
http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/simple/splitRecovery.py
----------------------------------------------------------------------
diff --git a/test/system/auto/simple/splitRecovery.py b/test/system/auto/simple/splitRecovery.py
deleted file mode 100755
index c860f99..0000000
--- a/test/system/auto/simple/splitRecovery.py
+++ /dev/null
@@ -1,30 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-from JavaTest import JavaTest
-
-import unittest
-
-class SplitRecoveryTest(JavaTest):
-    "Test recovery of partial splits"
-
-    order = 20
-    testClass="org.apache.accumulo.test.functional.SplitRecoveryTest"
-
-
-def suite():
-    result = unittest.TestSuite()
-    result.addTest(SplitRecoveryTest())
-    return result

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/simple/wal.py
----------------------------------------------------------------------
diff --git a/test/system/auto/simple/wal.py b/test/system/auto/simple/wal.py
deleted file mode 100755
index a3e4bef..0000000
--- a/test/system/auto/simple/wal.py
+++ /dev/null
@@ -1,68 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import signal
-import os
-import unittest
-import logging
-from simple.readwrite import SunnyDayTest
-from TestUtils import ACCUMULO_HOME
-
-log = logging.getLogger('test.auto')
-
-class WriteAheadLog(SunnyDayTest):
-
-     order = 25
-
-     settings = SunnyDayTest.settings.copy()
-   
-     # roll the log at least once
-     settings['tserver.walog.max.size'] = '2M'
-     settings['gc.cycle.delay'] = 1
-     settings['gc.cycle.start'] = 1
-     settings['master.recovery.delay'] = 0
-
-     # compact frequently
-     settings['tserver.memory.maps.max'] = '200K'
-     settings['tserver.compaction.major.delay'] = 1
-
-     # split frequently
-     tableSettings = SunnyDayTest.tableSettings.copy()
-     tableSettings['test_ingest'] = { 
-         'table.split.threshold': '750K',
-         }
-
-     def runTest(self):
-          self.sleep(3)
-          waitTime = self.waitTime()
-          self.waitForStop(self.ingester, waitTime)
-          log.info("Stopping tablet servers hard")
-          self.stop_accumulo(signal.SIGKILL)
-          self.sleep(5)
-          self.start_accumulo()
-          h = self.runOn(self.masterHost(), [self.accumulo_sh(), "gc"])
-          self.sleep(3)
-          log.info("Verifying Ingestion")
-          self.waitForStop(self.verify(self.masterHost(),
-                                       self.options.rows,
-                                       size=self.options.size),
-                           waitTime)
-          self.shutdown_accumulo()
-
-def suite():
-     result = unittest.TestSuite()
-     result.addTest(WriteAheadLog())
-     return result
-

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/simple/zoo.py
----------------------------------------------------------------------
diff --git a/test/system/auto/simple/zoo.py b/test/system/auto/simple/zoo.py
deleted file mode 100755
index d84cbe9..0000000
--- a/test/system/auto/simple/zoo.py
+++ /dev/null
@@ -1,54 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import os
-
-import logging
-import unittest
-import signal
-
-from readwrite import SunnyDayTest
-import TestUtils
-
-class SessionExpired(SunnyDayTest):
-
-    order = 25
-
-    def signal(self, which):
-        for host in self.hosts:
-            self.pkill(host, '=tserver', which)
-
-    def runTest(self):
-        # stop the tservers from talking to zookeeeper
-        self.signal(signal.SIGSTOP)
-        
-        # timeout the session
-        self.sleep(40)
-        
-        # turn the tservers back on so that they see the expired session
-        self.signal(signal.SIGCONT)
-
-        # wait for the tesrvers to stop (master and monitor are first and last
-        # handles)
-        for h in self.accumuloHandles[1:-1]:
-            if 'tserver' in h.cmd:
-                self.waitForStop(h, 5)
-        self.cleanupAccumuloHandles()
-
-        
-def suite():
-    result = unittest.TestSuite()
-    result.addTest(SessionExpired())
-    return result

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/simple/zooCacheTest.py
----------------------------------------------------------------------
diff --git a/test/system/auto/simple/zooCacheTest.py b/test/system/auto/simple/zooCacheTest.py
deleted file mode 100755
index fcbb3ab..0000000
--- a/test/system/auto/simple/zooCacheTest.py
+++ /dev/null
@@ -1,51 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import os
-import shutil
-import unittest
-import time
-
-from TestUtils import TestUtilsMixin, ACCUMULO_HOME, SITE, ZOOKEEPERS
-
-class ZooCacheTest(TestUtilsMixin, unittest.TestCase):
-    "Zoo Cache Test"
-
-    order = 21
-    testClass=""
-
-    def setUp(self):
-        self.create_config_file(self.settings.copy())
-        
-    def runTest(self):
-        shutil.rmtree('/tmp/zcTest-42')
-        handleCC = self.runClassOn('localhost', 'org.apache.accumulo.test.functional.CacheTestClean',
['/zcTest-42','/tmp/zcTest-42'])
-        self.waitForStop(handleCC, 10)
-        handleR1 = self.runClassOn('localhost', 'org.apache.accumulo.test.functional.CacheTestReader',
['/zcTest-42','/tmp/zcTest-42', ZOOKEEPERS])
-        handleR2 = self.runClassOn('localhost', 'org.apache.accumulo.test.functional.CacheTestReader',
['/zcTest-42','/tmp/zcTest-42', ZOOKEEPERS])
-        handleR3 = self.runClassOn('localhost', 'org.apache.accumulo.test.functional.CacheTestReader',
['/zcTest-42','/tmp/zcTest-42', ZOOKEEPERS])
-        handleW = self.runClassOn('localhost', 'org.apache.accumulo.test.functional.CacheTestWriter',
['/zcTest-42','/tmp/zcTest-42','3','500'])
-        self.waitForStop(handleW, 200)
-        self.waitForStop(handleR1, 1)
-        self.waitForStop(handleR2, 1)
-        self.waitForStop(handleR3, 1)
-
-    def tearDown(self):
-        os.unlink(os.path.join(ACCUMULO_HOME, 'conf', SITE))
-
-def suite():
-    result = unittest.TestSuite()
-    result.addTest(ZooCacheTest())
-    return result

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/stress/halfDead.py
----------------------------------------------------------------------
diff --git a/test/system/auto/stress/halfDead.py b/test/system/auto/stress/halfDead.py
deleted file mode 100755
index fa5255a..0000000
--- a/test/system/auto/stress/halfDead.py
+++ /dev/null
@@ -1,101 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import os
-
-import time
-import signal
-import unittest
-
-from simple.readwrite import SunnyDayTest
-from TestUtils import ACCUMULO_HOME
-
-import logging
-log = logging.getLogger('test.auto')
-
-class TabletServerHangs(SunnyDayTest):
-
-     order = 25
-   
-     # connections should timeout quickly for faster tests
-     settings = SunnyDayTest.settings.copy()
-     settings['general.rpc.timeout'] = '5s'
-     settings['instance.zookeeper.timeout'] = '15s'
-
-     def start_tserver(self, host):
-         log.info("Starting tserver we can pause with bad read/writes")
-         libpath = '%s/test/system/auto/fake_disk_failure.so' % ACCUMULO_HOME
-         os.environ['LD_PRELOAD'] = libpath
-         os.environ['DYLD_INSERT_LIBRARIES'] = libpath
-         os.environ['DYLD_FORCE_FLAT_NAMESPACE'] = 'true'
-         self.stop = self.runOn(self.masterHost(), [self.accumulo_sh(), 'tserver'])
-         del os.environ['LD_PRELOAD']
-         del os.environ['DYLD_FORCE_FLAT_NAMESPACE']
-         del os.environ['DYLD_INSERT_LIBRARIES']
-         self.flagFile = os.getenv("HOME") + "/HOLD_IO_%d" % self.stop.pid
-         log.debug("flag file is " + self.flagFile)
-         return self.stop
-          
-     def runTest(self):
-         waitTime = self.waitTime()
-         log.info("Waiting for ingest to stop")
-         self.waitForStop(self.ingester, waitTime)
-         MANY_ROWS = 500000
-
-         
-         self.ingester = self.ingest(self.masterHost(),
-                                     MANY_ROWS,
-                                     size=self.options.size)
-         # wait for the ingester to get going
-         for i in range(100):
-	     line = self.ingester.stdout.readline()
-	     if line == '' or line.find(' sent ') > 0:
-                break
-
-         log.info("Starting faking disk failure for tserver")
-         fp = open(self.flagFile, "w+")
-         fp.close()
-
-         self.sleep(10)
-         log.info("Ending faking disk failure for tserver")
-         os.unlink(self.flagFile)
-
-         # look for the log message that indicates a timeout
-         out, err = self.waitForStop(self.ingester, waitTime)
-         self.assert_(out.find('requeuing') >= 0)
-
-         log.info("Verifying Ingestion")
-         self.waitForStop(self.verify(self.masterHost(),
-                                      MANY_ROWS,
-                                      size=self.options.size),
-                          waitTime)
-         os.kill(self.stop.pid, signal.SIGHUP)
-
-         # look for the log message that indicates the tablet server stopped for a while
-         out, err = self.stop.communicate()
-         self.assert_(err.find('sleeping\nsleeping\nsleeping\n') >= 0)
-          
-
-     def tearDown(self):
-         SunnyDayTest.tearDown(self)
-         try:
-              os.unlink(self.flagFile)
-         except:
-              pass
-
-def suite():
-    result = unittest.TestSuite()
-    result.addTest(TabletServerHangs())
-    return result

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/stress/migrations.py
----------------------------------------------------------------------
diff --git a/test/system/auto/stress/migrations.py b/test/system/auto/stress/migrations.py
deleted file mode 100755
index d07d7a8..0000000
--- a/test/system/auto/stress/migrations.py
+++ /dev/null
@@ -1,82 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import os
-
-import logging
-import unittest
-import time
-import sleep
-
-from TestUtils import TestUtilsMixin, ACCUMULO_DIR
-
-log = logging.getLogger('test.auto')
-
-from simple.readwrite import SunnyDayTest, Interleaved
-from simple.delete import DeleteTest
-
-class ChaoticBalancerIntegrity(SunnyDayTest):
-    """Start a new table, create many splits, and attempt ingest while running a crazy load
balancer"""
-
-    order = 90
-
-    settings = TestUtilsMixin.settings.copy()
-    settings.update({
-      'tserver.memory.maps.max':'10K',
-      'tserver.compaction.major.delay': 0,
-      'table.balancer':'org.apache.accumulo.server.master.balancer.ChaoticLoadBalancer',
-      })
-
-    tableSettings = SunnyDayTest.tableSettings.copy()
-    tableSettings['test_ingest'] = { 
-    	'table.split.threshold': '10K',
-        }
-    def setUp(self):
-        # ensure we have two servers
-        if len(self.options.hosts) == 1:
-            self.options.hosts.append('localhost')
-        self.options.hosts = self.options.hosts[:2]
-        
-        TestUtilsMixin.setUp(self);
-
-        # create a table with 200 splits
-        import tempfile
-        fileno, filename = tempfile.mkstemp()
-        fp = os.fdopen(fileno, "wb")
-        try:
-            for i in range(200):
-                fp.write("%08x\n" % (i * 1000))
-        finally:
-            fp.close()
-        self.createTable('unused', filename)
-
-        # create an empty table
-        self.createTable('test_ingest')
-
-    def runTest(self):
-
-        # start test ingestion
-        log.info("Starting Test Ingester")
-        self.ingester = self.ingest(self.masterHost(),
-                                    200000,
-                                    size=self.options.size)
-        self.waitForStop(self.ingester, 120)
-        self.shell(self.masterHost(), 'flush -t test_ingest')
-        self.waitForStop(self.verify(self.masterHost(), self.options.rows), 60)
-
-def suite():
-    result = unittest.TestSuite()
-    result.addTest(ChaoticBalancerIntegrity())
-    return result

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/stress/msplit.py
----------------------------------------------------------------------
diff --git a/test/system/auto/stress/msplit.py b/test/system/auto/stress/msplit.py
deleted file mode 100755
index 1d639e5..0000000
--- a/test/system/auto/stress/msplit.py
+++ /dev/null
@@ -1,53 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import os
-
-import logging
-import unittest
-import time
-
-from TestUtils import ACCUMULO_DIR
-
-from simple.split import TabletShouldSplit
-
-log = logging.getLogger('test.auto')
-
-class MetaSplitTest(TabletShouldSplit):
-
-    order = TabletShouldSplit.order + 1
-    
-    tableSettings = TabletShouldSplit.tableSettings.copy()
-    tableSettings['!METADATA'] = { 
-    	'table.split.threshold': 500,
-        }
-    tableSettings['test_ingest'] = { 
-    	'table.split.threshold': '200K',
-    	'table.file.compress.blocksize': '10K',
-        }
-
-    def runTest(self):
-        TabletShouldSplit.runTest(self)
-        handle = self.runOn(self.masterHost(), [
-            'hadoop', 'fs', '-ls', os.path.join(ACCUMULO_DIR,'tables',self.getTableId('!METADATA'))
-            ])
-        out, err = handle.communicate()
-        lst = [line for line in out.split('\n') if line.find('tables') >= 0]
-        self.assert_(len(lst) > 3)
-
-def suite():
-    result = unittest.TestSuite()
-    result.addTest(MetaSplitTest())
-    return result

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/stress/restart.py
----------------------------------------------------------------------
diff --git a/test/system/auto/stress/restart.py b/test/system/auto/stress/restart.py
deleted file mode 100755
index 4e7f66c..0000000
--- a/test/system/auto/stress/restart.py
+++ /dev/null
@@ -1,199 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-from simple.readwrite import SunnyDayTest
-
-import unittest
-import logging
-import os
-import signal
-from TestUtils import TestUtilsMixin, ACCUMULO_HOME
-from subprocess import PIPE
-
-log = logging.getLogger('test.auto')
-
-class RestartTest(SunnyDayTest):
-    order = 80
-
-class RestartMasterTest(RestartTest):
-
-    def runTest(self):
-
-        self.sleep(3)
-        log.info("Stopping master server")
-        self.stop_master(self.masterHost())
-        self.sleep(1)
-        log.info("Starting master server")
-        self.start_master(self.masterHost())
-
-        self.waitForStop(self.ingester, 30)
-        self.waitForStop(self.verify(self.masterHost(), self.options.rows), 60)
-
-
-class RestartMasterRecovery(RestartTest):
-
-    settings = RestartTest.settings.copy()
-    settings['instance.zookeeper.timeout'] = 5
-
-    def runTest(self):
-        self.waitForStop(self.ingester, 30)
-
-        # start a recovery
-        self.stop_accumulo()
-        self.start_accumulo_procs()
-
-        self.sleep(5)
-
-        self.stop_master(self.masterHost())
-        self.start_master(self.masterHost())
-
-        self.waitForStop(self.verify(self.masterHost(), self.options.rows), 100)
-
-
-class RestartMasterSplitterTest(RestartMasterTest):
-    tableSettings = RestartMasterTest.tableSettings.copy()
-    tableSettings['test_ingest'] = { 
-            'table.split.threshold': '5K',
-        }
-
-
-class KilledTabletServerTest(RestartTest):
-
-    def startRead(self):
-        return self.verify(self.masterHost(), self.options.rows)
-
-    def stopRead(self, handle, timeout):
-        self.waitForStop(handle, timeout)
-
-    def readRows(self):
-        self.stopRead(self.startRead(), 400)
-
-    def runTest(self):
-
-        self.waitForStop(self.ingester, 120)
-        log.info("Ingester stopped")
-        log.info("starting scan")
-        self.readRows()
-        for host in self.hosts:
-            log.info("Restarting Tablet server on %s", host)
-            self.stop_tserver(host, signal.SIGKILL)
-            self.start_tserver(host)
-            log.info("Tablet server on %s started", host)
-            log.info("starting scan")
-            self.readRows()
-
-class KilledTabletServerSplitTest(KilledTabletServerTest):
-    tableSettings = KilledTabletServerTest.tableSettings.copy()
-    tableSettings['test_ingest'] = { 
-            'table.split.threshold': '5K',
-        }
-
-    settings = TestUtilsMixin.settings.copy()
-    settings.update({
-        'tserver.memory.maps.max':'5K',
-        'tserver.compaction.major.delay': 1,
-        'tserver.walog.max.size': '50K',
-        })
-
-    def ingest(self, host, count, start=0, timestamp=None, size=50, colf=None, **kwargs):
-        return KilledTabletServerTest.ingest(self, host, count*10, start, timestamp, size,
colf)
-
-    def verify(self, host, count, start=0, size=50, timestamp=None, colf='colf'):
-        return KilledTabletServerTest.verify(self, host, count*10, start, size, timestamp,
colf)
-            
-    def runTest(self):
-
-        for i in range(5):
-            self.sleep(20)
-            self.stop_tserver(self.masterHost(), signal.SIGKILL)
-            self.start_tserver(self.masterHost())
-
-        self.waitForStop(self.ingester, 600)
-        log.info("Ingester stopped")
-        log.info("starting scan")
-        self.readRows()
-        for host in self.hosts:
-            log.info("Restarting Tablet server on %s", host)
-            self.stop_tserver(host, signal.SIGKILL)
-            self.start_tserver(host)
-            log.info("Tablet server on %s started", host)
-            log.info("starting scan")
-            self.readRows()
-
-
-class KilledTabletDuringScan(KilledTabletServerTest):
-    "Kill a tablet server while we are scanning a table"
-
-    def runTest(self):
-
-        self.waitForStop(self.ingester, 90)
-        log.info("Ingester stopped")
-        handle = self.startRead()
-
-        for host in self.hosts:
-            log.info("Restarting Tablet server on %s", host)
-            self.stop_tserver(host, signal.SIGKILL)
-            self.start_tserver(host)
-            log.info("Tablet server on %s started", host)
-            log.info("starting scan")
-            self.stopRead(handle, 500)
-            if host != self.hosts[-1]:
-                handle = self.startRead()
-
-class KilledTabletDuringShutdown(KilledTabletServerTest):
-
-    def runTest(self):
-        self.waitForStop(self.ingester, 90)
-        log.info("Ingester stopped")
-        self.stop_tserver(self.hosts[0], signal.SIGKILL)
-        log.info("This can take a couple minutes")
-        self.shutdown_accumulo()
-
-
-from simple.split import TabletShouldSplit
-
-class ShutdownSplitter(TabletShouldSplit):
-    "Shutdown while compacting, splitting, and migrating"
-
-    tableSettings = TabletShouldSplit.tableSettings.copy()
-    tableSettings['!METADATA'] = { 
-            'table.split.threshold': '10K',
-        }
-    tableSettings['test_ingest'] = { 
-            'table.split.threshold': '5K',
-        }
-
-    def runTest(self):
-        self.sleep(1)
-        self.shutdown_accumulo()
-
-        # look for any exceptions
-        self.wait(
-            self.runOn(self.masterHost(),
-                       ['grep', '-r', '-q', '" at org.apache.accumulo.core"\\\\\\|" at org.apache.accumulo.server"',
-                        os.path.join(ACCUMULO_HOME,'logs') ])
-            )
-
-def suite():
-    result = unittest.TestSuite()
-    result.addTest(ShutdownSplitter())
-    result.addTest(KilledTabletDuringShutdown())
-    result.addTest(RestartMasterRecovery())
-    result.addTest(KilledTabletDuringScan())
-    result.addTest(RestartMasterTest())
-    result.addTest(RestartMasterSplitterTest())
-    result.addTest(KilledTabletServerTest())
-    result.addTest(KilledTabletServerSplitTest())
-    return result

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/stress/table.py
----------------------------------------------------------------------
diff --git a/test/system/auto/stress/table.py b/test/system/auto/stress/table.py
deleted file mode 100755
index 7c3e4c5..0000000
--- a/test/system/auto/stress/table.py
+++ /dev/null
@@ -1,61 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import unittest
-
-import os
-from TestUtils import TestUtilsMixin, ROOT, ROOT_PASSWORD, ACCUMULO_DIR
-
-class Table(TestUtilsMixin, unittest.TestCase):
-    "create and destroy the same table repeatedly, sometimes ingesting into it"
-
-    order = 85
-
-    def deleteTable(self, table):
-        out, err, code = self.rootShell(self.masterHost(),
-                                        "deletetable %s\n" % table)
-        self.processResult(out, err, code)
-        self.sleep(0.5)
-        
-    def tables(self):
-        code, out, err = self.shell(self.masterHost(), "tables\n")
-        self.processResult(out, err, code)
-        return out
-
-    def runTest(self):
-        import tempfile
-        fileno, self.filename = tempfile.mkstemp()
-        fp = os.fdopen(fileno, "wb")
-        try:
-            for i in range(0, 200, 10):
-                fp.write("%08x\n" % (i * 1000))
-            fp.close()
-
-            for i in range(5):
-                self.createTable('test_ingest')
-                self.deleteTable('test_ingest')
-            self.createTable('test_ingest')
-            for i in range(5):
-                self.wait(self.ingest(self.masterHost(), 10, start=i*10))
-                self.wait(self.verify(self.masterHost(), 10, start=i*10))
-                self.deleteTable('test_ingest')
-                self.createTable('test_ingest', self.filename)
-        finally:
-            os.unlink(self.filename)
-        
-def suite():
-    result = unittest.TestSuite()
-    result.addTest(Table())
-    return result

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7a1075a4/test/system/auto/stress/weird.py
----------------------------------------------------------------------
diff --git a/test/system/auto/stress/weird.py b/test/system/auto/stress/weird.py
deleted file mode 100755
index d7e0697..0000000
--- a/test/system/auto/stress/weird.py
+++ /dev/null
@@ -1,49 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import os
-
-import logging
-import unittest
-
-from TestUtils import TestUtilsMixin
-
-log = logging.getLogger('test.auto')
-
-class LateLastContact(TestUtilsMixin, unittest.TestCase):
-    """Fake the "tablet stops talking but holds its lock" problem we see when hard drives
and NFS fail.
-       Start a ZombieTServer, and see that master stops it.
-    """
-
-    order = 80
-
-    settings = TestUtilsMixin.settings.copy()
-    settings['general.rpc.timeout'] = '2s'
-
-    def setUp(self):
-        TestUtilsMixin.setUp(self);
-    
-    def tearDown(self):
-        TestUtilsMixin.tearDown(self);
-
-    def runTest(self):
-        handle = self.runClassOn(self.masterHost(), 'org.apache.accumulo.test.functional.ZombieTServer',
[])
-        out, err = handle.communicate()
-        assert handle.returncode == 0
-
-def suite():
-    result = unittest.TestSuite()
-    result.addTest(LateLastContact())
-    return result


Mime
View raw message