diff --git a/cloudsql-mysql-plugin/src/e2e-test/features/sink/CloudMySqlRunTimeMacro.feature b/cloudsql-mysql-plugin/src/e2e-test/features/sink/CloudMySqlRunTimeMacro.feature
index 717f9dcf5..5ab8b4727 100644
--- a/cloudsql-mysql-plugin/src/e2e-test/features/sink/CloudMySqlRunTimeMacro.feature
+++ b/cloudsql-mysql-plugin/src/e2e-test/features/sink/CloudMySqlRunTimeMacro.feature
@@ -142,7 +142,9 @@ Feature: CloudMySql Sink - Run time scenarios (macro)
     Then Enter runtime argument value "invalidTablename" for key "invalidTablename"
     Then Run the Pipeline in Runtime with runtime arguments
     Then Wait till pipeline is in running state
+    And Open and capture logs
     And Verify the pipeline status is "Failed"
+    And Close the pipeline logs
     Then Open Pipeline logs and verify Log entries having below listed Level and Message:
       | Level | Message                                  |
       | ERROR | errorLogsMessageInvalidTableName         |
@@ -181,7 +183,9 @@ Feature: CloudMySql Sink - Run time scenarios (macro)
     Then Enter runtime argument value "invalidPassword" for key "Password"
     Then Run the Pipeline in Runtime with runtime arguments
     Then Wait till pipeline is in running state
+    And Open and capture logs
     And Verify the pipeline status is "Failed"
+    And Close the pipeline logs
     Then Open Pipeline logs and verify Log entries having below listed Level and Message:
       | Level | Message                                  |
       | ERROR | errorLogsMessageInvalidCredentials       |
diff --git a/cloudsql-mysql-plugin/src/e2e-test/features/source/CloudMySqlRunTime.feature b/cloudsql-mysql-plugin/src/e2e-test/features/source/CloudMySqlRunTime.feature
index b884fa7fa..242e53d5d 100644
--- a/cloudsql-mysql-plugin/src/e2e-test/features/source/CloudMySqlRunTime.feature
+++ b/cloudsql-mysql-plugin/src/e2e-test/features/source/CloudMySqlRunTime.feature
@@ -224,7 +224,9 @@ Feature: CloudMySql Source - Run time scenarios
     Then Deploy the pipeline
     Then Run the Pipeline in Runtime
     Then Wait till pipeline is in running state
+    And Open and capture logs
     And Verify the pipeline status is "Failed"
+    And Close the pipeline logs
     Then Open Pipeline logs and verify Log entries having below listed Level and Message:
       | Level | Message                                  |
       | ERROR | errorLogsMessageInvalidBoundingQuery     |