Merge pull request #3378 from bipinprasad/storm3743
[STORM-3743] Add new topologies and change TestLargeCluster
diff --git a/storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java b/storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java
index ca73d9a..5e071e6 100644
--- a/storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java
+++ b/storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java
@@ -1,4 +1,4 @@
-/**
+/*
* 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
@@ -62,13 +62,32 @@
import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
+import java.util.concurrent.atomic.AtomicInteger;
@ExtendWith({NormalizedResourcesExtension.class})
public class TestLargeCluster {
private static final Logger LOG = LoggerFactory.getLogger(TestLargeCluster.class);
- public static final String TEST_CLUSTER_NAME = "largeCluster01";
- public static final String TEST_RESOURCE_PATH = "clusterconf/" + TEST_CLUSTER_NAME;
+ public enum TEST_CLUSTER_NAME {
+ TEST_CLUSTER_01("largeCluster01"),
+ TEST_CLUSTER_02("largeCluster02"),
+ TEST_CLUSTER_03("largeCluster03");
+
+ private final String clusterName;
+
+ TEST_CLUSTER_NAME(String clusterName) {
+ this.clusterName = clusterName;
+ }
+
+ String getClusterName() {
+ return clusterName;
+ }
+
+ String getResourcePath() {
+ return "clusterconf/" + clusterName;
+ }
+ }
+
public static final String COMPRESSED_SERIALIZED_TOPOLOGY_FILENAME_ENDING = "code.ser";
public static final String COMPRESSED_SERIALIZED_CONFIG_FILENAME_ENDING = "conf.ser";
@@ -88,8 +107,8 @@
* files are sequential. Unpaired files may be ignored by the caller.
*
* @param path directory in which resources exist.
- * @return
- * @throws IOException
+ * @return list of resource file names
+ * @throws IOException upon exception in reading resources.
*/
public static List<String> getResourceFiles(String path) throws IOException {
List<String> fileNames = new ArrayList<>();
@@ -114,8 +133,8 @@
/**
* InputStream to read the fully qualified resource path.
*
- * @param resource
- * @return
+ * @param resource path to read.
+ * @return InputStream of the resource being read.
*/
public static InputStream getResourceAsStream(String resource) {
final InputStream in = getContextClassLoader().getResourceAsStream(resource);
@@ -125,9 +144,9 @@
/**
* Read the contents of the fully qualified resource path.
*
- * @param resource
- * @return
- * @throws Exception
+ * @param resource to read.
+ * @return byte array of the fully read resource.
+ * @throws Exception upon error in reading resource.
*/
public static byte[] getResourceAsBytes(String resource) throws Exception {
InputStream in = getResourceAsStream(resource);
@@ -148,25 +167,24 @@
/**
* Create an array of TopologyDetails by reading serialized files for topology and configuration in the
- * resource path.
+ * resource path. Skip topologies with no executors/components.
*
* @param failOnParseError throw exception if there are unmatched files, otherwise ignore unmatched and read errors.
* @return An array of TopologyDetails representing resource files.
- * @throws Exception
+ * @throws Exception upon error in reading topology serialized files.
*/
- public static TopologyDetails[] createTopoDetailsArray(boolean failOnParseError) throws Exception {
+ public static TopologyDetails[] createTopoDetailsArray(String resourcePath, boolean failOnParseError) throws Exception {
List<TopologyDetails> topoDetailsList = new ArrayList<>();
List<String> errors = new ArrayList<>();
- List<String> resources = getResourceFiles(TEST_RESOURCE_PATH);
+ List<String> resources = getResourceFiles(resourcePath);
Map<String, String> codeResourceMap = new TreeMap<>();
Map<String, String> confResourceMap = new HashMap<>();
- for (int i = 0 ; i < resources.size() ; i++) {
- String resource = resources.get(i);
+ for (String resource : resources) {
int idxOfSlash = resource.lastIndexOf("/");
int idxOfDash = resource.lastIndexOf("-");
String nm = idxOfDash > idxOfSlash
- ? resource.substring(idxOfSlash + 1, idxOfDash)
- : resource.substring(idxOfSlash + 1, resource.length() - COMPRESSED_SERIALIZED_TOPOLOGY_FILENAME_ENDING.length());
+ ? resource.substring(idxOfSlash + 1, idxOfDash)
+ : resource.substring(idxOfSlash + 1, resource.length() - COMPRESSED_SERIALIZED_TOPOLOGY_FILENAME_ENDING.length());
if (resource.endsWith(COMPRESSED_SERIALIZED_TOPOLOGY_FILENAME_ENDING)) {
codeResourceMap.put(nm, resource);
} else if (resource.endsWith(COMPRESSED_SERIALIZED_CONFIG_FILENAME_ENDING)) {
@@ -187,15 +205,15 @@
Config.TOPOLOGY_ACKER_RESOURCES_ONHEAP_MEMORY_MB,
};
- for (String nm : codeResourceMap.keySet()) {
- String codeResource = codeResourceMap.get(nm);
- if (!confResourceMap.containsKey(nm)) {
- String err = String.format("Ignoring topology file %s because of missing config file for %s", codeResource, nm);
+ for (String topoId : codeResourceMap.keySet()) {
+ String codeResource = codeResourceMap.get(topoId);
+ if (!confResourceMap.containsKey(topoId)) {
+ String err = String.format("Ignoring topology file %s because of missing config file for %s", codeResource, topoId);
errors.add(err);
LOG.error(err);
continue;
}
- String confResource = confResourceMap.get(nm);
+ String confResource = confResourceMap.get(topoId);
LOG.info("Found matching topology and config files: {}, {}", codeResource, confResource);
StormTopology stormTopology;
try {
@@ -240,11 +258,10 @@
conf.put(Config.TOPOLOGY_RAS_ACKER_EXECUTORS_PER_WORKER, 1);
}
- String topoId = nm;
- String topoName = (String) conf.getOrDefault(Config.TOPOLOGY_NAME, nm);
+ String topoName = (String) conf.getOrDefault(Config.TOPOLOGY_NAME, topoId);
// conf
- StringBuffer sb = new StringBuffer("Config for " + nm + ": ");
+ StringBuilder sb = new StringBuilder("Config for " + topoId + ": ");
for (String param : examinedConfParams) {
Object val = conf.getOrDefault(param, "<null>");
sb.append(param).append("=").append(val).append(", ");
@@ -255,6 +272,10 @@
Map<ExecutorDetails, String> execToComp = TestUtilsForResourceAwareScheduler.genExecsAndComps(stormTopology);
LOG.info("Topology \"{}\" spouts={}, bolts={}, execToComp size is {}", topoName,
stormTopology.get_spouts_size(), stormTopology.get_bolts_size(), execToComp.size());
+ if (execToComp.isEmpty()) {
+ LOG.error("Topology \"{}\" Ignoring BAD topology with zero executors", topoName);
+ continue;
+ }
int numWorkers = Integer.parseInt("" + conf.getOrDefault(Config.TOPOLOGY_WORKERS, "0"));
TopologyDetails topo = new TopologyDetails(topoId, conf, stormTopology, numWorkers,
execToComp, Time.currentTimeSecs(), "user");
@@ -276,9 +297,12 @@
*/
@Test
public void testReadSerializedTopologiesAndConfigs() throws Exception {
- List<String> resources = getResourceFiles(TEST_RESOURCE_PATH);
- Assert.assertTrue("No resource files found in " + TEST_RESOURCE_PATH, !resources.isEmpty());
- TopologyDetails[] topoDetailsArray = createTopoDetailsArray(true);
+ for (TEST_CLUSTER_NAME testClusterName: TEST_CLUSTER_NAME.values()) {
+ String resourcePath = testClusterName.getResourcePath();
+ List<String> resources = getResourceFiles(resourcePath);
+ Assert.assertFalse("No resource files found in " + resourcePath, resources.isEmpty());
+ createTopoDetailsArray(resourcePath, true);
+ }
}
/**
@@ -312,114 +336,234 @@
}
/**
- * Create supervisors.
+ * Create supervisors based on a predefined supervisor distribution modeled after an existing
+ * large cluster in use.
*
- * @param uniformSupervisors true if all supervisors are of the same size, false otherwise.
- * @return supervisor details indexed by id
+ * @param testClusterName cluster for which the supervisors are created.
+ * @param reducedSupervisorsPerRack number of supervisors to reduce per rack.
+ * @return created supervisors.
*/
- private static Map<String, SupervisorDetails> createSupervisors(boolean uniformSupervisors) {
- Map<String, SupervisorDetails> retVal;
- if (uniformSupervisors) {
- int numRacks = 16;
- int numSupersPerRack = 82;
- int numPorts = 50; // note: scheduling is slower when components with large cpu/mem leave large percent of workerslots unused
- int rackStart = 0;
- int superInRackStart = 1;
- double cpu = 7200; // %percent
- double mem = 356_000; // MB
- Map<String, Double> miscResources = new HashMap<>();
- miscResources.put("network.resource.units", 100.0);
+ private static Map<String, SupervisorDetails> createSupervisors(
+ TEST_CLUSTER_NAME testClusterName, int reducedSupervisorsPerRack) {
- return TestUtilsForResourceAwareScheduler.genSupervisorsWithRacks(
- numRacks, numSupersPerRack, numPorts, rackStart, superInRackStart, cpu, mem, miscResources);
+ Collection<SupervisorDistribution> supervisorDistributions = SupervisorDistribution.getSupervisorDistribution(testClusterName);
+ Map<String, Collection<SupervisorDistribution>> byRackId = SupervisorDistribution.mapByRackId(supervisorDistributions);
+ LOG.info("Cluster={}, Designed capacity: {}",
+ testClusterName.getClusterName(), SupervisorDistribution.clusterCapacity(supervisorDistributions));
- } else {
- // this non-uniform supervisor distribution closely (but not exactly) mimics a large cluster in use
- int numSupersPerRack = 82;
- int numPorts = 50;
-
- Map<String, SupervisorDetails> retList = new HashMap<>();
-
- for (int rack = 0 ; rack < 12 ; rack++) {
- double cpu = 3600; // %percent
- double mem = 178_000; // MB
- for (int superInRack = 0; superInRack < numSupersPerRack ; superInRack++) {
- createAndAddOneSupervisor(rack, superInRack, cpu - 100 * (superInRack % 2), mem, numPorts, retList);
- }
+ Map<String, SupervisorDetails> retList = new HashMap<>();
+ Map<String, AtomicInteger> seenRacks = new HashMap<>();
+ byRackId.forEach((rackId, list) -> {
+ int tmpRackSupervisorCnt = list.stream().mapToInt(x -> x.supervisorCnt).sum();
+ if (tmpRackSupervisorCnt > Math.abs(reducedSupervisorsPerRack)) {
+ tmpRackSupervisorCnt -= Math.abs(reducedSupervisorsPerRack);
}
- for (int rack = 12 ; rack < 14 ; rack++) {
- double cpu = 2400; // %percent
- double mem = 118_100; // MB
- for (int superInRack = 0; superInRack < numSupersPerRack ; superInRack++) {
- createAndAddOneSupervisor(rack, superInRack, cpu - 100 * (superInRack % 2), mem, numPorts, retList);
+ final int adjustedRackSupervisorCnt = tmpRackSupervisorCnt;
+ list.forEach(x -> {
+ int supervisorCnt = x.supervisorCnt;
+ for (int i = 0; i < supervisorCnt; i++) {
+ int superInRack = seenRacks.computeIfAbsent(rackId, z -> new AtomicInteger(-1)).incrementAndGet();
+ int rackNum = seenRacks.size() - 1;
+ if (superInRack >= adjustedRackSupervisorCnt) {
+ continue;
+ }
+ createAndAddOneSupervisor(rackNum, superInRack, x.cpuPercent, x.memoryMb, x.slotCnt, retList);
}
- }
- for (int rack = 14 ; rack < 16 ; rack++) {
- double cpu = 1200; // %percent
- double mem = 42_480; // MB
- for (int superInRack = 0; superInRack < numSupersPerRack ; superInRack++) {
- createAndAddOneSupervisor(rack, superInRack, cpu - 100 * (superInRack % 2), mem, numPorts, retList);
- }
- }
- return retList;
- }
+ });
+ });
+ return retList;
}
/**
* Create a large cluster, read topologies and configuration from resource directory and schedule.
*
- * @throws Exception
+ * @throws Exception upon error.
*/
@Test
public void testLargeCluster() throws Exception {
- boolean uniformSupervisors = false; // false means non-uniform supervisor distribution
+ for (TEST_CLUSTER_NAME testClusterName: TEST_CLUSTER_NAME.values()) {
+ LOG.info("********************************************");
+ LOG.info("testLargeCluster: Start Processing cluster {}", testClusterName.getClusterName());
- Map<String, SupervisorDetails> supervisors = createSupervisors(uniformSupervisors);
+ String resourcePath = testClusterName.getResourcePath();
+ Map<String, SupervisorDetails> supervisors = createSupervisors(testClusterName, 0);
- TopologyDetails[] topoDetailsArray = createTopoDetailsArray(false);
- Assert.assertTrue("No topologies found", topoDetailsArray.length > 0);
- Topologies topologies = new Topologies(topoDetailsArray);
+ TopologyDetails[] topoDetailsArray = createTopoDetailsArray(resourcePath, false);
+ Assert.assertTrue("No topologies found for cluster " + testClusterName.getClusterName(), topoDetailsArray.length > 0);
+ Topologies topologies = new Topologies(topoDetailsArray);
- Config confWithDefaultStrategy = new Config();
- confWithDefaultStrategy.putAll(topoDetailsArray[0].getConf());
- confWithDefaultStrategy.put(Config.TOPOLOGY_SCHEDULER_STRATEGY, DefaultResourceAwareStrategy.class.getName());
+ Config confWithDefaultStrategy = new Config();
+ confWithDefaultStrategy.putAll(topoDetailsArray[0].getConf());
+ confWithDefaultStrategy.put(Config.TOPOLOGY_SCHEDULER_STRATEGY, DefaultResourceAwareStrategy.class.getName());
+ confWithDefaultStrategy.put(
+ Config.STORM_NETWORK_TOPOGRAPHY_PLUGIN,
+ TestUtilsForResourceAwareScheduler.GenSupervisorsDnsToSwitchMapping.class.getName());
- INimbus iNimbus = new INimbusTest();
- Cluster cluster = new Cluster(iNimbus, new ResourceMetrics(new StormMetricsRegistry()), supervisors, new HashMap<>(),
+ INimbus iNimbus = new INimbusTest();
+ Cluster cluster = new Cluster(iNimbus, new ResourceMetrics(new StormMetricsRegistry()), supervisors, new HashMap<>(),
topologies, confWithDefaultStrategy);
- scheduler = new ResourceAwareScheduler();
+ scheduler = new ResourceAwareScheduler();
- List<Class> classesToDebug = Arrays.asList(DefaultResourceAwareStrategy.class,
+ List<Class> classesToDebug = Arrays.asList(DefaultResourceAwareStrategy.class,
GenericResourceAwareStrategy.class, ResourceAwareScheduler.class,
Cluster.class
- );
- Level logLevel = Level.INFO ; // switch to Level.DEBUG for verbose otherwise Level.INFO
- classesToDebug.forEach(x -> Configurator.setLevel(x.getName(), logLevel));
- long startTime = System.currentTimeMillis();
- scheduler.prepare(confWithDefaultStrategy, new StormMetricsRegistry());
- scheduler.schedule(topologies, cluster);
- long endTime = System.currentTimeMillis();
- LOG.info("Scheduling Time: {} topologies in {} seconds", topoDetailsArray.length, (endTime - startTime) / 1000.0);
+ );
+ Level logLevel = Level.INFO ; // switch to Level.DEBUG for verbose otherwise Level.INFO
+ classesToDebug.forEach(x -> Configurator.setLevel(x.getName(), logLevel));
+ long startTime = System.currentTimeMillis();
+ scheduler.prepare(confWithDefaultStrategy, new StormMetricsRegistry());
+ scheduler.schedule(topologies, cluster);
+ long endTime = System.currentTimeMillis();
+ LOG.info("Cluster={} Scheduling Time: {} topologies in {} seconds",
+ testClusterName.getClusterName(), topoDetailsArray.length, (endTime - startTime) / 1000.0);
- for (TopologyDetails td : topoDetailsArray) {
- TestUtilsForResourceAwareScheduler.assertTopologiesFullyScheduled(cluster, td.getName());
+ for (TopologyDetails td : topoDetailsArray) {
+ TestUtilsForResourceAwareScheduler.assertTopologiesFullyScheduled(cluster, td.getName());
+ }
+
+ // Remove topology and reschedule it
+ for (int i = 0 ; i < topoDetailsArray.length ; i++) {
+ startTime = System.currentTimeMillis();
+ TopologyDetails topoDetails = topoDetailsArray[i];
+ cluster.unassign(topoDetails.getId());
+ LOG.info("Cluster={}, ({}) Removed topology {}", testClusterName.getClusterName(), i, topoDetails.getName());
+ IScheduler rescheduler = new ResourceAwareScheduler();
+ rescheduler.prepare(confWithDefaultStrategy, new StormMetricsRegistry());
+ rescheduler.schedule(topologies, cluster);
+ TestUtilsForResourceAwareScheduler.assertTopologiesFullyScheduled(cluster, topoDetails.getName());
+ endTime = System.currentTimeMillis();
+ LOG.info("Cluster={}, ({}) Scheduling Time: Removed topology {} and rescheduled in {} seconds",
+ testClusterName.getClusterName(), i, topoDetails.getName(), (endTime - startTime) / 1000.0);
+ }
+ classesToDebug.forEach(x -> Configurator.setLevel(x.getName(), Level.INFO));
+
+ LOG.info("testLargeCluster: End Processing cluster {}", testClusterName.getClusterName());
+ LOG.info("********************************************");
+ }
+ }
+
+ public static class SupervisorDistribution {
+ final String rackId;
+ final int supervisorCnt;
+ final int slotCnt;
+ final int memoryMb;
+ final int cpuPercent;
+
+ public SupervisorDistribution(int supervisorCnt, String rackId, int slotCnt, int memoryMb, int cpuPercent) {
+ this.rackId = rackId;
+ this.supervisorCnt = supervisorCnt;
+ this.slotCnt = slotCnt;
+ this.memoryMb = memoryMb;
+ this.cpuPercent = cpuPercent;
}
- // Remove topology and reschedule it
- for (int i = 0 ; i < topoDetailsArray.length ; i++) {
- startTime = System.currentTimeMillis();
- TopologyDetails topoDetails = topoDetailsArray[i];
- cluster.unassign(topoDetails.getId());
- LOG.info("({}) Removed topology {}", i, topoDetails.getName());
- IScheduler rescheduler = new ResourceAwareScheduler();
- rescheduler.prepare(confWithDefaultStrategy, new StormMetricsRegistry());
- rescheduler.schedule(topologies, cluster);
- TestUtilsForResourceAwareScheduler.assertTopologiesFullyScheduled(cluster, topoDetails.getName());
- endTime = System.currentTimeMillis();
- LOG.info("({}) Scheduling Time: Removed topology {} and rescheduled in {} seconds", i, topoDetails.getName(), (endTime - startTime) / 1000.0);
+ public static Map<String, Collection<SupervisorDistribution>> mapByRackId(Collection<SupervisorDistribution> supervisors) {
+ Map<String, Collection<SupervisorDistribution>> retVal = new HashMap<>();
+ supervisors.forEach(x -> retVal.computeIfAbsent(x.rackId, rackId -> new ArrayList<>()).add(x));
+ return retVal;
}
- classesToDebug.forEach(x -> Configurator.setLevel(x.getName(), Level.INFO));
+
+ public static Collection<SupervisorDistribution> getSupervisorDistribution(TEST_CLUSTER_NAME testClusterName) {
+ switch (testClusterName) {
+ case TEST_CLUSTER_01:
+ return getSupervisorDistribution01();
+ case TEST_CLUSTER_02:
+ return getSupervisorDistribution02();
+ case TEST_CLUSTER_03:
+ default:
+ return getSupervisorDistribution03();
+ }
+ }
+
+ private static Collection<SupervisorDistribution> getSupervisorDistribution01() {
+ int numSupersPerRack = 82;
+ int numPorts = 50;
+ int numSupersPerRackEven = numSupersPerRack / 2;
+ int numSupersPerRackOdd = numSupersPerRack - numSupersPerRackEven;
+
+ List<SupervisorDistribution> ret = new ArrayList<>();
+
+ for (int rack = 0; rack < 12; rack++) {
+ String rackId = String.format("r%03d", rack);
+ int cpu = 3600; // %percent
+ int mem = 178_000; // MB
+ int adjustedCpu = cpu - 100;
+ ret.add(new SupervisorDistribution(numSupersPerRackEven, rackId, numPorts, mem, cpu));
+ ret.add(new SupervisorDistribution(numSupersPerRackOdd, rackId, numPorts, mem, adjustedCpu));
+ }
+ for (int rack = 12; rack < 14; rack++) {
+ String rackId = String.format("r%03d", rack);
+ int cpu = 2400; // %percent
+ int mem = 118_100; // MB
+ int adjustedCpu = cpu - 100;
+ ret.add(new SupervisorDistribution(numSupersPerRackEven, rackId, numPorts, mem, cpu));
+ ret.add(new SupervisorDistribution(numSupersPerRackOdd, rackId, numPorts, mem, adjustedCpu));
+ }
+ for (int rack = 14; rack < 16; rack++) {
+ String rackId = String.format("r%03d", rack);
+ int cpu = 1200; // %percent
+ int mem = 42_480; // MB
+ int adjustedCpu = cpu - 100;
+ ret.add(new SupervisorDistribution(numSupersPerRackEven, rackId, numPorts, mem, cpu));
+ ret.add(new SupervisorDistribution(numSupersPerRackOdd, rackId, numPorts, mem, adjustedCpu));
+ }
+ return ret;
+ }
+
+ public static Collection<SupervisorDistribution> getSupervisorDistribution02() {
+ return Arrays.asList(
+ // Cnt, Rack, Slot, Mem, CPU
+ new SupervisorDistribution(78, "r001", 12, 42461, 1100),
+ new SupervisorDistribution(146, "r002", 36, 181362, 3500),
+ new SupervisorDistribution(18, "r003", 36, 181362, 3500),
+ new SupervisorDistribution(120, "r004", 36, 181362, 3500),
+ new SupervisorDistribution(24, "r005", 36, 181362, 3500),
+ new SupervisorDistribution(16, "r005", 48, 177748, 4700),
+ new SupervisorDistribution(12, "r006", 18, 88305, 1800),
+ new SupervisorDistribution(368, "r006", 36, 181205, 3500),
+ new SupervisorDistribution(62, "r007", 48, 177748, 4700),
+ new SupervisorDistribution(50, "r008", 36, 181348, 3500),
+ new SupervisorDistribution(64, "r008", 48, 177748, 4700),
+ new SupervisorDistribution(74, "r009", 48, 177748, 4700),
+ new SupervisorDistribution(74, "r010", 48, 177748, 4700),
+ new SupervisorDistribution(10, "r011", 48, 177748, 4700),
+ new SupervisorDistribution(78, "r012", 24, 120688, 2300),
+ new SupervisorDistribution(150, "r013", 48, 177748, 4700),
+ new SupervisorDistribution(76, "r014", 36, 181362, 3500),
+ new SupervisorDistribution(38, "r015", 48, 174431, 4700),
+ new SupervisorDistribution(78, "r016", 36, 181375, 3500),
+ new SupervisorDistribution(72, "r017", 36, 181362, 3500),
+ new SupervisorDistribution(80, "r018", 36, 181362, 3500),
+ new SupervisorDistribution(76, "r019", 36, 181362, 3500),
+ new SupervisorDistribution(78, "r020", 24, 120696, 2300),
+ new SupervisorDistribution(80, "r021", 24, 120696, 2300)
+ );
+ }
+
+ public static Collection<SupervisorDistribution> getSupervisorDistribution03() {
+ return Arrays.asList(
+ // Cnt, Rack, Slot, Mem, CPU
+ new SupervisorDistribution(40, "r001", 12, 58829, 1100),
+ new SupervisorDistribution(40, "r002", 12, 58829, 1100)
+ );
+ }
+
+ public static String clusterCapacity(Collection<SupervisorDistribution> supervisorDistributions) {
+ long cpuPercent = 0;
+ long memoryMb = 0;
+ int supervisorCnt = 0;
+ Set<String> racks = new HashSet<>();
+
+ for (SupervisorDistribution x: supervisorDistributions) {
+ memoryMb += ((long) x.supervisorCnt * x.memoryMb);
+ cpuPercent += ((long) x.supervisorCnt * x.cpuPercent);
+ supervisorCnt += x.supervisorCnt;
+ racks.add(x.rackId);
+ }
+ return String.format("Cluster summary: Racks=%d, Supervisors=%d, memoryMb=%d, cpuPercent=%d",
+ racks.size(), supervisorCnt, memoryMb, cpuPercent);
+ }
}
public static class INimbusTest implements INimbus {
diff --git a/storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestTopologyAnonymizerUtils.java b/storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestTopologyAnonymizerUtils.java
index ee1b337..0c2a171 100644
--- a/storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestTopologyAnonymizerUtils.java
+++ b/storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestTopologyAnonymizerUtils.java
@@ -66,8 +66,8 @@
public class TestTopologyAnonymizerUtils {
private static final Logger LOG = LoggerFactory.getLogger(TestTopologyAnonymizerUtils.class);
- private static final String DEFAULT_ORIGINAL_RESOURCES_PATH = "clusterconf/iridiumblue";
- private static final String DEFAULT_ANONYMIZED_RESOURCES_OUTDIR = "src/test/resources/clusterconf/largeCluster01";
+ private static final String DEFAULT_ORIGINAL_RESOURCES_PATH = "clusterconf/ebonyred";
+ private static final String DEFAULT_ANONYMIZED_RESOURCES_OUTDIR = "src/test/resources/clusterconf/largeCluster03";
public static final String COMPRESSED_SERIALIZED_TOPOLOGY_FILENAME_ENDING = "stormcode.ser";
public static final String COMPRESSED_SERIALIZED_CONFIG_FILENAME_ENDING = "stormconf.ser";
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00000-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00000-stormcode.ser
new file mode 100644
index 0000000..75a1493
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00000-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00000-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00000-stormconf.ser
new file mode 100644
index 0000000..dd2778a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00000-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00001-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00001-stormcode.ser
new file mode 100644
index 0000000..45982ef
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00001-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00001-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00001-stormconf.ser
new file mode 100644
index 0000000..d3fedb9
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00001-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00002-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00002-stormcode.ser
new file mode 100644
index 0000000..060da68
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00002-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00002-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00002-stormconf.ser
new file mode 100644
index 0000000..f120a21
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00002-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00003-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00003-stormcode.ser
new file mode 100644
index 0000000..1ef7f48
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00003-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00003-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00003-stormconf.ser
new file mode 100644
index 0000000..b5cd7f2
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00003-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00004-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00004-stormcode.ser
new file mode 100644
index 0000000..bc8b0f2
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00004-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00004-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00004-stormconf.ser
new file mode 100644
index 0000000..2c92372
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00004-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00005-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00005-stormcode.ser
new file mode 100644
index 0000000..f86accf
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00005-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00005-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00005-stormconf.ser
new file mode 100644
index 0000000..b64bb43
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00005-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00006-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00006-stormcode.ser
new file mode 100644
index 0000000..232e0f5
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00006-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00006-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00006-stormconf.ser
new file mode 100644
index 0000000..79387dc
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00006-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00007-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00007-stormcode.ser
new file mode 100644
index 0000000..7ebe1e7
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00007-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00007-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00007-stormconf.ser
new file mode 100644
index 0000000..5d11e3b
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00007-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00008-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00008-stormcode.ser
new file mode 100644
index 0000000..a0253bc
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00008-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00008-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00008-stormconf.ser
new file mode 100644
index 0000000..35a1ef8
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00008-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00009-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00009-stormcode.ser
new file mode 100644
index 0000000..8e97443
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00009-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00009-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00009-stormconf.ser
new file mode 100644
index 0000000..2120f8f
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00009-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00010-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00010-stormcode.ser
new file mode 100644
index 0000000..33003a3
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00010-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00010-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00010-stormconf.ser
new file mode 100644
index 0000000..9081c7a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00010-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00011-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00011-stormcode.ser
new file mode 100644
index 0000000..3804f0b
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00011-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00011-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00011-stormconf.ser
new file mode 100644
index 0000000..6a6f9b9
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00011-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00012-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00012-stormcode.ser
new file mode 100644
index 0000000..b0d113c
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00012-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00012-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00012-stormconf.ser
new file mode 100644
index 0000000..af1511a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00012-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00013-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00013-stormcode.ser
new file mode 100644
index 0000000..f38a3f7
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00013-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00013-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00013-stormconf.ser
new file mode 100644
index 0000000..a2bb9fb
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00013-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00014-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00014-stormcode.ser
new file mode 100644
index 0000000..75b4615
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00014-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00014-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00014-stormconf.ser
new file mode 100644
index 0000000..e32d031
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00014-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00015-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00015-stormcode.ser
new file mode 100644
index 0000000..3245bcd
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00015-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00015-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00015-stormconf.ser
new file mode 100644
index 0000000..ef69999
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00015-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00016-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00016-stormcode.ser
new file mode 100644
index 0000000..1891976
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00016-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00016-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00016-stormconf.ser
new file mode 100644
index 0000000..fa71b60
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00016-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00017-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00017-stormcode.ser
new file mode 100644
index 0000000..4b91160
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00017-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00017-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00017-stormconf.ser
new file mode 100644
index 0000000..c43bb4a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00017-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00018-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00018-stormcode.ser
new file mode 100644
index 0000000..e792431
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00018-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00018-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00018-stormconf.ser
new file mode 100644
index 0000000..4181338
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00018-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00019-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00019-stormcode.ser
new file mode 100644
index 0000000..e2c9c42
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00019-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00019-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00019-stormconf.ser
new file mode 100644
index 0000000..b552d63
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00019-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00020-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00020-stormcode.ser
new file mode 100644
index 0000000..71fb8ed
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00020-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00020-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00020-stormconf.ser
new file mode 100644
index 0000000..1b536b1
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00020-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00021-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00021-stormcode.ser
new file mode 100644
index 0000000..f29b5c3
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00021-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00021-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00021-stormconf.ser
new file mode 100644
index 0000000..be7bff6
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00021-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00022-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00022-stormcode.ser
new file mode 100644
index 0000000..ed12a19
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00022-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00022-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00022-stormconf.ser
new file mode 100644
index 0000000..260c2da
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00022-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00023-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00023-stormcode.ser
new file mode 100644
index 0000000..2a36bd2
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00023-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00023-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00023-stormconf.ser
new file mode 100644
index 0000000..0d11dfe
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00023-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00024-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00024-stormcode.ser
new file mode 100644
index 0000000..31189a6
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00024-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00024-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00024-stormconf.ser
new file mode 100644
index 0000000..afbe114
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00024-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00025-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00025-stormcode.ser
new file mode 100644
index 0000000..a7d652e
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00025-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00025-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00025-stormconf.ser
new file mode 100644
index 0000000..c5647d7
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00025-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00026-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00026-stormcode.ser
new file mode 100644
index 0000000..9d6e557
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00026-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00026-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00026-stormconf.ser
new file mode 100644
index 0000000..9fd7ca7
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00026-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00027-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00027-stormcode.ser
new file mode 100644
index 0000000..067c195
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00027-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00027-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00027-stormconf.ser
new file mode 100644
index 0000000..6bb9ee2
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00027-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00028-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00028-stormcode.ser
new file mode 100644
index 0000000..f59c96b
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00028-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00028-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00028-stormconf.ser
new file mode 100644
index 0000000..66d265e
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00028-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00029-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00029-stormcode.ser
new file mode 100644
index 0000000..aaa0fb8
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00029-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00029-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00029-stormconf.ser
new file mode 100644
index 0000000..e05fcd7
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00029-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00030-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00030-stormcode.ser
new file mode 100644
index 0000000..e5ba59e
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00030-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00030-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00030-stormconf.ser
new file mode 100644
index 0000000..9351ea2
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00030-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00031-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00031-stormcode.ser
new file mode 100644
index 0000000..1fe74ba
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00031-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00031-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00031-stormconf.ser
new file mode 100644
index 0000000..a279460
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00031-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00032-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00032-stormcode.ser
new file mode 100644
index 0000000..f44a374
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00032-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00032-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00032-stormconf.ser
new file mode 100644
index 0000000..6985c0e
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00032-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00033-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00033-stormcode.ser
new file mode 100644
index 0000000..42e682a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00033-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00033-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00033-stormconf.ser
new file mode 100644
index 0000000..b843b74
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00033-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00034-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00034-stormcode.ser
new file mode 100644
index 0000000..beb4493
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00034-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00034-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00034-stormconf.ser
new file mode 100644
index 0000000..c6389f7
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00034-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00035-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00035-stormcode.ser
new file mode 100644
index 0000000..84f538c
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00035-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00035-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00035-stormconf.ser
new file mode 100644
index 0000000..3716ff1
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00035-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00036-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00036-stormcode.ser
new file mode 100644
index 0000000..371a38d
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00036-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00036-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00036-stormconf.ser
new file mode 100644
index 0000000..f2572f7
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00036-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00037-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00037-stormcode.ser
new file mode 100644
index 0000000..102a8df
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00037-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00037-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00037-stormconf.ser
new file mode 100644
index 0000000..5df6dd3
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00037-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00038-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00038-stormcode.ser
new file mode 100644
index 0000000..0b9cbdf
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00038-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00038-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00038-stormconf.ser
new file mode 100644
index 0000000..75229d3
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00038-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00039-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00039-stormcode.ser
new file mode 100644
index 0000000..3513e7a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00039-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00039-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00039-stormconf.ser
new file mode 100644
index 0000000..84bbad0
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00039-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00040-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00040-stormcode.ser
new file mode 100644
index 0000000..cc70a7d
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00040-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00040-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00040-stormconf.ser
new file mode 100644
index 0000000..e8db4f5
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00040-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00041-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00041-stormcode.ser
new file mode 100644
index 0000000..705c254
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00041-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00041-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00041-stormconf.ser
new file mode 100644
index 0000000..fcb3413
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00041-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00042-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00042-stormcode.ser
new file mode 100644
index 0000000..3caf128
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00042-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00042-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00042-stormconf.ser
new file mode 100644
index 0000000..498295d
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00042-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00043-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00043-stormcode.ser
new file mode 100644
index 0000000..bff2033
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00043-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00043-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00043-stormconf.ser
new file mode 100644
index 0000000..3315e1d
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00043-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00044-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00044-stormcode.ser
new file mode 100644
index 0000000..4b9b39c
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00044-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00044-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00044-stormconf.ser
new file mode 100644
index 0000000..a1c54dc
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00044-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00045-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00045-stormcode.ser
new file mode 100644
index 0000000..e5daf0d
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00045-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00045-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00045-stormconf.ser
new file mode 100644
index 0000000..8e740b6
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster02/TopologyName00045-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00000-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00000-stormcode.ser
new file mode 100644
index 0000000..0194ef6
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00000-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00000-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00000-stormconf.ser
new file mode 100644
index 0000000..936c9a1
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00000-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00001-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00001-stormcode.ser
new file mode 100644
index 0000000..9a3d956
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00001-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00001-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00001-stormconf.ser
new file mode 100644
index 0000000..097f32a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00001-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00002-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00002-stormcode.ser
new file mode 100644
index 0000000..e9f909a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00002-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00002-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00002-stormconf.ser
new file mode 100644
index 0000000..ef15fac
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00002-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00003-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00003-stormcode.ser
new file mode 100644
index 0000000..cef22eb
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00003-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00003-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00003-stormconf.ser
new file mode 100644
index 0000000..d424a92
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00003-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00004-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00004-stormcode.ser
new file mode 100644
index 0000000..ee3cf0b
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00004-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00004-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00004-stormconf.ser
new file mode 100644
index 0000000..5bd9a00
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00004-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00005-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00005-stormcode.ser
new file mode 100644
index 0000000..e8aff98
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00005-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00005-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00005-stormconf.ser
new file mode 100644
index 0000000..44660f7
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00005-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00006-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00006-stormcode.ser
new file mode 100644
index 0000000..633486d
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00006-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00006-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00006-stormconf.ser
new file mode 100644
index 0000000..0e02e98
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00006-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00007-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00007-stormcode.ser
new file mode 100644
index 0000000..aea399f
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00007-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00007-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00007-stormconf.ser
new file mode 100644
index 0000000..2e2051a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00007-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00008-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00008-stormcode.ser
new file mode 100644
index 0000000..8a4610f
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00008-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00008-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00008-stormconf.ser
new file mode 100644
index 0000000..cbb7618
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00008-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00009-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00009-stormcode.ser
new file mode 100644
index 0000000..de8d144
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00009-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00009-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00009-stormconf.ser
new file mode 100644
index 0000000..30c867b
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00009-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00010-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00010-stormcode.ser
new file mode 100644
index 0000000..5e85b5a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00010-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00010-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00010-stormconf.ser
new file mode 100644
index 0000000..6f10e77
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00010-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00011-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00011-stormcode.ser
new file mode 100644
index 0000000..9904770
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00011-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00011-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00011-stormconf.ser
new file mode 100644
index 0000000..38cc5c6
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00011-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00012-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00012-stormcode.ser
new file mode 100644
index 0000000..4dad53e
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00012-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00012-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00012-stormconf.ser
new file mode 100644
index 0000000..d17bc26
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00012-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00013-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00013-stormcode.ser
new file mode 100644
index 0000000..6c03d4f
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00013-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00013-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00013-stormconf.ser
new file mode 100644
index 0000000..0963eed
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00013-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00014-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00014-stormcode.ser
new file mode 100644
index 0000000..04cd355
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00014-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00014-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00014-stormconf.ser
new file mode 100644
index 0000000..7a5e5f3
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00014-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00015-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00015-stormcode.ser
new file mode 100644
index 0000000..68e98ef
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00015-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00015-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00015-stormconf.ser
new file mode 100644
index 0000000..01c9828
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00015-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00016-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00016-stormcode.ser
new file mode 100644
index 0000000..f9fd98e
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00016-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00016-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00016-stormconf.ser
new file mode 100644
index 0000000..31b2059
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00016-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00017-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00017-stormcode.ser
new file mode 100644
index 0000000..948d27e
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00017-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00017-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00017-stormconf.ser
new file mode 100644
index 0000000..1e33fda
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00017-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00018-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00018-stormcode.ser
new file mode 100644
index 0000000..d2f390f
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00018-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00018-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00018-stormconf.ser
new file mode 100644
index 0000000..f119078
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00018-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00019-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00019-stormcode.ser
new file mode 100644
index 0000000..ab51ebc
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00019-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00019-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00019-stormconf.ser
new file mode 100644
index 0000000..642b24b
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00019-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00020-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00020-stormcode.ser
new file mode 100644
index 0000000..e12a7f0
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00020-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00020-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00020-stormconf.ser
new file mode 100644
index 0000000..00f952a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00020-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00021-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00021-stormcode.ser
new file mode 100644
index 0000000..b6b1ff0
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00021-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00021-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00021-stormconf.ser
new file mode 100644
index 0000000..2629926
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00021-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00022-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00022-stormcode.ser
new file mode 100644
index 0000000..ad4e092
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00022-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00022-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00022-stormconf.ser
new file mode 100644
index 0000000..d645756
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00022-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00023-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00023-stormcode.ser
new file mode 100644
index 0000000..b7fa8bb
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00023-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00023-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00023-stormconf.ser
new file mode 100644
index 0000000..c1e17df
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00023-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00024-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00024-stormcode.ser
new file mode 100644
index 0000000..eb6a52a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00024-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00024-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00024-stormconf.ser
new file mode 100644
index 0000000..5cff6fd
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00024-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00025-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00025-stormcode.ser
new file mode 100644
index 0000000..a0dcf3b
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00025-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00025-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00025-stormconf.ser
new file mode 100644
index 0000000..e5f550a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00025-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00026-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00026-stormcode.ser
new file mode 100644
index 0000000..3bbf4be
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00026-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00026-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00026-stormconf.ser
new file mode 100644
index 0000000..1192726
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00026-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00027-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00027-stormcode.ser
new file mode 100644
index 0000000..ca3f442
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00027-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00027-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00027-stormconf.ser
new file mode 100644
index 0000000..15861e0
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00027-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00028-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00028-stormcode.ser
new file mode 100644
index 0000000..4952088
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00028-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00028-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00028-stormconf.ser
new file mode 100644
index 0000000..c4c6f38
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00028-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00029-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00029-stormcode.ser
new file mode 100644
index 0000000..982f061
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00029-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00029-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00029-stormconf.ser
new file mode 100644
index 0000000..096f43f
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00029-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00030-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00030-stormcode.ser
new file mode 100644
index 0000000..68dd282
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00030-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00030-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00030-stormconf.ser
new file mode 100644
index 0000000..4d930af
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00030-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00031-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00031-stormcode.ser
new file mode 100644
index 0000000..1d0f109
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00031-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00031-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00031-stormconf.ser
new file mode 100644
index 0000000..b7cc3b3
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00031-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00032-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00032-stormcode.ser
new file mode 100644
index 0000000..54832c2
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00032-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00032-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00032-stormconf.ser
new file mode 100644
index 0000000..6b5ce9f
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00032-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00033-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00033-stormcode.ser
new file mode 100644
index 0000000..8421059
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00033-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00033-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00033-stormconf.ser
new file mode 100644
index 0000000..afb8d54
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00033-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00034-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00034-stormcode.ser
new file mode 100644
index 0000000..29af304
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00034-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00034-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00034-stormconf.ser
new file mode 100644
index 0000000..531759b
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00034-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00035-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00035-stormcode.ser
new file mode 100644
index 0000000..a983602
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00035-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00035-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00035-stormconf.ser
new file mode 100644
index 0000000..3d48f83
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00035-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00036-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00036-stormcode.ser
new file mode 100644
index 0000000..5577a13
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00036-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00036-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00036-stormconf.ser
new file mode 100644
index 0000000..d50fcc5
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00036-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00037-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00037-stormcode.ser
new file mode 100644
index 0000000..a6285e0
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00037-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00037-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00037-stormconf.ser
new file mode 100644
index 0000000..0371b98
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00037-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00038-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00038-stormcode.ser
new file mode 100644
index 0000000..dee70cb
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00038-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00038-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00038-stormconf.ser
new file mode 100644
index 0000000..2ec93cb
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00038-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00039-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00039-stormcode.ser
new file mode 100644
index 0000000..8a49632
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00039-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00039-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00039-stormconf.ser
new file mode 100644
index 0000000..e490836
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00039-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00040-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00040-stormcode.ser
new file mode 100644
index 0000000..7ccf986
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00040-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00040-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00040-stormconf.ser
new file mode 100644
index 0000000..fe98cc5
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00040-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00041-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00041-stormcode.ser
new file mode 100644
index 0000000..39c2400
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00041-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00041-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00041-stormconf.ser
new file mode 100644
index 0000000..9a52c71
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00041-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00042-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00042-stormcode.ser
new file mode 100644
index 0000000..159f26e
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00042-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00042-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00042-stormconf.ser
new file mode 100644
index 0000000..d3c837d
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00042-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00043-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00043-stormcode.ser
new file mode 100644
index 0000000..47fab99
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00043-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00043-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00043-stormconf.ser
new file mode 100644
index 0000000..659d85c
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00043-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00044-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00044-stormcode.ser
new file mode 100644
index 0000000..e72b9f3
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00044-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00044-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00044-stormconf.ser
new file mode 100644
index 0000000..c3a8094
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00044-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00045-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00045-stormcode.ser
new file mode 100644
index 0000000..cf4a448
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00045-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00045-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00045-stormconf.ser
new file mode 100644
index 0000000..937a11e
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00045-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00046-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00046-stormcode.ser
new file mode 100644
index 0000000..6740cab
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00046-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00046-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00046-stormconf.ser
new file mode 100644
index 0000000..92bcc84
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00046-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00047-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00047-stormcode.ser
new file mode 100644
index 0000000..7974445
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00047-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00047-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00047-stormconf.ser
new file mode 100644
index 0000000..9f82add
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00047-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00048-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00048-stormcode.ser
new file mode 100644
index 0000000..7959fd3
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00048-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00048-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00048-stormconf.ser
new file mode 100644
index 0000000..68c0927
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00048-stormconf.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00049-stormcode.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00049-stormcode.ser
new file mode 100644
index 0000000..73b8b7a
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00049-stormcode.ser
Binary files differ
diff --git a/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00049-stormconf.ser b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00049-stormconf.ser
new file mode 100644
index 0000000..cdd2379
--- /dev/null
+++ b/storm-server/src/test/resources/clusterconf/largeCluster03/TopologyName00049-stormconf.ser
Binary files differ