草庐IT

java - 强制hadoop将 map task 的数量设置为1

我觉得我的问题让每个人都感到困惑。再说清楚一点。我正在尝试订购我的数据。说我的数据(几条记录)是这样的012341389228797我的block大小是128MB,文件大小是380Mb(3个block)我正在尝试为我的记录提供订单号。1,012342,138923,28797为了给出正确的数字,我需要将数据放入1个map中,否则如果我得到3个maptask,我的编号将不正确。所以如果我这样做,我会得到完整的数据吗?输入到我的映射器类的数据不会发生任何变化,这将是我的原始数据,不是吗?一旦我使用noofmappers设置为1-Dmapreduce.job.maps=1或conf.setI

hadoop - 如何强制hadoop处理每个 map 的更多数据

我的工作进展非常缓慢,因为我认为hadoop为数据大小创建了太多maptask。我在一些网站上读到,用更少的map处理更大的数据block是有效的——有什么办法可以强制这样做吗?谢谢 最佳答案 两种可能性:增加90gb数据的block大小,将其设置为128m或更大将使您的maptask“工作更多”使用CombineFileInputFormat并将您的block组合到您认为合适的大小。第一个解决方案需要您重写数据以更改block大小,第二个解决方案可以嵌入到您的作业中。 关于hadoop

hadoop - 将 HUE 界面语言设置/强制为英语(Hadoop/Cloudera)

由于某种原因,当我从我的机器访问它时,hue界面语言是德语。(德语语言设置,但英语浏览器和操作系统)如何强制hue始终显示英文? 最佳答案 Hue正在采用您的浏览器发送的首选语言环境。您浏览器中的德语语言环境可能设置为比英语语言环境更高的优先级。Thisarticle说明您可以在哪里更改它。 关于hadoop-将HUE界面语言设置/强制为英语(Hadoop/Cloudera),我们在StackOverflow上找到一个类似的问题: https://stacko

hadoop - 如何强制 HBase 在 HDFS 上运行?

我在native文件系统上使用HBase并创建了一些表。现在我配置了HDFS并希望HBase使用它。我启动了Namenode和Datanode,但找不到可以告诉HBase使用HDFS的设置。我认为它可能会在重启时获取HDFS,所以我这样做了(stop-hbase+start-hbase),但我仍然能够看到我之前在native文件系统上创建的表。如何让HBase使用HDFS? 最佳答案 在$HBASE_HOME/conf/hbase-site.xml中,hbase.rootdir定义了HBase所在的文件系统/目录。看:http://

hadoop - HDFS - 如何强制复制因子

复制因子过去设置为3,但现在为1。如何强制复制因子到集群?换句话说,启动一个进程来删除现在过度复制的文件block? 最佳答案 如果你允许它自动超时会更好但是如果你想强制新的复制因子快速生效,你可以使用运行平衡器脚本,$HADOOP_HOME/bin/start-balancer.sh这应该重新平衡集群中的block。或者,您可以对现有文件执行此操作,hadoopfs-setrep-R1/,这可能会在/中递归地设置文件的复制级别 关于hadoop-HDFS-如何强制复制因子,我们在Sta

performance - 如何强制 PigStorage 输出几个大文件而不是数千个小文件?

我在我的pig脚本中使用了这些行:setdefault_parallel20;requests=LOAD‘/user/me/todayslogs.gz’USINGcustomParser;intermediate_results=some_data=FOREACHintermediate_resultsGENERATEday,request_id,result;STOREsome_dataINTO'/user/me/output_data'USINGPigStorage(',');“/user/me/todayslogs.gz”包含数千个gzip文件,每个文件大小为200MB。当脚本完

hadoop - HDFS 到 HDFS 完全强制移动文件

据我所知,在从一个HDFS位置移动到另一个位置时,没有直接选项可以覆盖HDFS中的文件,复制cp可以选择强制执行。我试图找出是否有任何黑客可以做到这一点?我们能做的是hdfsdfs-cp-f/hdfs/location1/hdfs/location2而不是hdfsdfs-mv-f/hdfs/location1//hdfs/location2/实现我的目的的一种方法是先执行hdfsdfs-cp-f/hdfs/location1/hdfs/location2,然后使用hdfsdfs-删除location1文件-rm-r/hdfs/location1但出于某种原因我不想这样做。任何其他使用一

hadoop - 如何强制 Hadoop 解压缩输入而不考虑其扩展名?

我正在运行map-reduce,我的输入是gzip压缩的,但没有.gz(文件名)扩展名。通常,当它们具有.gz扩展名时,Hadoop会在将它们传递给映射器之前负责即时解压缩它们。但是,如果没有扩展名,它不会这样做。我无法重命名我的文件,所以我需要某种“强制”Hadoop解压缩它们的方法,即使它们没有.gz扩展名。我尝试将以下标志传递给Hadoop:step_args=["-jobconf","stream.recordreader.compression=gzip",“-jobconf”,“mapred.output.compress=true”,“-jobconf”,“mapred.

hadoop - 如何强制 CTAS 生成单个文件?

我正在使用HDP2.5和Hive服务。当我使用以下查询创建配置单元表时;createtableSample_tablerowformatdelimitedfieldsterminatedby'|'storedastextfileASselect*fromsample_table_uniquewherestate='AL';要么我可以创建具有特定位置的外部表。我的问题是,当我创建表/外部表时,存储的文件已被拆分,即。如下图所示,明智的文件已被拆分。/apps/hive/warehouse/sampledb/sample_table:00000_0,00001_0,00002_0,0000

我如何强制使用Firebase实时数据库使用Websocket?

我知道Firebase实时数据库WebSDK可以使用Websocket或长时间播放来与后端服务器进行交谈。有没有办法强制使用Websocket?看答案通常,您不想这样做,因为FirebaseSDK会自动检测客户端是否支持Websocket,并在可能的情况下使用它们。由于Websockets在所有浏览器和所有环境中都不能可靠地工作(例如代理偶尔不能可靠地支持WebSocket流量),因此强迫Websocket使用可能会导致您的应用在某些情况下无法可靠地工作。作为诊断工具或解决非常具体的问题,您可以通过更改数据库来迫使客户使用Websocketwss://.firebaseio.com/代替htt