权限问题？
Flume(二)快速入门Flume安装部署 安装地址 Flume官网[http://flume.apache.org/] 文档查看地址[http://flume.apache.org/FlumeUs...
IP属地：广东
权限问题？
Flume(二)快速入门Flume安装部署 安装地址 Flume官网[http://flume.apache.org/] 文档查看地址[http://flume.apache.org/FlumeUs...
循环中出现异常，肯定会跳出循环。但是在此之前的数据量应该是没有问题的，报错了说明程序有问题，应该先看看异常的原因然后进行处理。还有一个就是可以为默认值。如果可以的话，想看看你的程序。
scala(二十二) 异常(Exception)语法处理上和Java类似，但是又不尽相同。 java中异常的处理方式: 1.捕获异常: try{..}catch(..){..} finally{...}2.抛出异常:1.在...
今天早上，我启动Hadoop ，然后访问 9870端口，显示的却是这样的 image.png 刚开始，我以为我哪里配置有问题，于是查看日志，例如出现这种错误， image.p...
异常：Producer attempted to produce with an old epoch. 解决方式 规避方式[https://issues.apache.org...
前言 记录了我使用CDH 安装 ES 过程 第一步：cdh 集成 es 参考文章[https://blog.csdn.net/guoliduo/article/details...
前言 我已经很久没有写过博客了，今天再次登录之后发现有了很多的关注和评论，让我感到我的文章的对大家还是有帮助的，以后会继续写下去的，进入主题。我使用maxwell也有很长时间...
GO ON ---（SQL高级） SQL INNER JOIN 关键字（在表中存在至少一个匹配时，INNER JOIN 关键字返回行） SELECT 列名称 FROM 表名称...
Window Function 前面指定了窗口的分配器, 接着我们需要来指定如何计算, 这事由window function来负责. 一旦窗口关闭, window func...
状态的一致性 当在分布式系统中引入状态时，自然也引入了一致性问题。 一致性实际上是"正确性级别"的另一种说法，也就是说在成功处理故障并恢复之后得到的结果，与没有发生任何故障时...
介绍 Flink具体如何保证exactly-once呢? 它使用一种被称为"检查点"（checkpoint）的特性，在出现故障时将系统重置回正确状态。下面通过简单的类比来解释...
什么是FlinkCEP FlinkCEP(Complex event processing for Flink) 是在Flink实现的复杂事件处理库. 它可以让你在无界流或有...
Catalog 提供了元数据信息，例如数据库、表、分区、视图以及数据库或其他外部系统中存储的函数和信息。 数据处理最关键的方面之一是管理元数据。 元数据可以是临时的，例如临时...
函数分类 官网介绍[https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/f...
窗口概述 在流处理应用中，数据是连续不断的，因此我们不可能等到所有数据都到了才开始处理。当然我们可以每来一个消息就处理一次，但是有时我们需要做一些聚合类的处理，例如：在过去的...
前言 flink中有七大官方定义的分区器以及一个用于自定义的分区器（共八个）。 org.apache.flink.streaming.runtime.partitioner....
前言 Flink从1.12.0上对流式API新增一项特性:可以根据你的使用情况和Job的特点, 可以选择不同的运行时执行模式(runtime execution modes)...
转换算子可以把一个或多个DataStream转成一个新的DataStream.程序可以把多个复杂的转换组合成复杂的数据流拓扑. map 作用将数据流中的数据进行转换, 形成新...
TaskManager与Slots Flink中每一个worker(TaskManager)都是一个JVM进程，它可能会在独立的线程上执行一个Task。为了控制一个worke...