大数据知识_大数据学习笔记

flink on yarn运行，web页面task managers  logs和stdout中文显示均乱码(全都问号)，解决办法如下： 修改flink-1.11.0/conf....

1. 系统环境 1.1.系统版本 CentOS Linux release：7.9.2009 (Core)64位RabbitMQ：3.9.8-1.el7Erlang：23.2JDK：1.8+1.2.关闭....

公司简介 深圳市弘源泰平资产管理有限公司组建于2016年，团队核心成员来自于知名高校，有丰富的资产配置与策略构建的实践经....

解压缩 [hadoop@hadoop1 soft]$ tar -zxvf kafka_2.11-0.11.0.2.tgz -C /opt/module [hadoop@hadoop1 module]$ mv /opt/m....

高并发，几乎是每个程序员都想拥有的经验。原因很简单：随着流量变大，会遇到各种各样的技术问题，比如接口响应超时、CPU lo....

一、RabbitMQ简介 RabbitMQ 是一个在AMQP(高级消息队列协议)基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件....

从2015年开始，中国的B2B电商就像“风口上的猪”开始翱翔，创业企业数量多、交易金额巨大、营收增长快使其成为行业热点。来....

1.spark是什么？ spark是一个用来实现快速，通用的集群计算平台 spark适用于各种各样原先需要多种不同的分布式平台的场景....

import com.alibaba.fastjson.JSONObject;import com.poizon.bigdata.flink.job.BaseFlinkJob;import com.poizon.bigdata.flink.

这里假设ip jar对应的版本 都匹配得上zookeeper服务器，防火墙也开了的情况下 然后，在运行中我执行下代码，发现有下述bug ....

前奏 为了实现一个spark的客户端访问服务端的python访问，折腾了好几天，现在终于解决了，查了网上的很多人写的文章，都没解....

我们的spark-sql版本： [hadoop@666 ~]$ spark-sql --versionWelcome to ____ __ / __/__ ___ _____....

结合Flink一周的使用经验，用到了三个模块 (source于kafka，sink到Mysql，kudu，kafka) source kafka是最简单的 //导入的包i....

前言 Kafka是一个分布式的流处理平台(0.10.x版本)，在kafka0.8.x版本的时候，kafka主要是作为一个分布式的、可分区的、具有....

目录 一、基本概念 二、RabbitMQ安装 设置ip 1 镜像 1.1 在线下载 1.2 使用离线镜像包 2 关闭防火墙 3 配置管理员用户信....

一、环境准备 LinuxJDK(1.8以上，推荐1.8)Python(推荐Python2.6.X) yum安装Python:https://www.cnblogs.com/kaishirenshi/....

序言 因为所以. Flink大数据计算的横向扩展是一定要考虑Parallelism 和Slot的. slot决定了parallelism的可行性以及数量.如果....

一旦你ZooKeeper客户端断开了连接，那ZooKeeper服务端就不再保存这个节点。再说下顺序性节点，顺序性节点是指，在创建节点的....

常规操作elasticSearch -分词检索 借助REST API GET bank/_search?q=*&sort=account_number:asc 检索条件全部 按照account....

问题如下 100瓶水，一瓶有毒，有一种试纸，不过需要一个小时才能出结果，问最少需要几片试纸才能在一小时内找到有毒的那一瓶....