flink ????hadoop????????

[??????????????]

???????????????? ??
hadoop????TestHACluster??????????api????????????????path 
hdfs://TestHACluster/user/flink/test  
??????????TestHACluster:8020?? ????????????????????????????????????????????????
??????????????????????????hive????????????????????????????TestHACluster:8020
StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();
DataStream<String&gt; input = env.fromCollection(Arrays.asList("1","2"));

StreamingFileSink<String&gt; sink = StreamingFileSink.forRowFormat(
        new Path("hdfs://TestHACluster/user/flink/test"),
        new SimpleStringEncoder<String&gt;(Encoder.UTF_8))
        .withBucketAssigner(new DateTimeBucketAssigner<&gt;())
        .build();
input.addSink(sink);
env.execute();