flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/RollingSink.java
/**
	 * Create a file system with the user-defined hdfs config.
	 * @throws IOException
	 */
Create a file system with the user-defined hdfs config.
Create a file system with the user - defined hdfs config .
private void initFileSystem() throws IOException {
		if (fs == null) {
			Path path = new Path(basePath);
			fs = BucketingSink.createHadoopFileSystem(path, fsConfig);
		}
	}
private void initFileSystem ( ) throws IOException { if ( fs == null ) { Path path = new Path ( basePath ) ; fs = BucketingSink . createHadoopFileSystem ( path , fsConfig ) ; } }
Create a file system with the user-defined hdfs config.
Create a file system with the user - defined hdfs config .