阿帕奇Flink的分离模式是什么？
./bin/flink run -d ./examples/batch/WordCount.jar
共有1个答案
Flink CLI以阻塞或分离模式运行作业。在阻塞模式下，CliFrontend（客户机）进程保持运行、阻塞，等待作业完成--之后它将打印出一些信息。在下面的示例中，我运行了一个流作业，几秒钟后从WebUI中取消了该作业：
$ flink run target/oscon-1.0-SNAPSHOT.jar
Starting execution of program
Program execution finished
Job with JobID b02da01c30585bfbc86a23446559987f has finished.
Job Runtime: 8673 ms
如果您在阻塞模式下运行，您可以杀死CliFrontend（例如，使用ctrl-C)，如果您愿意，那么作业将不受影响，只要它已经运行到足以将作业提交给集群。
在分离模式下，CliFrontend将作业提交给集群，然后立即退出。
-
我正在使用Flink从Apache Pulsar读取数据。我在pulsar中有一个分区主题，有8个分区。在本主题中，我生成了1000条消息，分布在8个分区中。我的笔记本电脑中有8个内核，因此我有8个子任务（默认情况下，并行度=#个内核）。在执行Eclipse中的代码后，我打开了Flink UI，发现一些子任务没有收到任何记录（空闲）。我希望所有8个子任务都能得到利用（我希望每个子任务都映射到我的主
-
我正在使用这两个实时数据流框架处理器。我找遍了所有的地方，但我找不到这两个框架之间有很大的区别。特别是，我想知道他们是如何工作的基础上的数据或拓扑等大小。
-
Apache Kafka：分布式消息传递系统 Apache Storm：实时消息处理 我们如何在实时数据管道中使用这两种技术来处理事件数据？ 在实时数据管道方面，我觉得两者做的工作是一样的。如何在数据管道上同时使用这两种技术？
-
我做了一个poc，其中我使用spark流从Kafka读取数据。但我们的组织要么使用ApacheFlink，要么使用Kafka消费者从ApacheKafka读取数据，作为标准流程。所以我需要用Kafka消费者或ApacheFlink替换Kafka流媒体。在我的应用程序用例中，我需要从kafka读取数据，过滤json数据并将字段放入cassandra中，因此建议使用kafka consumer而不是f
-
您能说Apache Karaf包括以下内容吗？其中包括： Apache Felix（它是OSGi 4.2框架的实现） Apache Aries（它是Blueprint标准的实现）
-
我们需要的是直接的API来设置和使用集群消息队列。我们最初的计划是使用Camel在集群JMS或ActiveMQ队列上进行消费/生产。Kafka如何使这项任务变得更容易？在任何一种情况下，应用程序本身都将在WebLogic服务器上运行。 消息传递将是点对点类型，其中有多个相同服务的实例在运行，但根据负载平衡策略，只有一个实例应该处理消息并发出结果。消息队列也是群集的，因此服务实例或队列实例的失败都不