@@ -54,8 +54,6 @@ public class CloudSqlMySql implements CdfHelper {
54
54
public static String folderName ;
55
55
List <String > propertiesSchemaColumnList = new ArrayList <>();
56
56
Map <String , String > sourcePropertiesOutputSchema = new HashMap <>();
57
- static int i = 0 ;
58
- GcpClient gcpClient = new GcpClient ();
59
57
int cloudSqlMySqlPreRecordsCount ;
60
58
int cloudSqlMySqlPostRecordsCount ;
61
59
@@ -497,7 +495,7 @@ public void closeTheBigQueryProperties() {
497
495
@ Then ("Get Count of no of records transferred to BigQuery in {string}" )
498
496
public void getCountOfNoOfRecordsTransferredToBigQueryIn (String table ) throws IOException , InterruptedException {
499
497
int countRecords ;
500
- countRecords = gcpClient .countBqQuery (E2ETestUtils .pluginProp (table ));
498
+ countRecords = GcpClient .countBqQuery (E2ETestUtils .pluginProp (table ));
501
499
BeforeActions .scenario .write ("**********No of Records Transferred******************:" + countRecords );
502
500
Assert .assertEquals (countRecords , recordOut ());
503
501
}
@@ -515,7 +513,7 @@ public void validateCountOfRecordsTransferredFromImportQueryToBigQueryIn(String
515
513
516
514
@ Then ("Delete the table {string}" )
517
515
public void deleteTheTable (String table ) throws IOException , InterruptedException {
518
- gcpClient .dropBqQuery (E2ETestUtils .pluginProp (table ));
516
+ GcpClient .dropBqQuery (E2ETestUtils .pluginProp (table ));
519
517
BeforeActions .scenario .write ("Table Deleted Successfully" );
520
518
}
521
519
@@ -794,7 +792,6 @@ public void verifyTheFolderCreatedInWithBucketName(String projectID, String buck
794
792
folderName = E2ETestUtils .listObjects (E2ETestUtils .pluginProp (projectID ),
795
793
E2ETestUtils .pluginProp (bucketName ));
796
794
Assert .assertTrue (folderName != null );
797
-
798
795
}
799
796
800
797
@ Then ("Validate the count of records transferred from BigQuery {string} to CloudSqlMySql {string}" )
0 commit comments