R Storm ACK не доходит до носа

Question

Я использую пакет R Storm, написанный Алленом Днем, чтобы представить R-болт в моей топологии. Мне сложно вставить кортеж в R-код. Я уменьшил свой болт R до минимальной работы. Ак никогда не доходит до Спора. Корреспонденты получают повторный ответ после интервала таймаута.

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), похоже, работает. Кортеж немедленно пересматривается. Кроме того, я могу видеть ack, заменив R болт на Java-болт. Кто-нибудь еще сталкивается с этой проблемой?

Answer 1

В пакете R-Storm произошла ошибка в функции ack(). Теперь это исправлено. Делайте git из репо, если вам это нужно.

https://github.com/allenday/R-Storm/blob/master/Storm/R/Storm.R

Любое обновление пакета после того, как этот пост должен иметь исправление.