1.Exception in thread "streaming-job-executor-0" java.lang.Error: java.lang.Interrupted...