问题描述：flink 启动，standalone 模式 StandaloneSessionClusterEntrypoint 进程起不来。解决办法：查看log日志文件org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to initialize the cluster entrypoint Standalon

去当前节点查看Log 日志：Java HotSpot™ 64-Bit Server VM warning: INFO: os::commit_memory(0x00000000c6600000, 966787072, 0) failed; error=‘Cannot allocate memory’ (errno=12)There is insufficient memory for the Ja

文章目录1. Editing(编辑)2. Search/Replace(查找/替换)3. Usage Search(使用搜索)4. Compile and Run(编译/运行)5. Debugging(调试)6. Navigation(导航)7. Refactoring(重构)8. VCS/Local History(版本控制/本地历史)9. Live Templates(动态模板)10. Gen

第1章 Spark SQL概述1.1什么是Spark SQLSpark SQL是Spark用来处理结构化数据的一个模块，它提供了2个编程抽象：DataFrame和DataSet，并且作为分布式SQL查询引擎的作用。我们已经学习了Hive，它是将Hive SQL转换成MapReduce然后提交到集群上执行，大大简化了编写MapReduc的程序的复杂性，由于MapReduce这种计算模型执行效...

systemctl stop firewalld.service命令关闭防火墙。关闭后防火墙后原点会变成黑色。使用systemctl status firewalld.service命令查看防火墙状态。关闭防火墙自启动命令systemctl disable firewalld.service。因为每次重启的时候防火墙会自启动，所以还要关闭自启动防火墙。(所有不说版本的都是耍流氓，博主使用版本如下)

Apache Kafka 2.4.0 已发布，此版本新增了不少新功能，其中包括：允许消费者从最近的副本进行获取为 Consumer Rebalance Protocol 增加对增量协同重新均衡（incremental cooperative rebalancing）的支持新增 MirrorMaker 2.0 (MM2)，新的多集群跨数据中心复制引擎引入新的 Java 授权程序接口支持 KTable

1. Kafka 中的 ISR(InSyncRepli)、 OSR(OutSyncRepli)、 AR(AllRepli)代表什么？ISR：In-Sync Replicas 副本同步队列AR：Assigned Replicas 所有副本ISR是由leader维护，follower从leader同步数据有一些延迟（包括延迟时间replica.lag.time.max.ms和延迟条数replica.l