mapred linuxtaskcontroller目录权限问题探究-低调大师

mapred linuxtaskcontroller目录权限问题探究

2017-11-21 571

今天发现测试环境的kerberos hadoop的hive不能跑了，具体表现是select * limit这种不走mapred的job是ok的，走mapred的job就会报错，报的错比较奇怪（Unable to retrieve URL for Hadoop Task logs. Unable to find job tracker info port.）但是确认jobtracker是ok的，配置文件也是正常的，看来和jobtracker没有关系，进一步分析tasktracker的日志，发现如下错误。。

 
        2014-03-26 17:28:02,048 WARN org.apache.hadoop.mapred.TaskTracker: Exception 
        while 
        localization java.io.IOException: Job initialization failed (24) with output: File 
        /home/test/platform 
        must be owned by root, but is owned by 501 
       
        at org.apache.hadoop.mapred.LinuxTaskController.initializeJob(LinuxTaskController.java:194) 
       
        at org.apache.hadoop.mapred.TaskTracker$4.run(TaskTracker.java:1420) 
       
        at java.security.AccessController.doPrivileged(Native Method) 
       
        at javax.security.auth.Subject.doAs(Subject.java:396) 
       
        at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1407) 
       
        at org.apache.hadoop.mapred.TaskTracker.initializeJob(TaskTracker.java:1395) 
       
        at org.apache.hadoop.mapred.TaskTracker.localizeJob(TaskTracker.java:1310) 
       
        at org.apache.hadoop.mapred.TaskTracker.startNewTask(TaskTracker.java:2727) 
       
        at org.apache.hadoop.mapred.TaskTracker$TaskLauncher.run(TaskTracker.java:2691) 
       
        Caused by: org.apache.hadoop.util.Shell$ExitCodeException:
       
        at org.apache.hadoop.util.Shell.runCommand(Shell.java:261) 
       
        at org.apache.hadoop.util.Shell.run(Shell.java:188) 
       
        at org.apache.hadoop.util.Shell$ShellCommandExecutor.execute(Shell.java:381) 
       
        at org.apache.hadoop.mapred.LinuxTaskController.initializeJob(LinuxTaskController.java:187) 
       
        ... 8 
        more

其中/home/test/platform是mapred程序所在目录，通过更改/home/test/platform的属主为root解决，不过这个为什么需要是root用户呢
从调用栈信息看到，是在调用LinuxTaskController类（因为用到了kerberos，taskcontroller需要选择这个类）的initializeJob出错了。initializeJob方法是对job做初始操作，传入user,jobid,token,mapred的local dir等参数，生成一个数组，并调用ShellCommandExecutor的构造方法进行实例化，最终调用ShellCommandExecutor类的execute方法。

 
        public 
        void 
        initializeJob(String user, String jobid, Path credentials, 
       
        Path jobConf, TaskUmbilicalProtocol taskTracker, 
       
        InetSocketAddress ttAddr 
       
        ) 
        throws 
        IOException { 
       
        List<String> command = 
        new 
        ArrayList<String>( 
       
        Arrays.asList(taskControllerExe ,  
        //task-controller 
       
        user, 
       
        localStorage.getDirsString(),         
        //mapred.local.dir  
       
        Integer. toString(Commands.INITIALIZE_JOB.getValue()), 
       
        jobid, 
       
        credentials.toUri().getPath().toString(),    
        //jobToken 
       
        jobConf.toUri().getPath().toString())); 
        //job.xml 
       
        File jvm =                                  
        // use same jvm as parent 
       
        new 
        File( 
        new 
        File(System.getProperty( 
        "java.home"
        ), 
        "bin" 
        ), 
        "java" 
        ); 
       
        command.add(jvm.toString()); 
       
        command.add(
        "-classpath"
        ); 
       
        command.add(System.getProperty(
        "java.class.path" 
        )); 
       
        command.add(
        "-Dhadoop.log.dir=" 
        + TaskLog.getBaseLogDir()); 
       
        command.add(
        "-Dhadoop.root.logger=INFO,console"
        ); 
       
        command.add(JobLocalizer.
        class
        .getName());  
        // main of JobLocalizer 
       
        command.add(user); 
       
        command.add(jobid); 
       
        // add the task tracker's reporting address 
       
        command.add(ttAddr.getHostName()); 
       
        command.add(Integer.toString(ttAddr.getPort())); 
       
        String[] commandArray = command.toArray( 
        new 
        String[
        0
        ]); 
       
        ShellCommandExecutor shExec = 
        new 
        ShellCommandExecutor(commandArray); 
       
        if 
        (LOG.isDebugEnabled()) { 
       
        LOG.debug( 
        "initializeJob: " 
        + Arrays.toString(commandArray));   
        //commandArray 
       
        } 
       
        try 
        { 
       
        shExec.execute(); 
       
        if 
        (LOG.isDebugEnabled()) { 
       
        logOutput(shExec.getOutput()); 
       
        } 
       
        } 
        catch 
        (ExitCodeException e) { 
       
        int 
        exitCode = shExec.getExitCode(); 
       
        logOutput(shExec.getOutput()); 
       
        throw 
        new 
        IOException(
        "Job initialization failed (" 
        + exitCode + 
       
        ") with output: " 
        + shExec.getOutput(), e); 
       
        } 
       
        }

