[HDFS Pagination]Does HDFS Java api Support Pagination?

2018-08-12 Thread Chang.Wu
HDFS-13759 I could use FileSystem RemoteIterator listed = fs.listStatusIterator(new Path("hdfs://warehousestore/user/chang.wu/flat_level_1")); like this to get files asynchronously. But in fact what I want is a pagination support, where I could pass two parameters, the offset

Yarn NODE_LOCAL request downgraded to RACK_LOCAL didn't cancel the original NODE_LOCAL request?

2017-12-02 Thread Chang.Wu
I know, when AM making container request, if the request container is NODE_LOCAL, then AM will also send out RACK_LOCAL and OFF_SWITCH requests. On the ResourceManager side, if RM successfully assigned a NODE_LOCAL container, I saw that RM canceled RACK_LOCAL and OFF_SWITCH requests because it w

Why hasContainerForNode return false directly when there is no request of ANY locality?

2017-11-26 Thread Chang.Wu
I am studying the FairScheduler source cod of yarn 2.7.3.By the code of class FSAppAttempt: ​ public boolean hasContainerForNode(Priority prio, FSSchedulerNode node) { ​ ResourceRequest anyRequest = getResourceRequest(prio, ResourceRequest.ANY); ResourceRequest rackRequest = getResou

Yarn resourcemanager stop allocating container when cluster resource is sufficient

2017-11-12 Thread Chang.Wu
Hadoop Version: 2.7.2 My Yarn cluster have (1100TB,368vCores) totallly with 15** nodemangers** . My cluster use fair-scheduler and I have 4 queues for different kinds of jobs: 10 mb, 30 vcores 422280 mb, 132 vcores 0.5f 90 90 5

Will Backup Node download image and edits log from NameNode?

2017-09-25 Thread Chang.Wu
From the official document of Backup Node?? it Says: The Backup node does not need to download fsimage and edits files from the active NameNode in order to create a checkpoint, as would be required with a Checkpoint node or Secondary NameNode, since it already has an up-to-date state of the name

How to make JobHistoryServer support HighAvailbility?

2017-07-24 Thread Chang.Wu
I want to configure two JobHistoryServers and use nginx as a HA.My gold is that even when on of my JobHistoryServer crashed , my oozie jobs can still work without any influence. I doubt if I can do so. If not , what can I do to make JobHistoryServer support HighAvailability? Many thanks.