最新在线上更新了代码之后导致了任务在消费kafka数据的时候,突然就不消费数据了,发现原因在公司的可视化界面中,看不到数据的更新,进入flink监控页面中看到任务没有fail...
发简信
IP属地：黑龙江
-
记录Flink1.9线上checkpoint失败的问题 -
关闭Chrome左右滑动时返回上一个网页
我用Mac电脑上用Chrome时，有一点非常不便让我常常无语。也不知道哪个工程师开发的功能，这么扯，每次用触摸板滑动浏览网页的时候，它会自动抓取你左滑动或者右滑动，变为返回上...
-
Kafka源码分析（七）消息发送可靠性——min.insync.replicas
继续解答问题：Kafka怎么样才能不丢消息？ 再次说明下acks的语义如果acks=all，代表消息需要在所有ISR都被持久化成功后，Broker才可以告诉生产者，消息已经发...
-
FlinkSQL的痛点
现在FlinkSQL可以source创建一张表,也可以sink也创建一张表 然后直接aggTable1.insertInto("out"); 但是如果要是比如out这个表是k...
-
Scala解析JSON
package com.mlamp.test_json /** * @Author: DaChun777 * @Date: 2021/12/8 上午10:35 * @Desc...
-
MAC上Git安装与GitHub基本使用目录 安装git创建ssh key、配置git提交本地项目到GitHub 一、安装Git MAC 上安装Git主要有两种方式 首先查看电脑是否安装Git，终端输入： 安装过则...
-
Mac idea 2020.1 版本的安装与破解一、 idea 的下载 官网下载地址：https://www.jetbrains.com/下载.png 百度云提供 2020.1 的版本： 链接: https://pan.b...
-
这个读请求会不会造成读不到最新的数据,因为写是满足过半性写就算写入完成
Zookeeper的选举和读写流程
Zookeeper选举过程 服务器启动或者服务器运行期间（Leader挂了），都会进入Leader选举，我们来看一下~假设现在ZooKeeper集群有五台服务器，它们myid...
-
其实这个十分之1的说法并不对,你自己测试就知道了.啊哈哈哈
Spark 配置Kryo序列化机制
一、Spark 的序列化 序列化Spark 是一个高性能、分布式的、基于内存计算的计算引擎，Spark 集群中包含多个节点，各节点之间要进行通信（比如数据传输，Spark 通...
-
Spark读取Hive数据
依赖如下: <dependencies> <!-- mysql --> <dependency> <groupId>mysql</groupId> ...
-
不会,也是根据关联字段Join的,这个intervalJoin生产没人用,太鸡肋了.
谈谈Flink DataStream API中的三种双流join操作
前言 本文是基础中的基础，看官可以放心食用。 在数据库中的静态表上做OLAP分析时，两表join是非常常见的操作。同理，在流式处理作业中，有时也需要在两条流上做join以获得...
-
Maven明明导入了依赖但是运行报错
我在运行flink程序时候,就是一个table程序,在编译时候以及写代码都不报错,然后运行就报错少依赖, 卧槽,而且这个依赖这个类我都能够找到,点进去能看到源码,死活报错找不...
-
MySQL获取毫秒值
select time_to_sec(now()), now(), current_timestamp(), replace(unix_timestamp(now(3)),'...
-
你找到了吗?哥,能发我一个吗
二、Azkaban单机与集群的安装
一、概述 在上一篇文章中，描述了如果使用源码对Azkaban进行编译并打包的过程，如果用户不想自己手动编译，可以直接下载笔者已经编译好的安装包，下载地址如下： 百度云链接：h...
