diff --git a/Data/BulkLoad/bulk_load.sql b/Data/BulkLoad/bulk_load.sql
index eaf9219..e465e49 100644
--- a/Data/BulkLoad/bulk_load.sql
+++ b/Data/BulkLoad/bulk_load.sql
@@ -21,6 +21,7 @@ BEGIN
   END IF;
 
   IF mip_bulk_load.g_flow_id IS NOT NULL THEN
+    mip_bulk_load.init;   
     mip_bulk_load.load_all;
     mip_bulk_load.report_err;
   ELSE