Fixed issue #8253

fluent · Dec 11, 2023 · 5404c33 · 5404c33
1 parent e3ea026
commit 5404c33
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/proxy/go/go.c b/src/proxy/go/go.c
@@ -135,11 +135,12 @@ int proxy_go_output_flush(struct flb_plugin_proxy_context *ctx,
     memcpy(buf, tag, tag_len);
     buf[tag_len] = '\0';
 
-    if (plugin->cb_flush_ctx) {
-        ret = plugin->cb_flush_ctx(ctx->remote_context, data, size, buf);
-    }
-    else {
-        ret = plugin->cb_flush(data, size, buf);
+    if (ctx->remote_context != NULL) {
+        if (plugin->cb_flush_ctx) {
+            ret = plugin->cb_flush_ctx(ctx->remote_context, data, size, buf);
+        } else {
+            ret = plugin->cb_flush(data, size, buf);
+        }
     }
     flb_free(buf);
     return ret;