Re:flink 访问hadoop集群问题

[程龙]

下面的代码是你本地运行的是吗 如果是本地需要最简单的方式 就是把hdfs-site.xml 和core-site.xml 配置文件放到资源目录下











在 2020-05-29 15:06:21，"了不起的盖茨比" <573693...@qq.com> 写道：
>请教大家一个问题 ，
>hadoop服务TestHACluster，可是我用api访问时候，填写了path 
>hdfs://TestHACluster/user/flink/test&nbsp;&nbsp;
>就会去访问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();