生产环境实战spark (6)分布式集群 5台设备 Scala安装

生产环境实战spark (6)分布式集群 5台设备 Scala安装

生产环境实战spark (6)分布式集群 Scala安装

1,scala官网下载scala安装到本地。

这里使用spark 2.1.x版本,而spark 2.1 版本需要scala2.1.1版本以上的兼容版本,因此下载安装 scala-2.11.8

下载地址:http://www.scala-lang.org/download/all.html

Spark runs on Java 7+, Python 2.6+/3.4+ and R 3.1+. For the Scala API, Spark 2.1.0 uses Scala 2.11. You will need to use a compatible Scala version (2.11.x).

2,从本地使用winscp工具将scala 2.11.8上传到master节点。   上传后检查    Last login: Wed Apr 19 09:27:17 2017 from 132.150.75.19
[root@master ~]# cd /usr/local
[root@master local]# ls
bin  etc  games  include  jdk1.8.0_121  lib  lib64  libexec  rhzf_setup_scripts  rhzf_spark_setupTools  sbin  share  src
[root@master local]# cd  rhzf_spark_setupTools
[root@master rhzf_spark_setupTools]# ls
jdk-8u121-linux-x64.tar.gz  scala-2.11.8.zip
[root@master rhzf_spark_setupTools]#

3,解压scala进行安装。   [root@master rhzf_spark_setupTools]# unzip scala-2.11.8.zip
Archive:  scala-2.11.8.zip
  creating: scala-2.11.8/
  creating: scala-2.11.8/man/
  creating: scala-2.11.8/man/man1/
 inflating: scala-2.11.8/man/man1/scala.1
 inflating: scala-2.11.8/man/man1/scalap.1
 inflating: scala-2.11.8/man/man1/fsc.1
 inflating: scala-2.11.8/man/man1/scaladoc.1
 inflating: scala-2.11.8/man/man1/scalac.1
  creating: scala-2.11.8/bin/
 inflating: scala-2.11.8/bin/scalac
 inflating: scala-2.11.8/bin/fsc
 inflating: scala-2.11.8/bin/fsc.bat
 inflating: scala-2.11.8/bin/scala
 inflating: scala-2.11.8/bin/scalap
 inflating: scala-2.11.8/bin/scaladoc.bat
 inflating: scala-2.11.8/bin/scaladoc
 inflating: scala-2.11.8/bin/scalac.bat
 inflating: scala-2.11.8/bin/scala.bat
 inflating: scala-2.11.8/bin/scalap.bat
  creating: scala-2.11.8/doc/
  creating: scala-2.11.8/doc/tools/
 inflating: scala-2.11.8/doc/tools/index.html
 inflating: scala-2.11.8/doc/tools/scalap.html
  creating: scala-2.11.8/doc/tools/images/
 inflating: scala-2.11.8/doc/tools/images/scala_logo.png
extracting: scala-2.11.8/doc/tools/images/external.gif
 inflating: scala-2.11.8/doc/tools/scala.html
  creating: scala-2.11.8/doc/tools/css/
 inflating: scala-2.11.8/doc/tools/css/style.css
 inflating: scala-2.11.8/doc/tools/fsc.html
 inflating: scala-2.11.8/doc/tools/scalac.html
 inflating: scala-2.11.8/doc/tools/scaladoc.html
 inflating: scala-2.11.8/doc/README
 inflating: scala-2.11.8/doc/LICENSE.md
  creating: scala-2.11.8/doc/licenses/
 inflating: scala-2.11.8/doc/licenses/mit_jquery-ui.txt
 inflating: scala-2.11.8/doc/licenses/mit_sizzle.txt
 inflating: scala-2.11.8/doc/licenses/apache_jansi.txt
 inflating: scala-2.11.8/doc/licenses/bsd_asm.txt
 inflating: scala-2.11.8/doc/licenses/mit_tools.tooltip.txt
 inflating: scala-2.11.8/doc/licenses/mit_jquery-layout.txt
 inflating: scala-2.11.8/doc/licenses/mit_jquery.txt
 inflating: scala-2.11.8/doc/licenses/bsd_jline.txt
 inflating: scala-2.11.8/doc/License.rtf
  creating: scala-2.11.8/lib/
 inflating: scala-2.11.8/lib/scala-parser-combinators_2.11-1.0.4.jar
 inflating: scala-2.11.8/lib/scala-reflect.jar
 inflating: scala-2.11.8/lib/scalap-2.11.8.jar
 inflating: scala-2.11.8/lib/scala-continuations-library_2.11-1.0.2.jar
 inflating: scala-2.11.8/lib/config-1.2.1.jar
 inflating: scala-2.11.8/lib/akka-actor_2.11-2.3.10.jar
 inflating: scala-2.11.8/lib/scala-continuations-plugin_2.11.8-1.0.2.jar
 inflating: scala-2.11.8/lib/scala-actors-migration_2.11-1.1.0.jar
 inflating: scala-2.11.8/lib/scala-xml_2.11-1.0.4.jar
 inflating: scala-2.11.8/lib/jline-2.12.1.jar
 inflating: scala-2.11.8/lib/scala-library.jar
 inflating: scala-2.11.8/lib/scala-compiler.jar
 inflating: scala-2.11.8/lib/scala-swing_2.11-1.0.2.jar
 inflating: scala-2.11.8/lib/scala-actors-2.11.0.jar
