input_thead: fixed threaded input processor initialization

Signed-off-by: Eduardo Silva <[email protected]>

Author: Leonardo Alminana

src/flb_input_thread.c

@@ -370,6 +370,16 @@ static void input_thread(void *data)
         return;
     }
 
+    ins->processor->notification_channel = ins->notification_channel;
+
+    ret = flb_processor_init(ins->processor);
+    if (ret == -1) {
+        flb_error("failed initialize processors for input %s",
+                  flb_input_name(ins));
+        input_thread_instance_set_status(ins, FLB_INPUT_THREAD_ERROR);
+        return;
+    }
+
     flb_plg_debug(ins, "[thread init] initialization OK");
     input_thread_instance_set_status(ins, FLB_INPUT_THREAD_OK);