Article: Communication optimisation for intermediate data of MapReduce computing model Journal: International Journal of Computational Science and Engineering (IJCSE) 2020 Vol.21 No.2 pp.226 - 233 Abstract: MapReduce is a typical computing model for processing and analysis of big data. MapReduce computing job produces a large amount of intermediate data after map phase. Massive intermediate data results in a large amount of intermediate data communication across rack switches in the Shuffle process of MapReduce computing model, this degrades the performance of heterogeneous cluster computing. In order to optimise the intermediate data communication performance of map-intensive jobs, the characteristics of pre-running scheduling information of MapReduce computing jobs are extracted, and job classification is realised by machine learning. The jobs of active intermediate data communication are mapped into a rack to keep the communication locality of intermediate data. The jobs with inactive communication are deployed to the nodes sorted by computing performance. The experimental results show that the proposed communication optimisation scheme has a good effect on Shuffle-intensive jobs, and can reach 4%–5%. In the case of larger amount of input data, the communication optimisation scheme is robust and can adapt to heterogeneous cluster. In the case of multi-user application scene, the intermediate data communication can be reduced by 4.1%. Inderscience Publishers - linking academia, business and industry through research

Title: Communication optimisation for intermediate data of MapReduce computing model

Authors: Yunpeng Cao; Haifeng Wang

Addresses: College of Information Science and Engineering, Linyi University, Middle of Shuangling Road, Linyi, Shandong, 276000, China; Shandong Provincial Key Laboratory of Network-Based Intelligent Computing, Linda Institute, Middle of Shuangling Road, Linyi, Shandong, 276000, China ' College of Information Science and Engineering, Linyi University, Middle of Shuangling Road, Linyi, Shandong, 276000, China; Shandong Provincial Key Laboratory of Network-Based Intelligent Computing, Linda Institute, Middle of Shuangling Road, Linyi, Shandong, 276000, China

Abstract: MapReduce is a typical computing model for processing and analysis of big data. MapReduce computing job produces a large amount of intermediate data after map phase. Massive intermediate data results in a large amount of intermediate data communication across rack switches in the Shuffle process of MapReduce computing model, this degrades the performance of heterogeneous cluster computing. In order to optimise the intermediate data communication performance of map-intensive jobs, the characteristics of pre-running scheduling information of MapReduce computing jobs are extracted, and job classification is realised by machine learning. The jobs of active intermediate data communication are mapped into a rack to keep the communication locality of intermediate data. The jobs with inactive communication are deployed to the nodes sorted by computing performance. The experimental results show that the proposed communication optimisation scheme has a good effect on Shuffle-intensive jobs, and can reach 4%–5%. In the case of larger amount of input data, the communication optimisation scheme is robust and can adapt to heterogeneous cluster. In the case of multi-user application scene, the intermediate data communication can be reduced by 4.1%.

Keywords: MapReduce computing model; big data processing; communication optimisation; intermediate data; machine learning.

DOI: 10.1504/IJCSE.2020.105729

International Journal of Computational Science and Engineering, 2020 Vol.21 No.2, pp.226 - 233

Received: 07 Oct 2017
Accepted: 03 May 2018
Published online: 11 Mar 2020 *

Full-text access for editors Full-text access for subscribers Purchase this article Comment on this article

Title: Communication optimisation for intermediate data of MapReduce computing model

Keep up-to-date