我正在使用allen day编写的r storm包在我的拓扑中引入一个r bolt。我很难在r代码中得到一个元组。我已经减少了我的r螺栓来做最小的工作。ack永远不会到达喷口。元组在达到超时间隔后重试。

executeTuple <- function(s) {
t = s$tuple;

mylist <- as.list(t$input)
s$log(c("ContentID = ", mylist$contentid))

s$ack(t)    
}

storm = Storm$new();
storm$lambda <- executeTuple
storm$run();

另一方面， s$fail(t) 似乎有用。立即重试元组。另外，我可以通过用javabolt替换r bolt来查看ack。还有人面临这个问题吗？