Traceback (most recent call last): File "C:\Users\stram\Anaconda3\lib\multiprocessing\spawn.py", line 105, in spawn_main File "C:\Users\stram_start_queue_management_thread()
F
(Node.java:187) at com.datatorrent.stram.engine.StreamingContainer.access$100(StreamingContainer.java:130)
at com.datatorrent.stram.engine.StreamingContainer$