Hello, there's no such option as of now. If you want to suggest it as a future feature, please raise a Jira.
There's a plethora of ways to do what you want to do, you can e.g. constrain your own code by using e.g. a Guava TimeLimiter (https://guava.dev/releases/ snapshot/api/docs/com/google/common/util/concurrent/TimeLimiter.html). Or you can create a decorator Bolt, TimeLimitedBolt, wrapping your existing bolt and forcing its execute() method to a time limit. Either way, you must make sure the long-running operation responds correctly to thread interruption. PJ ---------- Původní e-mail ---------- Od: Thomas Julian <[email protected]> Komu: user <[email protected]> Datum: 15. 7. 2019 11:12:24 Předmět: Request for configuration to set a processing timeout value for a Bolt " Hello, We want to set a processing time limit for a bolt based on a configuration. Are there any default configurations available in Storm to timeout a bolt? Thanks & Regards, Julian "
