fixed flb conn retry

Signed-off-by: Tanmaya Panda <[email protected]>
fluent · Jan 30, 2024 · f5a91a5 · f5a91a5
1 parent 2671c89
commit f5a91a5
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 9 deletions.
diff --git a/plugins/out_azure_kusto/azure_kusto.c b/plugins/out_azure_kusto/azure_kusto.c
@@ -140,10 +140,6 @@ flb_sds_t execute_ingest_csl_command(struct flb_azure_kusto *ctx, const char *cs
     /* Get upstream connection */
     u_conn = flb_upstream_conn_get(ctx->u);
 
-    if (!u_conn) {
-	    FLB_OUTPUT_RETURN(FLB_RETRY);
-    }
-
     if (u_conn) {
         token = get_azure_kusto_token(ctx);
 	    flb_plg_debug(ctx->ins, "after get azure kusto token");

diff --git a/plugins/out_azure_kusto/azure_kusto_ingest.c b/plugins/out_azure_kusto/azure_kusto_ingest.c
@@ -156,11 +156,6 @@ static flb_sds_t azure_kusto_create_blob(struct flb_azure_kusto *ctx, flb_sds_t
 
     u_conn = flb_upstream_conn_get(u_node->u);
 
-    if (!u_conn) {
-        flb_plg_error(ctx->ins,"cannot create upstream connection for blob commit");
-        return FLB_RETRY;
-    }
-
     if (u_conn) {
         if (pthread_mutex_lock(&ctx->blob_mutex)) {
             flb_plg_error(ctx->ins, "error unlocking mutex");