赞
踩
概述里介绍获得StreamExecutionEnvironment方法有三个
StreamExecutionEnvironment.getExecutionEnvironment();
StreamExecutionEnvironment.createLocalEnvironment();
StreamExecutionEnvironment.createRemoteEnvironment(String host, int port, String... jarFiles);
如果是在idea里面执行,会使用本地环境,在命令行里面执行jar文件,会使用当前的执行环境
使用本地环境
使用远程环境,参数主机地址、端口号、需要提交的jar包
在分布式系统中,构成系统的任何节点都是被定义为可以彼此独立失败的。比如在 Kafka中,broker可能会crash,在producer推送数据至topic的过程中也可能会遇到网络问题。根据producer处理此类故障所采取的提交策略类型,我们可以获得不同的语义:
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(5000, CheckpointingMode.AT_LEAST_ONCE);//每个5秒执行一次
env.setParallelism(2);//并行度2
参考:https://blog.csdn.net/GrassEva/article/details/120529303
https://blog.csdn.net/weixin_42311821/article/details/90598061
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。