阿兹卡班流动参数
如何为每个作业设置流程参数？我试图配置一个自定义警报程序，我希望每个作业都触发它。它看起来像是在从流参数中寻找“alert.type”属性，但现在我只能通过接口触发它。有什么想法吗？
共有1个答案
您可以使用REST API：
curl-k-d flowoverride[alert.type]=my-alerter-d scheduledate=01/30/2017-d scheduledite=03,44,pm,PDT-d is_recurring=off-d projectid=1-d ajax=scheduleflow-d projectname=myproject-d flow=myfroject-b“azkaban.browser.session.id=...”http://localhost:8081/schedule
请注意参数
-
我们的项目中有一个Azkaban属性，类似于，它用作spark作业的参数。命令（在流日志中）已经计算了表达式，但是生成的Azkaban文件（因为这是在gradle中定义的）仍然包含代码字符串。 我找不到任何关于这是如何工作的。谷歌搜索无济于事。文档中没有提到这个功能（关于参数）。
-
我对Apache Hadoop有些陌生。我已经看到了关于Hadoop、HBase、Pig、Hive和HDFS的这个和这个问题。两者都描述了上述技术之间的比较。 但是，我已经看到，Hadoop环境通常包含所有这些组件(HDFS、HBase、Pig、Hive、Azkaban)。 有人能以架构工作流的方式解释那些组件/技术与其在Hadoop环境中的职责之间的关系吗？最好是举个例子？
-
为什么会有例外 静默忽略？我可以看到流在打印后停止，但没有记录任何内容。请注意，问题不是一般的日志配置，因为如果我在我的文件中设置，我会看到很多输出。
-
问题内容： 当我在Android上运行使用Akka的应用程序时，收到以下异常： 在actor系统创建期间抛出此异常： 我以为proguard删除了一个构造函数，所以我在proguard.cfg中添加了以下行： 但这没有帮助。 我究竟做错了什么？ 问题答案： 您的具有以下签名的构造函数之一不公开或不存在：
-
考虑经典的“字数统计”程序。它计算某个目录中所有文件的字数。Master接收一些目录，并在Worker actors之间分割作业(每个Worker处理一个文件)。这是伪代码: 但是我想按计划运行这个字数统计程序(例如每1分钟)，提供不同的目录进行扫描。 Akka为调度消息传递提供了很好的方式: 但上述调度程序的问题始于调度程序按记号发送新消息，但之前的消息尚未处理（例如，我发送消息扫描某个大目录，
-
我正在尝试了解akka流媒体中的toMat。例如： viaMat vs via有什么用 谢谢你，阿伦