Hi All, I've solved the issue, it is due to TableName variable declared as static in bolt statement and initialized in constructor. In the method prepare() of bolt, it was "null" in DRPC mode because, I suppose, Storm is stateless and so no pointer to static memory is present. I have changed static to private and now works fine. Thanks anyway.
... View more
