在安装好Hadoop集群后，运行mapreduc。到如下的地方就卡住，要不到图二卡住，namenode和datanode，nodemanager，recemanager都启动正常，刚开始以为是hadoop3.2.3的版本问题。后来换成hadoop3.1.3还是不行。解决方案：方法1.在mapred-site.xml文件将<property><name>mapreduce.f

import com.alibaba.ververica.connectors.datahub.sink.DatahubSinkFunction;import com.aliyun.datahub.client.model.*;import org.apache.flink.api.common.functions.MapFunction;import org.apache.flink.strea

在实际应用中，我们经常会遇到来源不同的多条流，需要将它们的数据进行联合处理。所以Flink中合流的操作会更加普遍，对应的API也更加丰富。

开窗函数，窗口范围ROWS与RANGE