草庐IT

spark-ec

全部标签

spark入门案例以及sbt安装与打包(Linux环境)

创作初衷:由于在这上面翻过太多的烂文章(博主自己都没搞懂就“写作抄袭”),才写下此文(已从重装系统做过3次测试,没有问题才下笔),文章属于保姆级别。~~~~~~~~~~~~~~~~~~~~~~~~~创作不易,转载请说明~~~~~~~~~~~~~~~~~~~~~~~~~~~~~本文相关的版本信息(没部署Hadoop,本文环境基于Linux的,且文件和程序全是root用户组)操作系统:Centos7.4sbt打包插件:1.7.1   官链:sbt-Theinteractivebuildtoolspark版本:3.3.0     官链:Indexof/dist/sparkJDK版本:1.8     

spark入门案例以及sbt安装与打包(Linux环境)

创作初衷:由于在这上面翻过太多的烂文章(博主自己都没搞懂就“写作抄袭”),才写下此文(已从重装系统做过3次测试,没有问题才下笔),文章属于保姆级别。~~~~~~~~~~~~~~~~~~~~~~~~~创作不易,转载请说明~~~~~~~~~~~~~~~~~~~~~~~~~~~~~本文相关的版本信息(没部署Hadoop,本文环境基于Linux的,且文件和程序全是root用户组)操作系统:Centos7.4sbt打包插件:1.7.1   官链:sbt-Theinteractivebuildtoolspark版本:3.3.0     官链:Indexof/dist/sparkJDK版本:1.8     

JAVA代码实现Spark任务的提交

Spark的任务提交可以通过在Spark客户端上调用shell脚本将spark任务提交到yarn上执行。$./bin/spark-submit--classorg.apache.spark.examples.SparkPi\--masteryarn\--deploy-modecluster\--driver-memory4g\--executor-memory2g\--executor-cores1\--queuethequeue\examples/jars/spark-examples*.jar\10在某些场景下,无法直接去调用shell脚本或者需要监控任务的执行结果情况。这样的话,尝试通过

华为云和阿里云ECS服务器之间的区别

据IDC发布的云服务市场报告显示,阿里云市场占有率超过45%,腾讯云达到10%。一旦云服务器ecs宕机,受影响的企业将会不计其数。去年一年阿里宕机事故频繁发生,导致部分企业对阿里云ECS信心持续走低,从而转向了新兴的华为云,华为云服务器ecs和阿里云ecs有什么区别呢?华为云服务器ECS的优势:稳定可靠:故障自动迁移,数据多副本,支持云服务器和云硬盘的备份与恢复。安全保障:100%网络隔离,安全组规划保护,Anti-DDos流量清洗、Web应用防火墙、漏洞扫描等多种安全服务提供多维度防护软硬结合:基于华为多年专业硬件技术,结合自研虚拟化优化技术,更加高性能体验。云服务器ecs规格丰富:包括公共

Spark参数配置和调优,Spark-SQL、Config

一、Hive-SQL/Spark-SQL参数配置和调优#设置计算引擎sethive.execution.engine=spark;#设置spark提交模式setspark.master=yarn-cluster;#设置作业提交队列setspark.yarn.queue=${queue_name};#设置队列的名字setmapreduce.job.queuename=root.users.hdfs;#设置作业名称setspark.app.name=${job_name};#该参数用于设置Spark作业总共要用多少个Executor进程来执行setspark.executor.instances=

amazon-ec2 - Redis 故障转移,哨兵不工作

我正在尝试为故障转移支持设置redis-sentinel配置。这是我的配置,machine1:IP:10.0.0.16379withredis-sentinelport26379machine2:IP:10.0.0.26379withredis-sentinelport26379machine3:IP:10.0.0.36379withredis-sentinelport26379Redis哨兵配置机器1:sentinelmonitormymaster10.0.0.163792sentineldown-after-millisecondsmymaster60000sentinelfail

amazon-ec2 - Redis 故障转移,哨兵不工作

我正在尝试为故障转移支持设置redis-sentinel配置。这是我的配置,machine1:IP:10.0.0.16379withredis-sentinelport26379machine2:IP:10.0.0.26379withredis-sentinelport26379machine3:IP:10.0.0.36379withredis-sentinelport26379Redis哨兵配置机器1:sentinelmonitormymaster10.0.0.163792sentineldown-after-millisecondsmymaster60000sentinelfail

unity ECS简介

什么是UnityECSUnityECS是Unity引擎中的一种高性能游戏开发架构,它采用了基于数据的设计思路,与传统的面向对象编程不同。它的目标是提高游戏的性能和可伸缩性。UnityECS通过实体(Entity)、组件(Component)和系统(System)这三个概念来描述游戏对象。实体是游戏对象的标识符,组件是游戏对象的属性,系统是对实体和组件的操作。UnityECS与传统的面向对象编程不同,主要体现在以下方面:面向数据:ECS是一种基于数据的编程模型,它着重于描述游戏对象的属性和行为,而不是游戏对象本身。这使得ECS能够更加高效地处理大量的游戏对象。任务并行:ECS使用任务并行技术,使

unity ECS简介

什么是UnityECSUnityECS是Unity引擎中的一种高性能游戏开发架构,它采用了基于数据的设计思路,与传统的面向对象编程不同。它的目标是提高游戏的性能和可伸缩性。UnityECS通过实体(Entity)、组件(Component)和系统(System)这三个概念来描述游戏对象。实体是游戏对象的标识符,组件是游戏对象的属性,系统是对实体和组件的操作。UnityECS与传统的面向对象编程不同,主要体现在以下方面:面向数据:ECS是一种基于数据的编程模型,它着重于描述游戏对象的属性和行为,而不是游戏对象本身。这使得ECS能够更加高效地处理大量的游戏对象。任务并行:ECS使用任务并行技术,使

Spark 超大数据量下OOM的解决

背景大表2T,小表30G+,两表join到一新表分区。要求:尽可能的少用executorcore和memory,并减少时间占用前提executorcore和memory占用已经够高(--num-executors200--executor-cores4--executor-memory30G),不能再添加过多了。executor内存集群统一配置的上限是:yarn.scheduler.maximum-allocation-mb=30G,所以针对spark常见的优化——“把小变量广播出去”变的不太可行。广播的内容会存在每一个executor内,那内存都被广播占满了。已经做过的优化:“尽量避免频繁n