diff --git a/plugins/out_azure_kusto/azure_kusto.c b/plugins/out_azure_kusto/azure_kusto.c
index 1f3d8a75604..4b42d81bf17 100644
--- 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
index d48170ffeff..deb641c69c2 100644
--- 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");