草庐IT

apache-spark-2.3

全部标签

大数据学习之Spark性能优化

文章目录Spark三种任务提交模式宽依赖和窄依赖StageSparkJob的三种提交模式Shuffle机制分析未优化的HashBasedShuffle优化后的HashBasedShuffleSort-BasedShuffleSpark之checkpointcheckpoint概述checkpoint与持久化的区别checkPoint的使用checkpoint源码分析Spark程序性能优化性能优化分析内存都去哪了性能优化方案高性能序列化类库持久化或者checkpointJVM垃圾回收调优提高并行度数据本地化Spark性能优化之算子优化mapvsmapPartitionsforeachvsfore

android - 无法解析 com.android.tools.build :gradle:2. 2.3

我正在为工作开发一个移动应用程序项目,但是当我尝试运行该应用程序时,它经常会出现以下错误:Error:Aproblemoccurredconfiguringrootproject'projectName'.Couldnotresolvealldependenciesforconfiguration':classpath'.Couldnotresolvecom.android.tools.build:gradle:2.2.3.Requiredby::projectName:unspecifiedNocachedversionofcom.android.tools.build:gradle

大数据可视化BI分析工具Apache Superset实现公网远程访问

大数据可视化BI分析工具ApacheSuperset实现公网远程访问文章目录大数据可视化BI分析工具ApacheSuperset实现公网远程访问前言1.使用Docker部署ApacheSuperset1.1第一步安装docker、dockercompose1.2克隆superset代码到本地并使用dockercompose启动2.安装cpolar内网穿透,实现公网访问3.设置固定连接公网地址前言Superset是一款由中国知名科技公司开源的“现代化的企业级BI(商业智能)Web应用程序”,其通过创建和分享dashboard,为数据分析提供了轻量级的数据查询和可视化方案。Superset在数据处

Spark-Core

1、Spark简介2、Spark-Core核心算子3、Spark-Core4、SparkSQL文章目录一、RDD编程1、RDD序列化1.2Kryo序列化框架2、RDD依赖关系2.1查看血缘关系2.2查看依赖关系2.3窄依赖2.4宽依赖2.5Stage任务划分3、RDD持久化3.1Cache缓存3.2CheckPoint检查点3.3缓存和检查点区别3.4检查点存储到HDFS集群4、键值对RDD数据分区二、累加器三、广播变量一、RDD编程1、RDD序列化初始化工作是在Driver端进行的,而实际运行程序是在Executor端进行的,这就涉及到了跨进程通信,是需要序列化的。classUserexte

Apache Doris 入门教程03:使用Docker或Kubernetes部署Doris

构建DockerImage该文档主要介绍了如何通过Dockerfile来制作ApacheDoris的运行镜像,以便于在容器化编排工具或者快速测试过程中可迅速拉取一个ApacheDorisImage来完成集群的创建。软硬件要求​概述​Docker镜像在制作前要提前准备好制作机器,该机器的平台架构决定了制作以后的DockerImage适用的平台架构,如X86_64机器,需要下载X86_64的Doris二进制程序,制作以后的Image仅可在X86_64平台上运行。ARM平台(M1视同为ARM)同理。硬件要求​最低配置:2C4G推荐配置:4C16G软件要求​DockerVersion:20.10及以后

通过 MSE 实现基于Apache APISIX的全链路灰度

什么是全链路灰度?微服务体系架构中,服务之间的依赖关系错综复杂,有时某个功能发版依赖多个服务同时升级上线。我们希望可以对这些服务的新版本同时进行小流量灰度验证,这就是微服务架构中特有的全链路灰度场景,通过构建从网关到整个后端服务的环境隔离来对多个不同版本的服务进行灰度验证。在发布过程中,我们只需部署服务的灰度版本,流量在调用链路上流转时,由流经的网关、各个中间件以及各个微服务来识别灰度流量,并动态转发至对应服务的灰度版本。如下图:上图可以很好展示这种方案的效果,我们用不同的颜色来表示不同版本的灰度流量,可以看出无论是微服务网关还是微服务本身都需要识别流量,根据治理规则做出动态决策。当服务版本发

用户案例 | 蜀海供应链基于 Apache DolphinScheduler 的数据表血缘探索与跨大版本升级经验

导读蜀海供应链是集销售、研发、采购、生产、品保、仓储、运输、信息、金融为一体的餐饮供应链服务企业。2021年初,蜀海信息技术中心大数据技术研发团队开始测试用DolphinScheduler作为数据中台和各业务产品项目的任务调度系统工具。本文主要分享了蜀海供应链在海豚早期旧版本实践过程中的探索创新和在跨大版本升级部署过程中的经验,希望对大家有所启发和帮助。作者简介杜全,蜀海供应链大数据工程师,参与蜀海大数据平台和数据中台建设。业务背景介绍我们公司的主要业务如下图所示:领导驾驶舱:提供给高层领导查看的数据准实时分析,T+1经营分析、产品毛利类、市场价格等报表财务:各类日报、月报、年度报表;对账、毛

使用Apache Commons CSV工具类生成与解析CSV文件总结

文章目录前言ApacheCommonsCSV工具类CSV文件配置生成CSV文件解析CSV文件总结前言上文介绍了如何使用Hutool生成和解析CSV文件以及CSV文件的特点,CSV文件优缺点如下;优点包括:格式简单:CSV文件采用纯文本格式存储数据,格式简单易懂。可读性强:CSV文件中的数据可以被任何文本编辑器打开和编辑,可读性强。可以被广泛支持:CSV文件是一种常见的电子表格文件格式,在大多数操作系统和软件中都可以被支持。缺点包括:不支持复杂的数据类型:CSV文件只支持基本数据类型,对于复杂的数据类型如日期时间等需要进行额外的处理。缺乏标准:由于CSV文件没有明确的标准,因此在处理CSV文件时

android - 您如何以编程方式结束 2.3+ 上的通话?

在Android2.2之前,我知道我可以使用反射并通过getITelephony终止调用。但是,从2.3开始,这不再有效,因为即使您向您的应用授予MODIFY_PHONE_STATE权限,它现在也只是系统应用权限:https://stackoverflow.com/a/5095956/821423也就是说,这仍然是可能的,因为googleplay市场上的无数应用程序在ICS上都做得很好,例如,这个:https://play.google.com/store/apps/details?id=com.androminigsm.fscifree&hl=en那么问题来了,他们是怎么做到的?我知

字节跳动 Spark Shuffle 大规模云原生化演进实践

在字节跳动内部,Spark计算引擎被广泛应用于大规模数据处理,机器学习等场景,天任务数超过150W。线上集群磁盘类型多样,包括SSD、HDD及混合等。每天会产生超过100PB以上的Shuffle数据,同时单个任务的Shuffle数据量可能达到数百TB。巨量的Shuffle数据和复杂的计算资源环境也给Spark运行过程中的Shuffle性能带来了很多挑战。本文将从背景介绍、稳定性资源场景和混部资源场景分享字节跳动在SparkShuffle云原生化方面的大规模演进实践。一、背景介绍Spark 是字节跳动内使用广泛的计算引擎,已广泛应用于各种大规模数据处理、机器学习和大数据场景。目前中国区域内每天的