apache kafka - Spark Streaming jobs exception handling -


in spark streaming(kafka consumer) code have error. implemented exception handling never caught. tried both checked & unchecked exceptions.

my code running in executor. how catch exception when running in executor instead of driver ?

please suggest me.

spark parallel framework. add try catch code in code, exception thrown in other threads. code can not catch exception.


Comments

Popular posts from this blog

ubuntu - PHP script to find files of certain extensions in a directory, returns populated array when run in browser, but empty array when run from terminal -

php - How can i create a user dashboard -

javascript - How to detect toggling of the fullscreen-toolbar in jQuery Mobile? -