Parallel and Distributed Computing for Real-time Analytics

我的研究目标是创建一个运行时系统，该系统可以向外扩展到大型多核计算机集群，用于大数据分析的内存计算。许多现有的分布式系统没有利用高性能计算中开发的工具和技术来解决最终限制可伸缩性的性能问题。MPI(消息传递接口)是一个消息传递库，它是高性能计算并行编程的事实标准。我打算开发新的MPI中间件以及相关工具，作为计算分析的可伸缩运行时系统的基础。 向外扩展需要表达大量并发的能力，最终依赖于消息传递。因此，这项工作的起点将是我们的FG-MPI(细粒度MPI(消息传递接口))系统，我们已经证明该系统可以扩展到数千个和数百万个进程。FG-MPI扩展了MPICH，这是一个MPI运行时系统，用于派生MPI的大多数商业版本。这项工作将需要扩展现有的FG-MPI中间件，以及引入新的工具和技术来进行大规模编程。 这项研究涉及(A)研究MPI中间件的进一步改进以支持多核机器，(B)开发工具以支持用于指定进程组成和为MPI开发面向服务的数据结构的“演员式”编程环境，(C)遵循一百万进程方法论来开发大规模开发和部署程序的技术，(D)开发创新的基于消息的数据结构和算法，以支持基于大数据的基于知识的分析和推理。 这项研究直接针对计算机技术的两个主要趋势：多核和集群/云计算的出现。在这两种情况下-未来是平行的！核心问题是如何使用多核进行纵向扩展，或者如何使用更多计算机进行横向扩展，以提供处理和计算对当今可用的海量数据进行分析所需的性能。

The goal of my research is to create a runtime system that can scale-out to large size clusters of multicore machines for in-memory computation of analytics on big data. Many of the existing distributed systems do not take advantage of the tools and techniques developed in high performance computing for addressing the performance issues that ultimately limits scalability. MPI (Message-Passing Interface) is a message-passing library that is the de-facto standard in parallel programming for high performance computing. I intend to develop new MPI middleware along with associated tools as the basis for a scalable runtime system for computing analytics. Scaling-out requires the ability to express massive amounts of concurrency and ultimately relies on message-passing. As such, the starting point for this work will be our FG-MPI (Fine-Grain MPI (Message-Passing Interface)) system, which we have shown can scale to thousands and millions of processes. FG-MPI extends MPICH, an MPI runtime system that is used to derive most of the commercial versions of MPI. This work will require extending the existing FG-MPI middleware as well as introducing new tools and techniques for programming at large scale. The research involves (a) investigating further improvements to the MPI middleware to support multicore machines, (b) developing tools to support an "actor-like" programming environment for specifying the composition of processes and the development of service-oriented data structures for MPI, (c) following a million process methodology to develop techniques for developing and deploying programs at scale, (d) developing innovative message-based data structures and algorithms to support knowledge-based analysis and reasoning on big data. This research directly addresses the two main trends in computer technology: the appearance of multicore and cluster/cloud computing. In both cases --- the future is parallel! The central problem is how to use multicore to scale-up or how to use more machines to scale-out to provide the performance needed to process and compute analytics on the vast amount of data that is available today.