通过打开tasktracker的debug日志，可以获取commandArray的具体信息：

 
        2014
        -
        03
        -
        26 
        19
        :
        49
        :
        02
        ,
        489 
        DEBUG org.apache.hadoop.mapred.LinuxTaskController: initializeJob: 
       
        [/home/test/platform/hadoop-
        2.0
        .
        0
        -mr1-cdh4.
        2.0
        /bin/../sbin/Linux-amd64-
        64
        /task-controller, 
       
        hdfs, xxxxxxx, 
        0
        , job_201403261945_0002, xxxxx/jobToken, xxxx/job.xml, /usr/local/jdk1.
        6
        .0_37/jre/bin/java, 
       
        -classpath,xxxxxx.jar, -Dhadoop.log.dir=/home/test/logs/hadoop/mapred, -Dhadoop.root.logger=INFO,console, 
       
        org.apache.hadoop.mapred.JobLocalizer, hdfs, job_201403261945_0002, localhost.localdomain, 
        57536
        ]

其中比较重要的是taskControllerExe 这个参数，它代表了taskcontroller的可执行文件(本例中是/home/test/platform/hadoop-2.0.0-mr1-cdh4.2.0/bin/../sbin/Linux-amd64-64/task-controller)
而execute方法其实最终调用了task-controller.
task-controller的源码在 src/c++/task-controller目录下。
在configuration.c中定义了对目录属主进行检查：

 
        static 
        int 
        is_only_root_writable(
        const 
        char 
        *file) { 
       
        .......
       
        if 
        (file_stat.st_uid != 0) { 
       
        fprintf
        (LOGFILE, 
        "File %s must be owned by root, but is owned by %d\n"
        , 
       
        file, file_stat.st_uid); 
       
        return 
        0; 
       
        } 
       
        .......

如果检查的文件属主不是root，则报错。
调用这个方法的代码：

 
        int 
        check_configuration_permissions(
        const 
        char
        * file_name) { 
       
        // copy the input so that we can modify it with dirname 
       
        char
        * dir = strdup(file_name); 
       
        char
        * buffer = dir; 
       
        do 
        { 
       
        if 
        (!is_only_root_writable(dir)) { 
       
        free
        (buffer); 
       
        return 
        -1; 
       
        } 
       
        dir = dirname(dir); 
       
        } 
        while 
        (
        strcmp
        (dir, 
        "/"
        ) != 0); 
       
        free
        (buffer); 
       
        return 
        0; 
       
        }

即check_configuration_permissions会调用is_only_root_writable方法对二进制文件所在目录向上递归做父目录属主的检查，如果有一个目录属主不为root，就会出错。这就要求整个chain上的目录属主都需要是root.
这其实是出于taskcontroller的安全考虑，在代码中定义了不少关于这个可执行文件的权限的验证，只要有一个地方设置不正确，tasktracker都不会正常运行。
cloudra官方文档对这个文件的权限描述如下：

 
        The Task-controller program is used to allow the TaskTracker to run tasks under the Unix account of the user 
        who 
        submitted the job 
        in 
        the first place. 
       
        It is a setuid binary that must have a very specific 
        set 
        of permissions and ownership 
        in 
        order to 
        function 
        correctly. In particular, it must: 
       
        1)Be owned by root 
       
        2)Be owned by a group that contains only the user running the MapReduce daemons 
       
        3)Be setuid 
       
        4)Be group readable and executable

