[STORM-3743] Add new topologies and change TestLargeCluster for more realistic supervisor creation.
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..f1553dc 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
@@ -62,12 +62,16 @@
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_CLUSTER_01 = "largeCluster01";
+ public static final String TEST_CLUSTER_02 = "largeCluster02";
+
+ public static final String TEST_CLUSTER_NAME = TEST_CLUSTER_02;
public static final String TEST_RESOURCE_PATH = "clusterconf/" + TEST_CLUSTER_NAME;
public static final String COMPRESSED_SERIALIZED_TOPOLOGY_FILENAME_ENDING = "code.ser";
public static final String COMPRESSED_SERIALIZED_CONFIG_FILENAME_ENDING = "conf.ser";
@@ -148,7 +152,7 @@
/**
* 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.
@@ -255,6 +259,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");
@@ -312,57 +320,87 @@
}
/**
- * Create supervisors.
+ * Create supervisors for a larger cluster configuration.
*
- * @param uniformSupervisors true if all supervisors are of the same size, false otherwise.
+ * @param reducedSupervisorsPerRack number of supervisors to reduce in rack.
+ * @return created supervisors.
+ */
+ private static Map<String, SupervisorDetails> createSupervisors(int reducedSupervisorsPerRack) {
+ if (TEST_CLUSTER_NAME.equals(TEST_CLUSTER_02)) {
+ return createSupervisorsForCluster02(reducedSupervisorsPerRack);
+ } else {
+ return createSupervisorsForCluster01(reducedSupervisorsPerRack);
+ }
+ }
+
+ /**
+ * Create supervisors for a newer {@link #TEST_CLUSTER_02} cluster configuration to mimic a large cluster in use.
+ *
+ * @param reducedSupervisorsPerRack number of supervisors to reduce per rack.
+ * @return created supervisors.
+ */
+ private static Map<String, SupervisorDetails> createSupervisorsForCluster02(int reducedSupervisorsPerRack) {
+ Collection<SupervisorDistribution> supervisorDistributions = SupervisorDistribution.getSupervisorDistribution02();
+ Map<String, Collection<SupervisorDistribution>> byRackId = SupervisorDistribution.mapByRackId(supervisorDistributions);
+ LOG.info("Cluster={}, Designed capacity: {}", TEST_CLUSTER_NAME, SupervisorDistribution.clusterCapacity(supervisorDistributions));
+
+ 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() - Math.abs(reducedSupervisorsPerRack);
+ if (tmpRackSupervisorCnt > Math.abs(reducedSupervisorsPerRack)) {
+ tmpRackSupervisorCnt -= Math.abs(reducedSupervisorsPerRack);
+ }
+ 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);
+ }
+ });
+ });
+ return retList;
+ }
+
+ /**
+ * Create supervisors for a non-uniform supervisor distribution closely (but not exactly) mimics a large cluster in use.
+ *
+ * @param reducedSupervisorsPerRack is the reduction in supervisors per rack to constrain capacity (15 is tight)
* @return supervisor details indexed by id
*/
- 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> createSupervisorsForCluster01(int reducedSupervisorsPerRack) {
+ int numSupersPerRack = 82 - Math.abs(reducedSupervisorsPerRack);
+ int numPorts = 50;
- return TestUtilsForResourceAwareScheduler.genSupervisorsWithRacks(
- numRacks, numSupersPerRack, numPorts, rackStart, superInRackStart, cpu, mem, miscResources);
+ Map<String, SupervisorDetails> retList = new HashMap<>();
- } 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);
- }
+ 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);
}
- 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);
- }
- }
- 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;
}
+ 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);
+ }
+ }
+ 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;
}
/**
@@ -372,9 +410,7 @@
*/
@Test
public void testLargeCluster() throws Exception {
- boolean uniformSupervisors = false; // false means non-uniform supervisor distribution
-
- Map<String, SupervisorDetails> supervisors = createSupervisors(uniformSupervisors);
+ Map<String, SupervisorDetails> supervisors = createSupervisors(0);
TopologyDetails[] topoDetailsArray = createTopoDetailsArray(false);
Assert.assertTrue("No topologies found", topoDetailsArray.length > 0);
@@ -383,6 +419,9 @@
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<>(),
@@ -422,6 +461,74 @@
classesToDebug.forEach(x -> Configurator.setLevel(x.getName(), Level.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;
+ }
+
+ 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;
+ }
+
+ 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 String clusterCapacity(Collection<SupervisorDistribution> supervisorDistributions) {
+ long cpuPercent = 0;
+ long memoryMb = 0;
+ int supervisorCnt = 0;
+ Set<String> racks = new HashSet<>();
+
+ for (SupervisorDistribution x: supervisorDistributions) {
+ memoryMb += (x.supervisorCnt * x.memoryMb);
+ cpuPercent += (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 {
@Override
public void prepare(Map<String, Object> topoConf, String schedulerLocalDir) {
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
