Re: FileInputFormat 使用问题

[john]

嗨，找到问题了吗？我也遇到了

> 2020年6月1日 下午2:48，阿华田 <a15733178...@163.com> 写道：
> 
> //初始化任务参数
> ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
> FileInputFormat fileInputFormat = new TextInputFormat(new 
> Path("hdfs://arc/success_fid_flow <hdfs://arc/success_fid_flow>"));
> fileInputFormat.setNestedFileEnumeration(true);
> //过滤掉条件为true
> fileInputFormat.setFilesFilter(new 
> RegexExcludePathAndTimeFilter("2020-05-24","2020-05-24"));
> DataSet<String> source =env.createInput(fileInputFormat);
> source.output(new HdfsTrainSinktest());