该错误需要查看Hadoop的源代码（131行）：https://gitee.com/highmoutain/hadoop/blob/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/FileOutputF

远程连接方案, 允许所有的程序员都去连接远端的测试环境, 确保大家的环境都是统一的, 避免各种环境问题的发生,而且由于是连接的远程环境, 所有在pycharm编写代码 都会自动上传到远端服务器中, 在执行代码的时候, 相当于是直接在远端环境上进行执行操作。可以配置为Base环境，也可以配置为其他的虚拟环境, 但是目前建议配置为Base环境，因为Base环境自带python包更全面一些。Standa

sql = "insert into student(name,gender,age) values(%s,%s,%s)"# 不管什么类型的数据,都是使用%s替换。# sql = "insert into student(name,gender,age) values(%s,%s,%d)"# 错误。insert into student(name, gender, age) values ('赵雪

Apache Spark是用于大规模数据（large-scala data）处理的统一（unified）分析引擎。

—>在.30的虚拟机主页面上右上角的开关处，找到有线，点击打开有线设置，在弹出的页面中的有线一栏，点击一个有齿轮的图标，然后点击IPV4，将地址改为192.168.200.30后点击右上角的应用，然后在有线一栏的打开关闭处，点击关闭后再点击打开，完成后可以在自己的计算机上的命令行界面，输入命令ping 192.168.200.30后回车，查看网卡的连接情况,注意如果这里连不上网，请在虚拟网络编辑器

MQ：message queue消息队列activeMQ: 出现时期比较早的一款消息队列的中间件产品，在早期使用人群是非常多，目前整个社区活跃度严重下降，使用人群很少了rabbitMQ: 此款是目前使用人群比较多的一款消息队列的中间件的产品，社区活跃度比较高，主要是应用传统业务领域中rocketMQ: 是阿里推出的一款消息队列的中间件的产品，目前主要是在阿里系环境中使用，目前支持的客户端比较少，主

Kafka本质上就是一个消息队列的中间件的产品，主要负责消息数据的传递。也就说学习Kafka 也就是学习如何使用Kafka生产数据，以及如何使用Kafka来消费数据。

2- 分发之后，记得要修改每个server.properties的 id 和 监听地址。(5) 给start-kafka.sh、stop-kafka.sh配置执行权限。5- 启动的时候server.properties中路径，不要写错了。（2）准备slave配置文件，用于保存要启动哪几个节点上的kafka。（1）在 节点1 中创建 /export/onekey 目录。# 2.再在三台集群上都输入以

可以在可视化的工具通过点击来操作kafka完成主题的创建，分区等操作注意: 安装完后桌面不会有快捷方式,需要去电脑上搜索,或者去自己选的安装位置找到发送快捷方式到桌面!

然而，在大多数情况下，这种开销是可以接受的，因为它提高了系统的容错性和可靠性，对于大多数企业级应用来说，这是非常重要的考虑因素。kafka-consumer-perf-test.sh 是 Apache Kafka 自带的消费者性能测试脚本，它能够评估 Kafka 消费者的吞吐量和其他性能指标。- 主副本-leader replica: 实际负责数据读写的副本，生产者和消费者都与这个副本进行交互的。