问题还没有结束，taskcontroller有一个配置文件为taskcontroller.cfg.关于这个配置文件位置的获取比较让人纠结。
搜到有些文档说是通过设置HADOOP_SECURITY_CONF_DIR即可，但是在cdh4.2.0中，这个环境变量并不会生效，可以通过打patch来解决:
https://issues.apache.org/jira/browse/MAPREDUCE-4397

默认情况下，目录取值的方法如下：

 
        #ifndef HADOOP_CONF_DIR    //如果编译时不指定HADOOP_CONF_DIR的值，没调用infer_conf_dir方法。
       
        conf_dir = infer_conf_dir(argv[0]); 
       
        if 
        (conf_dir == NULL) { 
       
        fprintf
        (LOGFILE, 
        "Couldn't infer HADOOP_CONF_DIR. Please set in environment\n"
        ); 
       
        return 
        INVALID_CONFIG_FILE; 
       
        } 
       
        #else
       
        conf_dir = strdup(STRINGIFY(HADOOP_CONF_DIR)); 
       
        #endif

其中infer_conf_dir方法如下，即通过获取二进制文件的相对路径来得到配置文件的存放目录，比如我们线上执行文件的位置为/home/test/platform/hadoop-2.0.0-mr1-cdh4.2.0/bin/../sbin/Linux-amd64-64/task-controller，配置文件的位置为
/home/test/platform/hadoop-2.0.0-mr1-cdh4.2.0/conf/taskcontroller.cfg：

 
        char 
        *infer_conf_dir(
        char 
        *executable_file) { 
       
        char 
        *result; 
       
        char 
        *exec_dup = strdup(executable_file); 
       
        char 
        *dir = dirname(exec_dup); 
       
        int 
        relative_len = 
        strlen
        (dir) + 1 + 
        strlen
        (CONF_DIR_RELATIVE_TO_EXEC) + 1; 
       
        char 
        *relative_unresolved = 
        malloc
        (relative_len); 
       
        snprintf(relative_unresolved, relative_len, 
        "%s/%s"
        , 
       
        dir, CONF_DIR_RELATIVE_TO_EXEC); 
       
        result = realpath(relative_unresolved, NULL); 
       
        // realpath will return NULL if the directory doesn't exist 
       
        .......

关于taskcontrol相关类的实现放在后面的文件讲解。

本文转自菜菜光 51CTO博客，原文链接：http://blog.51cto.com/caiguangguang/1385587，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/434611

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

hive中表状态数据的获取

在做容量规划的时候，我们需要关注hive中表的占用空间大小，文件数量，平均文件大小，已及存储格式，虽然在hive中也有statistcs的功能，但是值并准确（相比mysql的show table status相差很多）我们可以通过一些简单地方法去拿到这个值，比如通过hadoop fs -du 来获取表占用的空间大小，通过hadoop fs -count获取表的文件数量,然后定期取值并load到数据库中。在元数据库中，通过创建view来获取数据库，hdfs路径，表类型，存储格式等信息 1 2 3 4 5 6 7 8 9 10 11 12 13 CREATE OR REPLACE VIEW table_location_type AS SELECT CONCAT_WS( '.' ,a. NAME ,b.TBL_NAME) AS db_table,SUBSTR(c.LOCATION,18) AS db_location,b.TBL_TYPE AS type,SUBSTRING_INDEX(c.INPUT_FORMAT, '.' ,-1) AS IN_FOR FROM dbsa,tblsb...

2017-11-22

718

本地windows跑Python程序调用Spark

应用场景 spark是用scala写的一种极其强悍的计算工具，spark内存计算，提供了图计算，流式计算，机器学习，即时查询等十分方便的工具，当然我们也可以通过python代码，来调用实现spark计算，用spark来辅助我们计算，使代码效率更快，用户体验更强。操作流程按照windows搭建Python开发环境博文，搭建python开发环境，实际已经将Spark环境部署完成了，所以直接可以用python语言写一些spark相关的程序！代码示例： from pyspark import SparkContext sc = SparkContext("local","Simple App") doc = sc.parallelize([['a','b','c'],['b','d','d']]) words = doc.flatMap(lambda d:d).distinct().collect() word_dict = {w:i for w,i in zip(words,range(len(words)))} word_dict_b = sc.broadcast(word_dict...

2017-11-22

539

发表评论

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。