草庐IT

token_storage

全部标签

hadoop - 运行 Hadoop wordcount 示例时找不到作业 token 文件

我刚刚在一个小型集群上成功安装了Hadoop。现在我正在尝试运行wordcount示例,但出现此错误:****hdfs://localhost:54310/user/myname/test1112/04/2413:26:45INFOinput.FileInputFormat:Totalinputpathstoprocess:112/04/2413:26:45INFOmapred.JobClient:Runningjob:job_201204241257_000312/04/2413:26:46INFOmapred.JobClient:map0%reduce0%12/04/2413:26

hadoop - Hive INSERT OVERWRITE 到 Google Storage 作为 LOCAL DIRECTORY 不起作用

我使用以下Hive查询:hive>INSERTOVERWRITELOCALDIRECTORY"gs://Google/Storage/Directory/Path/Name"rowformatdelimitedfieldsterminatedby','select*from.;我收到以下错误:"Error:FailedwithexceptionWrongFS:"gs://Google/Storage/Directory/PathName",expected:file:///我做错了什么? 最佳答案 从语法中删除Local。参见下面的

hadoop - 使用 globStatus 和 Google Cloud Storage 存储桶作为输入时无法运行 Spark 作业

我正在使用Spark1.1。我有一个Spark作业,它只在存储桶下寻找特定模式的文件夹(即以...开头的文件夹),并且应该只处理那些。我通过执行以下操作实现了这一点:FileSystemfs=FileSystem.get(newConfiguration(true));FileStatus[]statusArr=fs.globStatus(newPath(inputPath));ListstatusList=Arrays.asList(statusArr);ListpathsStr=convertFileStatusToPath(statusList);JavaRDDpaths=sc.

hadoop - Hadoop 和 Google Cloud Storage Connector 的问题

我已经通过谷歌控制台中的Deployments界面部署了一个hadoop集群。(Hadoop2.x)我的任务是过滤存储在一个GoogleStorage(GS)存储桶中的数据,并将结果放入另一个存储桶中。所以,这是一个只有map的工作,带有简单的python脚本。请注意,集群和输出桶位于同一区域(EU)。利用GoogleCloudStorageConnector,我运行以下流媒体作业:hadoopjar/home/hadoop/hadoop-install/share/hadoop/tools/lib/hadoop-streaming-2.4.1.jar\-Dmapreduce.outp

hadoop - 除了 hadoop 集群中设置的时间之外,如何为长时间运行的应用程序更新委托(delegate) token

我有一个在我的Hadoop环境中运行的ApacheApex应用程序。我对应用程序没有任何问题,只是它在7天后失败了。而且,我意识到这是因为任何应用程序的集群级别设置。有什么办法,我可以每隔一段时间定期更新委托(delegate)token,以确保作业连续运行而不会失败!!我可以在网上找到任何关于如何更新hdfs委托(delegate)token的资源!!有人可以分享您的知识吗? 最佳答案 Apexdocumentation中提到了这个问题.它还详细提供了2个解决方案。Hadoop系统的非侵入式将选择“自动刷新方法”。基本上你需要将你

java - WebHDFS Java 客户端未正确处理 Kerberos token

我正在尝试运行一个长生命周期的WebHDFS客户端(实际上是在HDFS上构建前端框架)。但是我的token一天后就会过期(这里是默认的kerberos配置),起初我尝试运行一个线程来调用userLoginInformation.currentUser().checkTGTAndReloginFromKeytab();然而,即使我看到TGT重新登录21小时,但在24小时后我的WebHDFS文件系统卡在“缓存中未找到token”(这是一个错误,意味着服务器已经删除了我的token)。查看代码@https://github.com/apache/hadoop/blob/release-2.7

hadoop - 将文件从 Google Cloud Storage 加载到本地 Hadoop 集群

我正在尝试将Google云存储文件加载到本地Hadoop集群。我开发了一个解决方法(程序)来将本地EdgeNode和distcp上的文件下载到Hadoop。但这似乎是双向解决方法,并没有给人留下深刻印象。我浏览了几个网站(links1、link2),这些网站总结了使用HadoopGoogleCloudStorage连接器进行此类过程,并且需要基础架构级别的配置,这在所有情况下都是不可能的。有什么方法可以使用Python或Java以编程方式将文件直接从CloudStorage复制到Hadoop。 最佳答案 要以编程方式执行此操作,您可

hadoop - 有人知道如何修复 hadoop-functions.sh "syntax error near unexpected token ` <'"吗?

我在运行OSX10.14.2的MacPro上配置了Hadoop3.1.1,当我运行start-all.sh时出现以下错误$sudo/usr/local/Cellar/hadoop/3.1.1/sbin/start-all.shStartingnamenodeson[localhost]/usr/local/Cellar/hadoop/3.1.1/libexec/bin/../libexec/hadoop-functions.sh:line398:syntaxerrornearunexpectedtoken`启动数据节点、辅助名称节点、资源管理器和节点管理器的问题相同。我在网上找到了类似

java - SIMPLE 身份验证未启用。可用 :[TOKEN, KERBEROS] -Hbase Master 无法激活

我正在尝试设置一个具有3个节点的HBase集群。我已经尝试配置SecureHbase一周了,但我仍然遇到错误:ERROR[Thread-15]master.HMaster:Failedtobecomeactivemasterorg.apache.hadoop.ipc.RemoteException(org.apache.hadoop.security.AccessControlException):SIMPLEauthenticationisnotenabled.Available:[TOKEN,KERBEROS]我正在运行Hbase2.0.5和Hadoop3.1.2。Secureha

azure - HDInsight : Selection method not accepting Storage account

在部署HDInsight群集时,在DataSource下,无论我选择哪种选择方法(“来自所有订阅”或“访问key”),我都无法附加我的存储帐户。我在东南亚地区创建了一个新的存储帐户(它是与“存储”分开创建的)并希望使用它。这是我的做法:第一部分:选择方法:来自所有订阅-配置所需的设置(按照屏幕截图中的1、2和3)一切都很好。上面写着“正在获取访问key”。到目前为止,一切都很好。它还会选择默认容器。然后它抛出这个错误:第二部分:选择方法:访问键-我选择“访问key”,输入存储名称,它会选择默认容器......一切都很好。然后我从存储帐户粘贴访问key然后它抛出这个错误:存储帐户是Sta