[root@master rhzf_spark_setupTools]# ls
jdk-8u121-linux-x64.tar.gz  scala-2.11.8  scala-2.11.8.zip  
   复制到/usr/local目录:
[root@master rhzf_spark_setupTools]# mv scala-2.11.8 /usr/local
[root@master rhzf_spark_setupTools]# cd /usr/local
[root@master local]# ls
bin  etc  games  include  jdk1.8.0_121  lib  lib64  libexec  rhzf_setup_scripts  rhzf_spark_setupTools  sbin  scala-2.11.8  share  src
 
 

4,配置linux环境变量。vi  /etc/profile
 
 

export JAVA_HOME=/usr/local/jdk1.8.0_121
export SCALA_HOME=/usr/local/scala-2.11.8

export PATH=.:$PATH:$JAVA_HOME/bin:$SCALA_HOME/bin
 

在命令行中输入source  /etc/profile,使刚才修改的SCALA_HOME及PATH配置文件生效 。[root@master local]# source  /etc/profile
 

5,单机master节点上scala安装完成,版本检查。

[root@master local]# scala -version
Scala code runner version 2.11.8 -- Copyright 2002-2016, LAMP/EPFL
[root@master local]#


6,编写脚本,在woker的节点也安装scala。  
   [root@master rhzf_setup_scripts]# ls
rhzf_hosts_scp.sh  rhzf_ssh.sh
[root@master rhzf_setup_scripts]# vi rhzf_scala.sh


#!/bin/sh
for i in  238 239 240 241
do
scp   -rq /usr/local/scala-2.11.8  root@10.*.*.$i:/usr/local/scala-2.11.8
scp   -rq /etc/profile  [email protected].$i:/etc/profile
ssh   root@10.*.*.$i source /etc/profile    done


[root@master rhzf_setup_scripts]# ls
rhzf_hosts_scp.sh  rhzf_scala.sh  rhzf_ssh.sh
[root@master rhzf_setup_scripts]# chmod u+x rhzf_scala.sh
[root@master rhzf_setup_scripts]# ./rhzf_scala.sh
[root@master rhzf_setup_scripts]#


7, 在woker的节点检查scala安装完成。   [root@worker01 ~]# scala -version
Scala code runner version 2.11.8 -- Copyright 2002-2016, LAMP/EPFL
[root@worker01 ~]#
 
   Last login: Tue Apr 18 12:52:16 2017 from master
[root@worker02 ~]# scala -version
Scala code runner version 2.11.8 -- Copyright 2002-2016, LAMP/EPFL
[root@worker02 ~]#
 


Last login: Tue Apr 18 12:52:01 2017 from worker02
[root@worker03 ~]# scala -version
Scala code runner version 2.11.8 -- Copyright 2002-2016, LAMP/EPFL
[root@worker03 ~]#


Last login: Tue Apr 18 12:08:22 2017 from 132.150.75.19
[root@worker04 ~]# scala -version
Scala code runner version 2.11.8 -- Copyright 2002-2016, LAMP/EPFL
[root@worker04 ~]#

Read more

科普文:微服务之微服务框架Spring Cloud Alibaba组件简介

科普文:微服务之微服务框架Spring Cloud Alibaba组件简介

