Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Migration of unmigrated content due to installation of a new plugin
Table of Contents

...

Components

Wiki Markup
Apache
Hama consists of three major components:
 Hama, based on Bulk Synchronous Parallel model\[1\], comprises three major components: 

It is very similar with Hadoop architecture, only except the portion of communication and synchronization mechanisms.

...

BSPMaster is responsible for the following:

  • maintaining Maintaining its own state.
  • Maintaining groom server status.
  • Maintaining supersteps and other counters in a cluster.
  • Maintaining job progress information jobs and tasks.
  • Scheduling Jobs and assigning tasks to groom servers
  • Distributing execution classes and configuration across groom servers.
  • Providing users with the cluster control interface (web and console based).

...

Wiki Markup
A [Groom Server|GroomServer] (shortly referred to as groom) is a process that manages life cycle of bsp tasks assigned by BSPMaster. Each groom contacts the BSPMaster, and reports task statuses by means of periodical piggybacks with BSPMaster. Each groom is designed to run with HDFS or other distributed storages. Basically, a groom server and a data node should be run on one physical node to get the best performance for data-locality. Note However,that in a massive parallel environment, the benefit of data locality is lost when large amount of virtual processes must be multiplexed onto physical processes\[12\].

Zookeeper

A Zookeeper is used to manage the efficient barrier synchronization of the BSPPeers. Later, it will also be used for the area of a fault tolerance system.

Communication and Synchronization Process

Each BSP task has a set of Outgoing Message Manager and Incoming Queue.

Outgoing Message Manager collects the message to be sent, serializes it, compresses it and puts it in a bundles. At barrier synchronization phase, each BSP task exchanges the bundles, deserializes it, decompresses it and puts it into the Incoming Queue.

System Diagram

Image Added

  1. BSPMaster starts up
  2. GroomServer starts up
  3. ZooKeeper cluster starts up
  4. GroomServer dynamically registers itself to BSPMaster
  5. GroomServer forks/ manages BSPPeer(s)
  6. BSPPeers communicate/ perform barrier synchronization through ZooKeeper cluster.

Reference

Wiki Markup
\[1\]. Valiant, Leslie G., A bridging model for parallel computation. 

Wiki Markup
\[2\]. David B. Skillicorn, Jonathan M. D. Hill, and W. F. [McColl]. Questions and Answers about BSP. Scientific Programming, 6(3):249-274, Fall 1997.

...