讲师回答 / 大数据技术与架构
你好,我才看到你的留言。这个问题比较可能是因为:你这个类中import的是不是StreamExecutionEnvironment,或者看看Tuple2是不是引用对了。
2019-02-13
flink相对于storm吞吐高近30倍,实验环境。spark为了实现exactly-once特性,导致吞吐急剧下降。跟flink差将近连个数量级。
2019-01-17
讲师回答 / 大数据技术与架构
我来回答下吧。单机版确实不需要。实际生产环境一般是on yarn,是需要hadoop环境的。但是,注意啦!flink本身已经和hadoop继承在一个包里了。大家可以去官网看,安装包带了对应版本的hadoop。所以,结论是,需要。但是安装过程大大简化。大概比安装spark集群简单60%以上。希望对你有帮助。
2019-01-12