解决python插入大量数据时出现：python Lost connection to MySQL server during query问题

step3：将普通主数据流和广播流进行connect，调用process方法，在process方法中通过自定义BroadcastProcessFunction继承的processElement方法和processBroadcastElement方法，分别对普通主数据流中事件和广播流中事件进行处理。个人认为当一个数据流需要另一个不停变化实时数据参与计算处理时，可以将不停变化的实时数据作为广播流，将两

使用TEZ作为Hive默认执行引擎时，需要在调用Hive CLI的时候启动YARN应用，预分配资源，这需要花一些时间，而使用MapReduce作为执行引擎时是在执行语句的时候才会去启用YARN应用。所以说，hive on tez使用./bin/hive后一直卡住是假象，待预分配资源任务结束后，即可输入hive sql正常执行。hive on tez使用./bin/hive启动后一直卡住，无法进入命

连接生产环境的VPN后用dbeaver连上hive后，经常查询无响应掉线，报错：org.apache.thrift.transport.TTransportException: java.net.SocketException: 你的主机中的软件中止了一个已建立的连接。如果电脑开启了类似火绒、360这样的安全软件，尝试关闭后执行查询即可（也可以研究此类软件的安全策略），猜测是此类安全软件做了某种限

下载安装不在赘述，本文只记述一些neo4j的基本入门操作。

抢占是 YARN 在资源紧张时的机制，用于重新分配低优先级任务的资源给更高优先级的任务。configured capacity=5%，表示队列的初始容量百分比，即avation队列在最开始可以使用132G*5%=6.75G，75*5%=3.75cores。: 这是当前等待资源的最高优先级请求的优先级值。通常，当 YARN 没有立即分配到符合要求的资源时，容器会被延迟，直到合适的资源可用。confi

flink yarn-session 启动失败retrying connect to server 0.0.0.0/0.0.0.0:8032

flink集群搭建TaskManagerRunner启动失败

基于3台虚拟机服务器如何安装ambari，并通过ambari安装各大数据组件

对于数据量的统计，从表是否分区分为和两者有着不同的统计方式。