第一代spring cloud 的组件 第一代实现: Spring Cloud Netflix 第二代Spring Cloud Alibaba主流时代 spring cloud 现在已经是一种标准了,各公司可以基于它的编程模型编写自己的组件 ,比如Netflix、阿里巴巴都有自己的一套通过spring cloud 编程模型开发的分布式服务组件 。Spring Cloud Alibaba 主要包含 Sentinel、Nacos、RocketMQ、Dubbo、Seata 等组件。 Spring Cloud 二代组件 第二代实现: Spring Cloud Alibaba. Spring Cloud Alibaba 是阿里巴巴结合自身的微服务实践而推出的微服务开发的一站式解决方案,是 Spring Cloud 第二代实现的主要组成部分。Spring Cloud Alibaba 吸收了 Spring Cloud Netflix

By Ne0inhk
科普文:微服务之分布式链路追踪SkyWalking单点服务搭建

科普文:微服务之分布式链路追踪SkyWalking单点服务搭建

1. 概述 1.1 概念 SkyWalking 是什么? FROM 分布式系统的应用程序性能监视工具,专为微服务、云原生架构和基于容器(Docker、K8s、Mesos)架构而设计。 提供分布式追踪、服务网格遥测分析、度量聚合和可视化一体化解决方案。 1.2 功能列表 SkyWalking 有哪些功能? FROM * 多种监控手段。可以通过语言探针和 service mesh 获得监控是数据。 * 多个语言自动探针。包括 Java,.NET Core 和 Node.JS。 * 轻量高效。无需大数据平台,和大量的服务器资源。 * 模块化。UI、存储、集群管理都有多种机制可选。 * 支持告警。 * 优秀的可视化解决方案。 1.3 整体架构 SkyWalking

By Ne0inhk
科普文:linux系列之操作系统内存管理详解

科普文:linux系列之操作系统内存管理详解

1. 内存管理方法 内存管理主要包括虚地址、地址变换、内存分配和回收、内存扩充、内存共享和保护等功能。 2. 连续分配存储管理方式 连续分配是指为一个用户程序分配连续的内存空间。连续分配有单一连续存储管理和分区式储管理两种方式。 2.1 单一连续存储管理 在这种管理方式中,内存被分为两个区域:系统区和用户区。应用程序装入到用户区,可使用用户区全部空间。其特点是,最简单,适用于单用户、单任务的操作系统。CP/M和 DOS 2.0以下就是采用此种方式。这种方式的最大优点就是易于管理。但也存在着一些问题和不足之处,例如对要求内存空间少的程序,造成内存浪费;程序全部装入,使得很少使用的程序部分也占用—定数量的内存。 2.2 分区式存储管理 为了支持多道程序系统和分时系统,支持多个程序并发执行,引入了分区式存储管理。分区式存储管理是把内存分为一些大小相等或不等的分区,操作系统占用其中一个分区,其余的分区由应用程序使用,每个应用程序占用一个或几个分区。分区式存储管理虽然可以支持并发,但难以进行内存分区的共享。 分区式存储管理引人了两个新的问题:内碎片和外碎片。 内碎片是占用

By Ne0inhk
科普文:微服务之Spring Cloud Alibaba消息队列组件RocketMQ工作原理

科普文:微服务之Spring Cloud Alibaba消息队列组件RocketMQ工作原理

概叙 本文探讨 RocketMQ 的事务消息原理,并从源码角度进行分析,以及事务消息适合什么场景,使用事务消息需要注意哪些事项。 同时详细介绍RocketMQ 事务消息的基本流程,并通过源码分析揭示了其内部实现原理,尽管事务消息增加了系统的复杂性,但在需要保证消息一致性的场景中,它仍然是一种非常有效的解决方案,比如资金转账、订单处理、分布式事务、库存管理等场景。 什么是事务消息 事务消息是为了保证分布式系统中消息的一致性而引入的一种消息类型。事务消息允许消息发送方在发送消息后,进行本地事务操作,并根据本地事务的执行结果来决定消息的最终状态(提交或回滚)。 RocketMQ 事务消息的优缺点 优点 * 保证消息一致性:通过事务消息,RocketMQ 能够保证分布式系统中消息的一致性,避免数据不一致问题。 * 高性能:RocketMQ 的事务消息性能较高,能够满足高并发场景的需求。 * 易用性:RocketMQ 提供了简单易用的 API,使得开发者能够方便地使用事务消息。 缺点 * 复杂性:事务消息的引入增加了系统的复杂性,开发者需要处理事

By Ne0inhk