Added conditional flush logs before data load

Author: datacharmer

employees.sql

@@ -95,7 +95,7 @@ CREATE TABLE salaries (
 ) 
 ; 
 
-flush binary logs;
+flush /*!50503 binary */ logs;
 
 SELECT 'LOADING departments' as 'INFO';
 source load_departments.dump ;

employees_partitioned.sql

@@ -145,6 +145,8 @@ partition by range COLUMNS (from_date)
 )
 */;
 
+flush /*!50503 binary */ logs;
+
 SELECT 'LOADING departments' as 'INFO';
 source load_departments.dump ;
 SELECT 'LOADING employees' as 'INFO';

employees_partitioned_5.1.sql

@@ -167,6 +167,8 @@ partition by range (to_days(from_date))
 )
 */;
 
+flush /*!50503 binary */ logs;
+
 SELECT 'LOADING departments' as 'INFO';
 source load_departments.dump ;
 SELECT 'LOADING employees' as 'INFO';