请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

flink1.9版直接运行出错

使用了1.9版本的Flink模板来创建项目的。
根据本课学习的内容,运行代码如下:

    public static void main(String[] args) throws Exception{

        final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        DataSet<String> input = env.readTextFile("file:///Users/jeff/projects/study/flink-train-java/test.txt");
        input.print();
        input.flatMap(new FlatMapFunction<String, Tuple2<String, Integer>>() {
            @Override
            public void flatMap(String s, Collector<Tuple2<String, Integer>> collector) throws Exception {
                String[] tokens = s.toLowerCase().split(" ");
                for (String token: tokens){
                    if (token.length() > 0) {
                        collector.collect(new Tuple2<String, Integer>(token, 1));
                    }

                }
            }
        }).groupBy(0).sum(1).print();
        env.execute("Flink Batch Java API Skeleton");

    }

执行该Main函数时,并没有输出想要的结果,并且程序不会自动停止,而是处于一个运行着的状态。
翻了一下日志,有报一个错:
00:42:34,972 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at main(BatchWCJavaApp.java:12) (org.apache.flink.api.java.io.TextInputFormat)) (1/8) (98a5cbecb493ed76e173902afdfaad42) switched from CREATED to SCHEDULED.
00:42:34,980 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{858aa7d798c6f34199c63394476feacd}]

如何解决这个问題?

正在回答 回答被采纳积分+3

2回答

提问者 杰夫斯基 2019-11-10 10:45:17

Java运行版本问題,虽然是Java8,但是几年前的环境,手动升级到java8的最新版本u231后,问題就解决了。

1 回复 有任何疑惑可以回复我~
Michael_PK 2019-10-31 03:30:43

请先使用上课的版本,不同版本有区别。另外请提供error日志

0 回复 有任何疑惑可以回复我~
  • 提问者 杰夫斯基 #1
    换成1.7.0的结果同样的。
    日志太长没办法在此贴出来,已在QQ群上传了日志,麻烦老师帮忙看看。
    回复 有任何疑惑可以回复我~ 2019-10-31 07:04:19
  • Michael_PK 回复 提问者 杰夫斯基 #2
    error日志
    回复 有任何疑惑可以回复我~ 2019-10-31 08:05:51
  • 提问者 杰夫斯基 回复 Michael_PK #3
    无Error日志,全是INFO
    回复 有任何疑惑可以回复我~ 2019-10-31 08:32:49
问题已解决,确定采纳
还有疑问,暂不采纳
意见反馈 帮助中心 APP下载
官方微信