《CDP企业数据云平台从入门到实践》——Hive 迁移到 CDP(3)

简介: 《CDP企业数据云平台从入门到实践》——Hive 迁移到 CDP(3)

《CDP企业数据云平台从入门到实践》——Hive 迁移到 CDP(2) https://developer.aliyun.com/article/1227683?groupCode=ClouderaCDP


二、 使用 Replication Manager 迁移 Hive 数据


2. 使用 RM 迁移 Hive 演示

image.png

image.png

示的环境版本如上图所示。

image.png

CDH群中有Hive中三test对应ORC

Parquet式,示需要将三testCDH5迁移CDP,并进行一

image.png

,进行复制,迁移CDH5的数据。群中行,需要点击--加同行,才能继续

image.png

行的Cloudera Manager果启TLS对应口为71837180使用认的账户和行管理码。完成后会接,接认证之可在复制时在不同集群中进行数据迁

image.png

行的单包括接性、编辑和

-复制-创建计-Hive复制。

image.png

填写以上规信息

HDFS存储Hive数据和数据的可项,是创建表的根目。比如HDFS的目/mypathuser/hive/warehouse/bdr.db/tab1

那么复制/mypath/user/hive/warehouse/bdr.db/tab1

image.png


填写以上资源信息中,复制策略为小集合中的文件复制任务mapper完后再理下一个指根据文件大小实一分

image.png

image.png

image.png

image.png

令详信息具体信息

image.png

从上图信息中可以到,Hive数据复制分为6

第一步:Hive Metastore

第二步:数据文件。

第三步:Hive数据复制,HDFS数据复制,、文件列举文件、将行中,并在目端触HDFS的复制务。

步:Hive Metastore入。

步:通过引发Impala shellInvalidate

步:在目端重Snapshots使其变为可

image.png

历史记行结。图中示了费时间为2分,复制了3期文件3个,失败文件。

复制文件是已经存在。

image.png

此时目已经变为/data/user/hive/warehouse,下面有3,意味着复制成

image.png

default库下也已经存在三。此处发生了几个变化:

第一,的性变为“EXTERNAL”部表

第二,变为/data/user/hive/warehouse

第三,增加external.table.purge性,做数据理的时文件一起删

通过Replication Manager迁移Hive有以下几个

需要企业的许可证。

数据迁移HiveCDP变为表同purge性。

增量数据动创建快,需要在Hive动快。通过比较快的方式对应增量来同增量数据,以减少数据


《CDP企业数据云平台从入门到实践》——Hive 迁移到 CDP(4) https://developer.aliyun.com/article/1227680?groupCode=ClouderaCDP


目录
相关文章
|
4月前
|
监控 安全 数据可视化
java基于微服务的智慧工地管理云平台SaaS源码 数据大屏端 APP移动端
围绕施工现场人、机、料、法、环、各个环节,“智慧工地”将传统建筑施工与大数据物联网无缝结合集成多个智慧应用子系统,施工数据云端整合分析,提供专业、先进、安全的智慧工地解决方案。
112 1
|
22天前
|
SQL 物联网 数据处理
"颠覆传统,Hive SQL与Flink激情碰撞!解锁流批一体数据处理新纪元,让数据决策力瞬间爆表,你准备好了吗?"
【8月更文挑战第9天】数据时代,实时性和准确性至关重要。传统上,批处理与流处理各司其职,但Apache Flink打破了这一界限,尤其Flink与Hive SQL的结合,开创了流批一体的数据处理新时代。这不仅简化了数据处理流程,还极大提升了效率和灵活性。例如,通过Flink SQL,可以轻松实现流数据与批数据的融合分析,无需在两者间切换。这种融合不仅降低了技术门槛,还为企业提供了更强大的数据支持,无论是在金融、电商还是物联网领域,都将发挥巨大作用。
37 6
|
2天前
|
SQL 关系型数据库 HIVE
实时计算 Flink版产品使用问题之如何将PostgreSQL数据实时入库Hive并实现断点续传
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
2天前
|
SQL 分布式计算 数据处理
实时计算 Flink版产品使用问题之怎么将数据从Hive表中读取并写入到另一个Hive表中
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
12天前
|
SQL 存储 分布式计算
|
13天前
|
SQL 存储 监控
Hive 插入大量数据
【8月更文挑战第15天】
|
2月前
|
SQL 关系型数据库 MySQL
实时计算 Flink版操作报错合集之从mysql读数据写到hive报错,是什么原因
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
2月前
|
SQL DataWorks 监控
DataWorks产品使用合集之同步数据到Hive时,如何使用业务字段作为分区键
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
|
3月前
|
SQL 分布式计算 HIVE
实时计算 Flink版产品使用问题之同步到Hudi的数据是否可以被Hive或Spark直接读取
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
3月前
|
SQL 关系型数据库 MySQL
基于Hive的天气情况大数据分析系统(通过hive进行大数据分析将分析的数据通过sqoop导入到mysql,通过Django基于mysql的数据做可视化)
基于Hive的天气情况大数据分析系统(通过hive进行大数据分析将分析的数据通过sqoop导入到mysql,通过Django基于mysql的数据做可视化)
下一篇
云函数