# AUTO GENERATED BY TROIKA DISCOVERY TOOL # # This is a comment # (commands are case sensitive) # application=Application, processor=CPU, hd=HardDisk, link=Link, memory=Memory, # node=Node, config=Configuration, switch=Switch, scheduler=Scheduler, filesplit=FileSplit Info # Configuration must come before applications # Filesplit order must be the same with the application order # # NOTE: Please make sure that filesplit locations are consistent with application size and related filesplit configs. # ____________________________________________________________________________________________________SYNTAX_________________________________________ # [] --> represents optional args. (with default values of Hadoop v2.2) # # APPLICATION: application applicationSize(size_t) applicationOwnerID(size_t) mapIntensity(double) mapSortIntensity(double) reduceIntensity(double) reduceSortIntensity(double) mapOutputPercent(double) # reduceOutputPercent(double) finalOutputPercent(double) clientEventID(int) rmEventID(int) queueId(size_t) [recordSize(size_t) # [isThereACombiner(int) combinerIntensity(double) combinerCompressionPercent(double) [mapCpuVcores(int) reduceCpuVcores(int) [mapreduceMapMemory(size_t) mapreduceReduceMemory(size_t) # [amResourceMB(size_t) amCpuVcores(int)]]]]] # CONFIG: config mapreduceJobReduces(int) [mapreduceInputFileinputformatSplitMinsize(size_t) [mapreduceInputFileinputformatSplitMaxsize(size_t) # [dfsBlocksize(size_t) [mapreducetaskIOSortFactor(int) [mapreduceTaskIOSortMb(size_t) [mapreduceMapSortSpillPercent(double) # [mapreduceJobtrackerTaskscheduler(int) [mapreduceReduceShuffleParallelcopies(int) [mapreduceReduceShuffleMergePercent(double) # [mapreduceReduceShuffleInputBufferPercent(double) [mapreduceReduceInputBufferPercent(double) [mapreduceJobUbertaskEnable(bool) # [mapreduceJobUbertaskMaxmaps(int) [mapreduceJobUbertaskMaxreduces(int) # [nodemanagerResourceMemoryMB(size_t) nodemanagerResourceCpuCores(int) # [getMapreduceJobReduceSlowstartCompletedmaps(double) [mapred_child_java_opts(double)]]]]]]]]]]]]]]]]] # CPU: processor numberOfCores(int) capacity(size_t) [delayType(int) [unit(int) [delayratio(double)]]] # MEMORY: memory maxReadSpeed(size_t) maxWriteSpeed(size_t) minReadSpeed(size_t) minWriteSpeed(size_t)remainingCapacity(size_t) # [delayType(int) [unit(int) [delayratio(double)]]] # HARDDISK: hd maxReadSpeed(size_t) maxWriteSpeed(size_t) minReadSpeed(size_t) minWriteSpeed(size_t) [delayType(int) [unit(int) [delayratio(double)]]] # NODE: node ID(int) rackID(int) nodeType(int) connectedLinkID(int) # LINK: link ID(int) capacity(double) upEndpointID(int) lowEndpointID(int) [mttr(double) [mtbf(double) # [delayType(int) [unit(int) [delayratio(double)]]]]] # SWITCH: switch ID(int) [upEndpointID(int)] # SCHEDULER: scheduler numberOfQueues(int) capacityOfQueue1(double) capacityOfQueue2(double) ... capacityOfQueueN(double) [maxAmResourcePercent(double) [minAllocMB(size_t) maxAllocMB(size_t) # [minAllocVcores(int) maxAllocVcores(int) [resourceCalculator (bool)]]]] # FILESPLIT: filesplit isforcedMapTaskCount(int) forcedReduceTaskCount(int) numberOfFilesplits(int) nodeExpectedId1(int) nodeExpectedId2(int) ... nodeExpectedIdN(int) # ____________________________________________________________________________________________________INPUT___________________________________________ # Please replace each *value* with the corresponding value # E.g. *finalOutputPercent* might be replaced with 99 # Remove the optional arguments that you would like to use the default values # Make sure that the parameter order is preserved and no undefined *value* remains in the final input.txt # SCHEDULER scheduler 1 100 # For each TOR Switch add the event id of each end. # TOR SWITCH (RACK_i) switch *ID* *upEndpointID* # There is a single aggregation switch: add its event id. # AGGREGATION SWITCH (INTER RACK) switch *ID* # CONFIGURATION config *mapreduceJobReduces* [*mapreduceInputFileinputformatSplitMinsize* [*mapreduceReduceShuffleParallelcopies* [*dfsBlockSize* [*mapreduceTaskIoSortFactor* [*mapreduceTaskIoSortMb* [*mapreduceMapSortSpillPercent* [1 [*mapreduceReduceShuffleParallelcopies* [*mapreduceReduceShuffleMergePercent* [*mapreduceReduceShuffleInputBufferPercent* [*mapreduceReduceInputBufferPercent* [0 [*mapreduceJobUbertaskMaxmaps* [*mapreduceJobUbertaskMaxreduces* [*nodemanagerResourceMemoryMB* *nodemanagerResourceCpuCores* [*getMapreduceJobReduceSlowstartCompletedmaps* [*mapred_child_java_opts*]]]]]]]]]]]]]]]]] # FILESPLIT LOCATIONS (in terms of expected node event type) filesplit *isforcedMapTaskCount* *forcedReduceTaskCount* *numberOfFilesplits* *nodeExpectedId1* *nodeExpectedId2* *...* nodeExpectedIdN* # APPLICATION application 10737418200 0 *mapIntensity* *mapSortIntensity* *reduceIntensity* *reduceSortIntensity* *mapOutputPercent* *reduceOutputPercent* *finalOutputPercent* *clientEventID* *rmEventID* 0 # For each TOR to AGGR link add this # LINK (TOR to AGGR) link *ID* 118390264.283 *upEndpointID* *lowEndpointID* # Please update eventIDs of Node to TOR links # LINK (to TOR) link *ID* 123254603.776 *upEndpointID* *lowEndpointID* # LINK (to TOR) link *ID* 123254603.776 *upEndpointID* *lowEndpointID* # LINK (to TOR) link *ID* 123254603.776 *upEndpointID* *lowEndpointID* # LINK (to TOR) link *ID* 123254603.776 *upEndpointID* *lowEndpointID* # LINK (to TOR) link *ID* 123254603.776 *upEndpointID* *lowEndpointID* # LINK (to TOR) link *ID* 123254603.776 *upEndpointID* *lowEndpointID* # START: NODE_localhost CONFIGURATION processor 4 *capacity* # MEMORY memory *maxReadSpeed* *maxWriteSpeed* *minReadSpeed* *minWriteSpeed* 13553684480 # max read/write speed - min read/write speed hd 267356344 109216451 217356344 103216451 # NODE node *ID* *rackID* *nodeType* *connectedLinkID* # END: NODE_localhost CONFIGURATION # START: NODE_node1 CONFIGURATION processor 4 *capacity* # MEMORY memory *maxReadSpeed* *maxWriteSpeed* *minReadSpeed* *minWriteSpeed* 13554958336 # max read/write speed - min read/write speed hd 269701087 97202995 226909749 94266982 # NODE node *ID* *rackID* *nodeType* *connectedLinkID* # END: NODE_node1 CONFIGURATION # START: NODE_node2 CONFIGURATION processor 4 *capacity* # MEMORY memory *maxReadSpeed* *maxWriteSpeed* *minReadSpeed* *minWriteSpeed* 13554761728 # max read/write speed - min read/write speed hd 256397789 116388520 236397789 106388520 # NODE node *ID* *rackID* *nodeType* *connectedLinkID* # END: NODE_node2 CONFIGURATION # START: NODE_node3 CONFIGURATION processor 4 *capacity* # MEMORY memory *maxReadSpeed* *maxWriteSpeed* *minReadSpeed* *minWriteSpeed* 13554761728 # max read/write speed - min read/write speed hd 253044195 82522931 212509130 81579212 # NODE node *ID* *rackID* *nodeType* *connectedLinkID* # END: NODE_node3 CONFIGURATION # START: NODE_node4 CONFIGURATION processor 4 *capacity* # MEMORY memory *maxReadSpeed* *maxWriteSpeed* *minReadSpeed* *minWriteSpeed* 13554761728 # max read/write speed - min read/write speed hd 257555850 90149734 217495214 78549167 # NODE node *ID* *rackID* *nodeType* *connectedLinkID* # END: NODE_node4 CONFIGURATION # START: NODE_node5 CONFIGURATION processor 4 *capacity* # MEMORY memory *maxReadSpeed* *maxWriteSpeed* *minReadSpeed* *minWriteSpeed* 13554761728 # max read/write speed - min read/write speed hd 267382738 93610035 224354054 82498544 # NODE node *ID* *rackID* *nodeType* *connectedLinkID* # END: NODE_node5 CONFIGURATION