hdfs-site.xml ??
core-site.xml??IDEA??resourcesconfnamespace
kcz
?? 2020-06-02 19:20
user-zh
?? flink-1.10 hdfs
??
String path = "hdfs://HACluster/user/flink/t
Hi,kcz
inprogressfinished??[1]??RollingPolicy
inprogressfinished
[1]https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/connectors/streamfile_sink.html#part-file-lifecycle
[2]https://ci.apache.org/
??
String path = "hdfs://HACluster/user/flink/test-1/2020-05-29--15/";
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
FileInputFormat fileInputFormat = new TextInputFormat(new Path(path));
fileInputFormat.setNestedFileEnumeration(true);
env.readFile(
