草庐IT

size_bytes

全部标签

hadoop - Hadoop 中的 VIRTUAL_MEMORY_BYTES 任务计数器是什么意思?

权威指南中的以下摘录提供了如下所示的高级详细信息,但是这个任务计数器中的虚拟内存到底指的是什么?如何解读?它与PHYSICAL_MEMORY_BYTES有什么关系?以下是其中一份工作的示例摘录。物理空间约为214GB。虚拟空间约为611GB。 最佳答案 1.这个任务计数器中的虚拟内存到底指的是什么?VirtualMemoryhereisusedtopreventOutofMemoryerrorsofatask,ifdatasizedoesn'tfitsinRAM(physicalmem).inRAM.Soaportionofmemo

java - Hadoop MapReduce : size of data processed in shuffle and reduce phase

我在包含多个AWS实例的集群上运行HadoopMapReduceJava应用程序。我想知道是否有可能在混洗阶段知道数据集的大小,即总共有多少数据被混洗。另外,是否可以知道每个reducer任务处理了多少数据? 最佳答案 您应该能够从JobTrackerWebUI中找到此信息。有一个名为“Reduceshufflebytes”的计数器详细说明了被打乱的总字节数-参见https://issues.apache.org/jira/browse/HADOOP-4845以及原始链接票证以获取更多信息。对于每个reducer计数,深入到已完成的

hadoop - 接口(interface)错误 : TSocket read 0 bytes when using hue with hbase

这是我在hueconfig中的设置[hbase]#以逗号分隔的HBaseThrift服务器列表#集群,格式为“(name|host:port)”。hbase_clusters=(集群|MasterIP:ThriftPort)#在截断之前获取的每行的行数或列数的硬限制。##truncate_limit=500但是当我连接到hue网页并切换到Hbase选项卡时,它显示日志:[08/Dec/201319:30:13+0000]中间件信息处理异常:Api错误:TSocket读取0字节:回溯(最近调用最后):文件“/home/ubuntu/workspaces/hue/hue-master/bu

java - @size(max = value) 与 @min(value) 和 @max(value) 之间的区别

我想做一些域验证。在我的对象中,我有一个整数。现在我的问题是:如果我写@Min(SEQ_MIN_VALUE)@Max(SEQ_MAX_VALUE)privateIntegersequence;和@Size(min=1,max=NAME_MAX_LENGTH)privateIntegersequence;如果是整数,哪一个适合域验证?谁能解释一下它们之间有什么区别?谢谢。 最佳答案 @Min和@Max用于验证数字字段,可以是String(表示数字)、int、short、byte等以及它们各自的原始包装器。@Size用于检查字段的长度限

java - @size(max = value) 与 @min(value) 和 @max(value) 之间的区别

我想做一些域验证。在我的对象中,我有一个整数。现在我的问题是:如果我写@Min(SEQ_MIN_VALUE)@Max(SEQ_MAX_VALUE)privateIntegersequence;和@Size(min=1,max=NAME_MAX_LENGTH)privateIntegersequence;如果是整数,哪一个适合域验证?谁能解释一下它们之间有什么区别?谢谢。 最佳答案 @Min和@Max用于验证数字字段,可以是String(表示数字)、int、short、byte等以及它们各自的原始包装器。@Size用于检查字段的长度限

java - 信息 :Error: java. lang.ClassNotFoundException : org. apache.hadoop.hbase.util.Bytes

今天早上我在我的pig脚本中使用了我的UDF,没有任何问题。但是现在,当我尝试时收到此错误消息:信息:错误:java.lang.ClassNotFoundException:org.apache.hadoop.hbase.util.Bytes我想这意味着我在我的类路径中错过了一个hbasejar!!但我什么也没改变!我该如何解决?我如何添加hbasejar的示例会很棒!! 最佳答案 我通过在我的pig脚本中注册hbase来解决它。注册路径/to/hbase/jar以我为例注册/usr/lib/hbase/hbase.jar;

hadoop - Spark : Minimize task/partition size skew with textFile's minPartitions option?

我正在通过sc.textFile("/data/*/*/*")之类的方式将数万个文件读入rdd>一个问题是这些文件中的大多数都是微小的,而其他的则巨大。这会导致任务不平衡,从而导致各种众所周知的问题。我能否通过sc.textFile("/data/*/*/*",minPartitions=n_files*5)读取数据来拆分最大的分区,其中n_files是输入文件的个数吗?如约定elsewhere在stackoverflow上,minPartitions被传递到hadooprabithole,并在org.apache.hadoop.mapred.TextInputFormat.getSp

hadoop - 检查点在 HDFS 中是如何工作的?我想弄清楚 fs.checkpoint.period 和 fs.checkpoint.size

当它说时,辅助名称节点检查点每小时(fs.checkpoint.period以秒为单位)或如果编辑日志已达到64MB(fs.checkpoint.size以字节为单位)则更早?究竟是什么意思?据我了解,编辑日志存储在本地文件磁盘中。 最佳答案 HDFS元数据可以认为由两部分组成:基本文件系统表(存储在名为fsimage的文件中)和列出对基本表所做更改的编辑日志(存储在文件中称为edits)。检查点是协调fsimage与edits以生成新版本的fsimage的过程。这样做有两个好处:更新版本的fsimage和截断的编辑日志。fs.ch

hadoop - Apache hive : LOAD DATA vs INSERT OVERWRITE OUTPUT FILE SIZE

我正在使用ApacheHive,我不明白为什么如果我使用INSERTOVERWRITE与LOAD加载数据,表的大小会加倍。问题说明如下:我创建了一个表项从item.dat加载数据(大约28MB)在Azure中发生的是文件item.dat将被移动到hive/warehouse并且当然大小保持不变现在,如果我创建另一个与item相同的表item2,然后使用以下命令将数据从item加载到item2:INSERTOVERWRITETABLEitem2SELECT*FROMitem表item2的大小是item的两倍(大约55MB)为什么会这样?有什么办法可以避免吗?附言。这只是为了说明问题。在实

java - HBase 的 Bytes.toBytes - 它的输出是有序的吗?

我正在使用org.apache.hadoop.hbase.util.Bytes.toBytes(T)。我将此函数的输出存储在HBase中的一个值中,然后我想对其使用比较操作(CompareOp.GREATER、CompareOp.LESS...).Bytes.toBytes(T)的输出是否保持这些类型的“可比性”?意思是,对于double例如:doubled1=...,d2=...;Bytes.compare(Bytes.toBytes(d1),Bytes.toBytes(d2))==Double.compare(d1,d2)这是否适用于这些类型?float/doubleint/lon