toRDD之后用map算子就可以啊

@tedxianfq 这个代码有点多，五月份我会上传这部分视频和代码。

@正在探索的小白瑶 666

你创建的topic是wordsendertest。但是你启动的消费指定的topic是wordsender，所以指定收不到数据啊

报什么错？印象中要给一个空的用户名和密码

好的我发给你

/**
 * 通用工具类
 * 
 * @author   青牛
 * @Date     2017年9月1日   
 */
public class Utils {

    /**
     * 判断是否为空，支持字符串、map、集合、数组和其它对象
     * 
     * @param obj               判断的对象
     * @return                  为空返回True，不为空返回False
     */
    public static boolean isEmpty(Object obj){
        if(obj == null){
            return true;
        }else if (obj instanceof String){
            return "".equals(String.valueOf(obj).trim());
        }else if (obj instanceof Map<?,?>){
            return ((Map<?,?>) obj).isEmpty();
        }else if (obj instanceof Collection<?>){
            return ((Collection<?>) obj).isEmpty();
        }else if (obj.getClass().isArray()){
            return Array.getLength(obj) == 0;
        }
        return false;
    }

    /**
     * 判断是否为空，支持字符串、map、集合、数组和其它对象
     * 
     * @param obj               判断的对象
     * @return                  为空返回False，不为空返回True
     */
    public static boolean isNotEmpty(Object obj){
        return !isEmpty(obj);
    }

}

@tedxianfq 这个是启动每个节点上的regionserver，daemons是启动每个节点的，daemon是启动一个节点的。所以根据你的需求使用带s还是不带s的。

@tedxianfq 你的master起来了吗？

你这上面是不是还有其它异常啊？都贴出来看看

@maxy 因为sortbykey在内部使用了RangePartitioner，所以会保证分区1小于分区2，以此类推

你那key是string所以按照字典序排列了，给他转成int的

datanode重新上报匹配的块信息了？

@luo6994658 任何可被执行的文件都是二进制的，但二进制文件不一定可被执行啊？比如一个视频文件也是二进制的，但是它并不能被直接执行，它需要一个播放器程序才能打开，这个播放器程序一定是二进制的。 whereis -b就是找这种播放器，而不是找这种视频文件。