当前位置: 首页 > 知识库问答 >
问题:

NumLatereCordsDrop:它对操作员意味着什么

蒋高杰
2023-03-14

这里有多个任务。其中一个任务是bookinginfowithfraudanddefaultandmainsp->tsandmbookingwithspobjects。我们称之为任务-1。在任务-1中,我分配一个时间戳并生成水印,我使用boundedoutofordernestimestampextractor,其中maxoutoforderness等于2min。

下一个操作符是我窗口数据,并在上面做一些聚合,然后下沉到Kafka。让我们将这个聚合和下沉的链接任务称为task-2

NumLatereCordsDrople:查看这个度量值,它告诉这个运算符/任务由于延迟到达而丢弃的记录数

问题:当我窗口元素时,我已经分配了0允许的迟到。所以它可能掉了一些元素。但是当我查看度量时,由于windows不是一个运算符,所以没有度量可以告诉windows丢弃了多少元素。

当我查看task-2度量时,它显示了NumLatereCordsDrople的计数。这是什么意思。窗口聚合任务如何删除记录。或者,由于它正在聚合窗口,所以计数基本上是窗口丢弃的记录数。

共有1个答案

宇文念
2023-03-14

Window运算符是Flink使用NumlatereCordsDroped的唯一地方(而且,Window聚合函数在Window运算符中运行),所以是的,计数是Window丢弃的记录数。

 类似资料:
  • 问题内容: 我了解这是用来创建别名的。因此,将一个长名称别名为一个短名称是有意义的。但是,我看到一个查询 ,这意味着什么? 问题答案: 可以以多种方式使用别名,而不仅仅是缩短长列名。 在这种情况下,您的示例意味着您将返回一列始终包含的列,并且其别名/列名称为。 当您使用计算值(例如)时,也可以使用别名。

  • 我想创建一个

  • 问题内容: 什么是甲骨文针对谷歌的诉讼意味着Android开发?我知道这不是与编程有关的问题,但是我想不出另一个可以在此提出问题的论坛。 问题答案: 从技术上讲,Oracle正在为此而努力。Android实际上不是Java,而是Java-> Dalvik转换器。尽管据我所知没有人尝试过,但没有人对转换器提出诉讼。您最好在TechCrunch或其他与技术类似的与新闻界类似的网站上关注事情。

  • 问题内容: 什么是甲骨文针对谷歌的诉讼意味着Android开发?我知道这不是与编程有关的问题,但是我想不出另一个可以在此提出问题的论坛。 问题答案: 从技术上讲,Oracle正在为此而努力。Android实际上不是Java,而是Java-> Dalvik转换器。尽管据我所知没有人尝试过,但没有人对转换器提出诉讼。您最好在TechCrunch或其他与技术类似的与新闻界类似的网站上关注事情。

  • 我最近看到新的Gmail API宣布吹嘘OAuth 2.0用户身份验证。 我有点担心,因为在我们的企业Google Apps域中,我已经使用XOAUTH2与Gmail集成。(从本质上讲,XOAUTH2 包括对 IMAP 身份验证的 OAuth 2.0 支持)。 我应该担心吗? 新的Gmail API是否意味着XOAUTH2的终结开始?

  • 描述中说: 在2020-11-10之前的Rust模型箱中发现了一个问题。共享数据结构具有发送和同步特征的实现,而不考虑内部类型。 什么是模型板条箱?抱歉,如果它的愚蠢的问题,但我是新的CVE漏洞。