Flink搭建部署-standalon模式、onyarn模式（包含hadoop、zookeeper部署）1、Flink虚拟机环境部署2.1、standalone模式2.2、onyarn模式2.3、高可用zookeeper3.1、

在win10上安装zookeeper，一个初学者犯的错，记录下，以防再犯！错误如下：上面的错误已经说的很清楚了，unabletoaccessdatadir,exitingabnormally。无法访问datadir路径的文件

1.下载需要的软件ElasticStack：Elasticsearch、Kibana、Beats和Logstash|Elasticikanalysis下载地址：https://github.com/medcl/e

下面用java给出一个kafka生产与消费的简单示例：运行环境：java：javaversion"1.8.0_291"kafka：org.apache.kafkakafka_2.112.1.0与消费者相

第1关：Sqoop数据导出语法学习start-all.shschematool-dbTypemysql-initSchema第2关：HDFS数据导出至Mysql内mysql-uroot-p123123-h127.0.0.1

题目：代码：fault_detect.pyimportsysfrompysparkimportSparkContextfrompyspark.streamingimportStreamingContextdefdet

选择器，选择器，就是选择如何把一个source的数据同时写到多个channel，是复制到各个channel，大家数据一样，还是有规则的将一些数据给achannel，另一些数据给bchannel。source可以向多个channel

首先：一定要先启动ZooKeeper再启动Kafka顺序不可以改变。先关闭kafka，再关闭zookeeper。启动ZooKeeper后不要暴力关闭命令行，否则接下来启动kafka时会连接不上，显示Timeout错误两个都不能暴

需求一用户活跃主题(日活、周活、月活)涉及知识点：concat、concat_ws、collect_set、date_add、next_day、last_day、date_format、hive动态分区、if函数1、dws层dws_u

出现此问题的原因是，数据库字段长度太长，超出了索引的限制长度，针对过长的字段，我们需要创建前缀索引，那么前缀索引如何创建呢？这个问题又该如何解决呢？mysql默认情况下单个列的索引不能超过767位，我们可以启用innodb_large_