flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Biao Liu <mmyy1...@gmail.com>
Subject Re: 1.7.1版本getDistributedCache().getFile("key")失败问题
Date Wed, 03 Apr 2019 08:26:40 GMT
Hi, 按照你给出的部分代码,看不出问题所在,按道理是不应该的
建议给出更详细的信息,可以考虑以下几个方面
1. 完整可复现的代码(可以放到附件中),方便其他同学复现问题
2. 具体使用版本

PS: 如果你确认不是你测试环境/代码的问题,甚至可以直接建 jira issue
来反馈 bug,参见
https://flink.apache.org/how-to-contribute.html#file-a-bug-report


天边的云 <lyuan023@126.com> 于2019年4月3日周三 下午3:24写道:

> 如题,按照官方例子
> env9.registerCachedFile("hdfs://xxx/key", "key");
>
>
> ...
> .map(
>     new RichMapFunction<String, String>() {
>       @Override
>       public String map(String value) throws Exception {
>         return value;
>       }
>       @Override
>       public void open(Configuration parameters) {
>        File file =
> getRuntimeContext().getDistributedCache().getFile("key");
>             System.out.println(file.getAbsolutePath());
>       }
>
>
>     });
> ...
> 之前1.5版本没有任何问题,相同的代码更换到1.7.1版本之后报如下错误:
> java.lang.IllegalArgumentException: File with name 'key' is not available.
> Did you forget to register the file?
>
>
> 有谁遇到相同的问题或对这块代码有研究的吗?
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message