下面的代码是你本地运行的是吗 如果是本地需要最简单的方式 就是把hdfs-site.xml 和core-site.xml 配置文件放到资源目录下
在 2020-05-29 15:06:21,"了不起的盖茨比" <573693...@qq.com> 写道:
>请教大家一个问题 ,
>hadoop服务TestHACluster,可是我用api访问时候,填写了path
>hdfs://TestHACluster/user/flink/test
>就会去访问TestHACluster:8020, 但是我是没有那个端口的,针对这种情况怎么处理下。
>因为这个问题,我后面去操作hive时候也是会提示问题,无法连接TestHACluster:8020
>StreamExecutionEnvironment env =
>StreamExecutionEnvironment.getExecutionEnvironment();
>DataStream<String> input = env.fromCollection(Arrays.asList("1","2"));
>
>StreamingFileSink<String> sink = StreamingFileSink.forRowFormat(
> new Path("hdfs://TestHACluster/user/flink/test"),
> new SimpleStringEncoder<String>(Encoder.UTF_8))
> .withBucketAssigner(new DateTimeBucketAssigner<>())
> .build();
>input.addSink(sink);
>env.execute();