是否可以在流式闪烁作业中创建批处理闪烁作业？
我有一个使用Apache Flink（Flink版本:1.8.1)使用Scala进行流式处理的工作。flow作业要求如下：Kafka->写给Hbase->用不同的主题再次发送给Kafka
在向Hbase写入过程中，需要从另一个表中检索数据。为确保数据不为空(NULL)，作业必须（在一定时间内）重复检查数据是否为空。
编辑：我的意思是，有了我在内容中描述的问题，我想过必须在作业流中创建某种类型的作业批处理，但我找不到适合我的案例的例子。那么，是否可以在流式闪烁作业中创建批处理闪烁作业呢？如果是，你能帮助提供类似我需要的条件的例子吗？
共有1个答案
使用最新版本的Flink，您可以通过SQL/Table API对HBase进行查找查询（使用可配置的缓存）。您的用例听起来很容易以这种方式实现。更多信息请参阅文档。
-
我想运行流作业。 当我尝试使用和Flink Web界面在本地运行该作业时，没有问题。 但是，我当前正在尝试使用Flink on YARN（部署在Google Dataproc上）运行我的作业，并且当我尝试取消它时，取消状态将永远持续，并且TaskManager中仍有一个插槽被占用。 这是我得到的日志：
-
这是因为在开发模式下，为了通过 Webpack 实现热加载，CSS代码是打包在 JavaScript 代码中，并动态打到页面中去，从而元素重绘引起了闪烁。 不用担心，在生产模式下，CSS代码会单独打包至独立的文件并置于head标签内，不会出现页面闪烁的现象。
-
我有一个关于在Kinesis流中分片数据的问题。我想在向我的kinesis流发送用户数据时使用一个随机分区键，这样碎片中的数据是均匀分布的。为了使这个问题更简单，我想通过在Flink应用程序中键入用户ID来聚合用户数据。
-
我在Lollipop上的共享元素转换中看到了奇怪的事情。共享元素在开始动画之前闪烁（请看视频https://www.youtube.com/watch?v=DCoyyC_S-9A） 我不知道为什么会这样。但是，当我添加
-
我试图在Flink中编写一个需要两个阶段的计算。 在第一阶段，我创建一个Graph并获取它的顶点id： 在第二阶段，我想使用这些ID为每个顶点运行SingleSourceShortestPath。 它在本地工作（在IntelliJ IDE和命令行中使用），但当我使用其WebUI在Flink上提交作业时，程序只是执行直到方法并且不运行程序的剩余部分（用于语句和）。 问题是什么？ 这是我的代码：
-
我试图用pyplay制作一个游戏，我几乎完成了，但我想让被画在墙上的盒子不闪烁，这些红色的盒子在整个游戏中闪烁，我不想让它们闪烁，最后，我在一个if条件下调用player碰撞函数，在这里每当我制作新的碰撞器时，我每次都要在if条件下添加函数，我想要的是碰撞器对象自动调用这个函数，而不需要我在if语句中为碰撞器的每个实例调用它对象。请指导我如何这样做。