出口码-1073741515在编写文件时，Spark Scala代码失败
在尝试使用Spark Scala在Intellij中运行简单程序时，我会在低于错误 错误： Caused by: ExitCodeException exitCode=-1073741515: 代码： file.saveAs…
错误 - 蜂巢中分区表的滴列
如何在Hive中丢下一列分歧式桌子？ 我有一个带有4列的外部表，例如： column_a column_b column_c dt_test-分区 i必须删除column_c，所以，我正在尝试…
通过Oozie奔跑时找不到SQOOP命令
当我在CLI中运行SQOOP脚本时，它运行良好，没有任何问题。但是，当使用Oozie运行它时，它会失败，因为找不到SQOOP命令。似乎SQOOP未安装在其他数据节…
使用hadoop map-reduce计算值列表的中位数
我是Hadoop Mrjob的新手。我有一个文本文件，其中包含每行数据“ id groupID值”。我正在尝试使用Hadoop Map-reduce计算文本文件中所有值的中位数。但…
erreur：httpconnectionpool（host =＆＃x27; dnode2＆＃x27;，port = 9864）：用url： /webhdfs超过了最大检索
我正在尝试在与Docker一起部署的Python应用程序中的HDFS服务器上读取文件，在DEV期间，我没有任何问题，但是在prod中，有一个错误： erreur：httpconn…
hadoop mapreduce带有字典
我正在尝试将另一个功能添加到Hadoop Apache https://hadoop.apache.org/docs/stable/hadoop/hadoop-mapreduce-client/hadoop-mapreduce-client-core-…
无法创建数据库，因为它已经存在，但是它不是T
我想使用命令创建Hive数据库： create database sbx_products_diff 但是它失败了以下错误： jdbc：hive2：// myhost＆gt;创建数据库SBX_PRODUCTS_DIFF…
如何使用不像在配置单元中的显示表？
我正在尝试将所有表格中的所有表获取不像特定关键字的数据库。 我能够使用类似功能，但无法在 show tables like '*student*'; 上面的显示表中使用不像…
为什么在HBase中不可能进行聚合？
我想知道为什么 HBase 本身不支持诸如 SUM / AVG 之类的聚合操作。我了解到有几种解决方法可以实现相同的目的，但是虽然有这些解决方法，但为什么 HBa…
FileNotFoundError: [Errno 2] 将文件放入 hdfs 时没有这样的文件或目录
我在 python 中使用 subprocess.popen 将文件放入HDFS中。它可以使用Windows cmd 上的Python准确地运行。但是，当我使用vscode运行代码时，我会得到“…
Hive CBO。 Hive SQL查询错误的错误结果，其中有多个条件在WHERE子句中
我正在 Hive 中运行一个 SQL 查询，在启用和禁用 CBO 的情况下它会给出不同的结果。启用 CBO 时（set hive.cbo.enable=true;），结果是错误的。 先决…
执行多个MAPRED作业，这些作业是由延迟执行的
我想知道是否可以在之前的作业给定延迟后执行/或提交要在 hadoop 集群中执行的 mapred 作业。为了解释清楚，作业是按顺序提交的，并且作业是在前面的m…
如何使用Scala从HDFS目录中删除所有文件
对于我目前正在使用 Scala 和 Spark 进行的项目，我必须编写一个代码来检查我正在处理的 hdfs 目录是否为空，如果不是，我必须从该目录中删除所有文件…
HDFS文件系统，使用Scala API获取最新文件夹
我们的应用程序从多个 HDFS 数据文件夹中读取数据，文件夹每周/每天/每月更新一次，因此根据更新周期，我们需要找到最新的路径，然后读取数据。 我们…
S3afilesystem -S3访问密钥和秘密密钥
我正在尝试读/编写S3存储桶并在Java中开发代码。在运行代码时，我会收到访问密钥和秘密密钥的授权错误。 我已经定义了FS如下： Configuration conf = …
