apache-samza

1热度

1回答

我正在尝试更改Apache Samza的日志记录级别，以便我可以获得debug语句;缺省值是info。更具体地说，我试图让this debug statement出现。我在Clojure项目中使用Samza。做这个的最好方式是什么？ Samza Logging页面没有提供任何有用的信息。

0热度

1回答

纱线没有得到节点

这是在具有2个任务节点和主控的AWS EMR集群中。我在尝试启动纱线作业的hello-samza。这项工作陷入了接受状态。我看了其他帖子，似乎我的纱线没有节点。什么纱线没有获得任务节点的帮助将有所帮助。 [[email protected] hello-samza]$ deploy/yarn/bin/yarn node -list 17/04/18 23:30:45 INFO client.R

0热度

1回答

有没有job.coordinator.system的替代选择

我想使用samza，但是案例是我们的kafka话题的创造是有限的（话题创作应该被审查，并且应该具体具体）。那么，有没有其他的选择“job.coordinator.system”？我需要使用介绍。非常感谢！

0热度

1回答

阿帕奇Samza：入门Samza REST和HELLO-samza

我下面的Apache Samza website的Hello-samza教程，想添加一个REST服务如下所述：http://samza.apache.org/learn/tutorials/latest/samza-rest-getting-started.html 我可以看到在纱线的samza工作UI，但下面的生成指令产生的错误： ./gradlew samza-rest:clean relea

1热度

2回答

如何从本地文件系统和hdfs系统读取Apache Samza中的文件

在Apache Samza中寻找从本地系统或HDFS读取文件的方法然后将过滤器，聚合，条件，排序，分组应用到批处理数据。请提供一些帮助。

2热度

2回答

YARN的Samza在哪里放置KV国家商店？

我需要找到Yarn上的Samza放置其KV国家商店的地方。我怀疑它是在YARN本地应用程序目录中的所有YARN应用程序，但我相信它是可配置的，因为我在几个月前（在不同的环境中映射文件夹到内存）执行此操作，但现在不记得。为了可能，我需要能够将samza KV存储与其他应用程序的其他YARN应用程序数据分开。

0热度

1回答

如何检查KeyValueStore中的所有元素

我有一个KeyValueStore类型的KeyValueStore。我不知道键的范围。有什么方法可以遍历samza中的整个keyvaluest？谢谢

1热度

1回答

您好，Samza得到NullPointException

我没有使用网格脚本来启动HELLO-samza项目http://samza.apache.org/startup/hello-samza/0.11/ 我按照网格脚本步骤下载Hadoop的，卡夫卡&动物园管理员配置动物园管理员，Hadoop的，卡夫卡，因为它在电网脚本执行启动饲养员，纱，卡夫卡，在这个步骤中，可以通过8088端口访问页面纱在浏览器然后我运行该脚本斌/运行 - job.sh -

0热度

1回答

一个samza任务如何能够占用超过一个卡夫卡划分流

我有消耗2个主题典型samza任务：从configdata和config，并将邮件作为rocksdb本地状态，以检查是否从data消息确定。如果这两个主题中的每一个都只有一个分区，则此任务可以正常工作。一旦我将data分为十个分区，config仍然是一个分区，事情就会改变。默认情况下，samza产生10个任务消耗分区0〜9 data的话题，唯一的任务0的消耗config话题： task[0] -

0热度

1回答

你好samza无法在windows 7中正常运行

我做了如http://samza.apache.org/startup/hello-samza/0.13/所示的一切基本上，克隆repo并键入“bin/grid bootstrap”。然而，最后我收到一条错误消息，说zookeeper无法启动，如下所示，有谁知道我该如何解决这个问题，还有什么我应该做的，使其工作？