沉没到目的地后的工艺元件
我正在设置一个从 Kafka 读取并汇到 HDFS 的 flink 管道。我想在addSink（）步骤之后处理元素。这是因为我想设置触发文件，指示某个分区/小时的数据写入（到接收器）已完成。如何实现这一点？目前我正在使用铲斗水槽。
>
DataStream消息流=env. addSource（flinkKafka消费者011）；
//将消息流转换为keyedStream的一些聚合
keyedStream.addSink（水槽）；
//如何处理3之后的元素。？
共有1个答案
Flink API不支持将作业图扩展到接收器之外。（但是，您可以在向接收器写入数据的同时分叉流并执行其他处理。）
使用流式文件接收器，您可以观察到零件文件在完成时转换到完成状态。有关更多信息，请参见JavaDoc。
状态存在于单个操作符中——只有该操作符(例如ProcessFunction)可以修改它。如果你想在接收完成后修改键值状态，没有简单的方法。一种想法是在ProcessFunction中添加一个处理时间计时器，它具有定期唤醒并检查新完成的零件文件的键控状态，并根据它们的存在修改状态。或者，如果粒度不合适，则编写一个自定义源来做类似的事情，并将信息流式传输或广播到ProcessFunction(这将必须是一个协ProcessFunction或KeyedBroadcastProcessFunction)中，它可以用它来进行必要的状态更新。
-
我正在运行一个Django服务，它为selenium启动chromedriver，并从网站上获取数据。Django服务由另一个Java服务通过HTTP调用。 这是代码： views.py 刮刀py公司 问题是，在java服务完成所有调用并完成整个过程后，有25-50个chrome进程孤立在RAM中，占用超过1 GB的内存。我在这里有什么不对吗？
-
我试图在Flink的数据流上应用每窗口功能。以下是我的代码 下面是我的实现MyProcessWindow函数 然而，当我试图通过maven编译上述代码时，我得到了以下错误 知道我做错了什么吗？仅供参考，我正在使用ApacheFlink 1.5.1版，并在Mac上使用maven3编译Java代码。
-
我有一个 spring-boot 项目的 gradle 构建作为 Jenkins 的工作。我正在使用 Jenkins 的 artifactory 插件将生成的 JAR 发布到我们的 artifactory 服务器。 构建成功完成并发布工件，但 Jenkins 控制台报告与 Artifactory 通信时出错（摘自下面列出的控制台）。 我使用的是Jenkins 1.597、artifactory插件
-
AndroidManifest.xml
-
我正在尝试进入沉浸式模式，使用 工具栏部分隐藏在状态栏后面。那么我如何使工具栏再次正确地出现呢？
-
我目前正在尝试使用artifactory Jenkins插件启动管道。当我在jenkins freestyle项目中使用该插件作为构建步骤时，它工作得非常好。当我从管道中直接运行maven时，它工作得非常好。当我使用下面的脚本运行maven通过Artifactory插件时，它失败了。我得到的错误是： 此环境中不提供编译器。也许你是在JRE而不是JDK上运行？ 这是我目前的剧本：