SparkSQL之thriftserver/beeline的使用
启动thriftserver
使用命令启动:./start-thriftserver.sh --master local[2] --jars /home/iie4bu/software/mysql-connector-java-5.1.35.jar
。
然后使用jps -m
查看,可以看到SparkSubmit
同样可以通过浏览器进行访问。实际上beeline访问端口则需要访问10000
启动客户端beeline
使用命令:bin/beeline -u jdbc:hive2://manager:10000 -n iie4bu
上面的图展示了正确连接的情况。
使用命令查看表:show tables;
查询语句:select * from sal s join people p on s.transactionid=p.id;
可以在浏览器中查看到作业:
可以查看详细的执行计划。
当我们在启动一个beeline
时,会出现两个session:
修改thriftserver启动时的默认端口
首先将上面的beeline和thriftserver停止。
然后启动thriftserver时,指定端口号:14000。
./start-thriftserver.sh --master local[2] --jars /home/iie4bu/software/mysql-connector-java-5.1.35.jar --hiveconf hive.server2.thrift.port=14000
然后启动beeline
客户端:
beeline -u jdbc:hive2://manager:14000 -n iie4bu
,启动成功:
thriftserver与spark-shell/spark-sql区别
spark-shell和spark-sql启动时每次都需要重新申请资源,都是一个新的spark application。
thriftserver不管启动多少个客户端(beeline/jdbc方式),永远都是一个spark application。好处一:是只要在启动时申请一次就可以了,不需要在申请资源了。好处二:当一个客户端修改一个表之后,另一个客户端可以看到,解决了数据共享的问题,多个客户端可以共享数据。
SparkSQL之thriftserver/beeline的使用相关推荐
- Spark入门(七)Spark SQL thriftserver/beeline启动方式
一.启动thrift服务 启动thriftServer,默认端口为10000,. --jars 添加worker类库 --driver-class-path 驱动类库 --master spark集群 ...
- 2021年大数据Spark(三十三):SparkSQL分布式SQL引擎
目录 分布式SQL引擎 Hive的SQL交互方式 ThriftServer JDBC/ODBC Server 开启sparksql的thriftserver 使用beeline 客户端连接 JDBC/ ...
- SparkSQL操作Hive
title: SparkSQL操作Hive date: 2020-05-12 16:12:55 tags: Spark Apache Hive 是 Hadoop 上的 SQL 引擎,Spark SQL ...
- 慕课网Spark SQL日志分析 - 4.从Hive平滑过渡到Spark SQL
4.1 SQLContext/HiveContext/SparkSesson 1.SQLContext 老版本文档:spark.apache.org/docs/1.6.1/ SQLContext示例文 ...
- 巨杉数据库linux,【巨杉数据库SequoiaDB】巨杉Tech |巨杉数据库的HTAP场景实践
01 背景 由于业务形式的发展,越来越多的需求需要对交易数据进行实时分析,例如推荐.决策.监控等,传统的处理办法是使用ETL的方式把OLTP业务产生的数据同步到OLAP的数据数据库,导致了数据需要在不 ...
- 【巨杉数据库SequoiaDB】巨杉Tech |巨杉数据库的HTAP场景实践
01 背景 由于业务形式的发展,越来越多的需求需要对交易数据进行实时分析,例如推荐.决策.监控等,传统的处理办法是使用ETL的方式把OLTP业务产生的数据同步到OLAP的数据数据库,导致了数据需要在不 ...
- Spark3 读写 S3 Parquet, Hive, Hudi
Spark 读 S3 Parquet 写入 Hudi 表 目录 Spark 读 S3 Parquet 写入 Hudi 表 参考 关于S3,S3N和S3A的区别与联系 Spark 读写 S3 Parqu ...
- 大数据项目(二)————某电信公司通话记录改造
1.项目介绍 某互联网公司面向APP应用开发者提供的,以品牌互推.流量互导.广告分账为主的一站式服务平台. 将通话记录数据由原来的oracle系统改造成使用大数据架构解决方案.主要使用hbase做通话 ...
- 日志分析 进入大数据Spark SQL的世界
以慕课网日志分析为例 进入大数据 Spark SQL 的世界 这篇blog是这个项目的总结,因为从别的地方学习过Hadoop.Spark的一些基础知识了,所以这部分略过.针对自身的不足,我抛出一些问题 ...
最新文章
- 程序员面试题精选100题(61)-数对之差的最大值
- Matlab与线性代数 -- 矩阵的重组3
- 堆栈的栈顶和栈底在哪_【c# .net】堆栈(Stack)
- python的工资为什么这么低-为什么学完Python找不到工作?原因如下!
- 【心情】今天买了YINSH!
- BZOJ2956 (模积和)
- mysql workbench 1064_MySQL Workbench:查询错误(1064):第1行“ VISIBLE”附近的语?mysql-问答-阿里云开发者社区-阿里云...
- SpringCloud 从菜鸟到大牛之一 微服务介绍
- sqlserver日志管理(转载)
- python冒泡循环示例_Python for循环示例
- 计算机操作系统笔记(六)
- 极大似然法python例子
- android怎样开启root权限管理,手机怎样开启root权限(最新安卓手机一键root教程)...
- STM32F407移植FreeModbus中遇到接收最后一个字节是0xff或0xfe的解决方法
- Fluent Meshing的workflow方法
- <i> vs <em> vs <cite>
- SX1262 与 SX1278、SX1276 有什么区别?
- 职场漂流记:过往皆为浮云
- WIN10插入耳机没声音,Realtek音频管理器打不开
- 有没有压缩视频的软件?能压缩视频的软件?压缩视频用什么软件比较好?
热门文章
- java url json字符串_JAVA中带有JSON字符串的HTTP POST请求
- java token生成和验证_SpringBoot集成JWT生成token及校验方法过程解析
- 超大数据量存储常用数据库分表分库算法总结
- 关于微信授权与登录的相关操作(纯手敲)
- java反序列化 构造函数_FastJson反序列化和构造函数之间的一点小秘密
- 笔记本html连接电视机,WinXP系统的笔记本如何连接电视?笔记本连接液晶电视方法...
- java两字符串是否相等_Java与JavaScript中判断两字符串是否相等的区别
- win10pin不可用进不去系统_解决win7系统下连接网络打印机不可用的处理方法
- html5中加亮文本,html实现高亮关键字
- linux svn 自动发布,linux svn tomcat maven 自动发布打包