问题标签 [apache-apex]

有人可以帮我理解吗，

apache apex 是否有任何内置的 kafka 输入运算符可以从 Kafka 0.9 安全 kafka 主题中读取？

在运行Kafka-> Apache Apex->Hbase时，它在 Yarn 任务中表示以下异常：

我的 DataTorrent 日志显示以下异常。我正在运行与 Kafka -> Apex -> Hbase 流应用程序通信的应用程序。

添加代码：

LineOutputOperator 扩展 AbstractFileOutputOperator

如何解决这个问题？

谢谢。

是否可以在没有 DataTorrent RTS 的情况下使用 Apache Apex？似乎有可能，但我找不到任何关于安装自己构建的 apex 源的教程（要运行，你需要 leasapex二进制文件）。我看到 Apex CLI 在构建后可用，./engine/src/main/scripts/apex但也许有一些比逐个构建更简单的方法。

如何使用 Apache Apex 创建批处理应用程序？

我发现的所有示例都是流式应用程序，这意味着它们不会结束，我希望我的应用程序在处理完所有数据后关闭。

谢谢

我正在尝试启动 Apache Apex cli，但无法启动。该文件说只是apex在命令提示符下输入，但说No command 'apex' found

在开始使用它之前我需要执行一些前置步骤吗？

我拥有所有可用的先决条件，例如 Hadoop、JDK 7、Git 和 Maven。

我有一个 Apache Apex 应用程序 DAG，它从队列中读取 RabbitMQ 消息。我应该使用哪个 Apache Apex Malhar 运算符？有几个运算符，但不清楚使用哪一个以及如何使用它。

我正在关注与帮助创建启动项目的 Apache Apex 相关的文档。 https://apex.apache.org/docs/apex-3.4/apex_development_setup/#creating-new-apex-project

在执行 maven 命令时，

我面临以下问题。

这个错误的原因是什么？

有没有一种方法，我们可以使用它来预测 Apache Apex 中两个不同运算符之间的 N/W 延迟。

在将要在操作员中使用的数据完全驻留在不同机器上的情况下；这将增加操作员的延迟。

这个怎么计算？

Apex 的所有示例都表明 DAG 的第一个运算符应该是输入运算符。这个算子能否出现在 DAG 中间某处。

考虑一种情况，其中我有数据要从数据库中获取，基于刚刚由前一个运算符处理的一些数据，这意味着输入运算符将出现在 DAG 的中间某处。

根据输入运算符的定义，它是一个没有任何输入流的运算符。但如果使用连接器，它也可以完成获取数据的工作。那么，如果我在 DAG 之间的某个地方获取数据，它会起作用吗？

I've downloaded Apache Apex 3.5.0 along with Malhar 3.5.0.

I've successfully started the apex client and submitted the Yahoo Finance demo example to our YARN cluster (running CDH 5.10). The cluster is running and configured properly (many Spark and MR jobs are running on it).

I see the application I submitted as RUNNING in YARN as well as in the Apex cli. However when I try to connect to the Application Master I get a 404.

I also tried directly to connect to the appMasterTrackingUrl reported by get-app-info command, and I get the same error.

I tried a couple of apex examples, and I always get the same error.

Any idea why?