分享

【着急】windows下eclipse运行Java的Spark程序不进call方法如何解决?

Imagination 发表于 2016-4-29 13:34:56 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 10 11887
windows下eclipse运行Java的Spark程序不进call方法如何解决?
[mw_shl_code=java,true]JavaPairRDD<String, Integer> levels = hBaseRDD.mapToPair(
                    new PairFunction<Tuple2<ImmutableBytesWritable, Result>, String, Integer>() {
                        @Override
                        public Tuple2<String, Integer> call(Tuple2<ImmutableBytesWritable, Result> immutableBytesWritableResultTuple2) throws Exception {
                            byte[] o = immutableBytesWritableResultTuple2._2().getValue(Bytes.toBytes("SSFPXX"), Bytes.toBytes("SSFPXX"));
                            if (o != null) {
                                return new Tuple2<String, Integer>(new String(o), 200);
                            }
                            return null;
                        }
                    });[/mw_shl_code]

已有(10)人评论

跳转到指定楼层
Imagination 发表于 2016-4-29 13:35:48
debug 的时候 就是不进call方法
回复

使用道具 举报

Alkaloid0515 发表于 2016-4-29 16:31:34
debug不进去?
条件够应该可以。

回复

使用道具 举报

atsky123 发表于 2016-4-29 16:32:42

楼主看来已经想明白了。赐教,有时候也会遇到
回复

使用道具 举报

Imagination 发表于 2016-4-29 16:33:46
Alkaloid0515 发表于 2016-4-29 16:31
debug不进去?
条件够应该可以。

有例子吗,我想处理hbase数据,根据几个条件分组,然后汇总
回复

使用道具 举报

Imagination 发表于 2016-4-29 16:35:07
atsky123 发表于 2016-4-29 16:32
楼主看来已经想明白了。赐教,有时候也会遇到

sc.addJar("target\\test-dir\\HadoopMRHbase.jar");
执行的是我jar包的东西,但是我输出System.out.println("*********************进来了*****************");他还是不打印,不明白

回复

使用道具 举报

atsky123 发表于 2016-4-29 17:02:48
Imagination 发表于 2016-4-29 16:35
sc.addJar("target\\test-dir\\HadoopMRHbase.jar");
执行的是我jar包的东西,但是我输出System.out.pri ...

没看到打印语句,写在包里了??
包执行了吗
回复

使用道具 举报

Imagination 发表于 2016-4-29 17:50:13
atsky123 发表于 2016-4-29 17:02
没看到打印语句,写在包里了??
包执行了吗

执行了,有点无语 ,就没打印我输出那些

回复

使用道具 举报

atsky123 发表于 2016-4-29 21:39:44
Imagination 发表于 2016-4-29 17:50
执行了,有点无语 ,就没打印我输出那些

spark有work日志,是不是打印到别的地方了
回复

使用道具 举报

12下一页
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条