diff --git a/README.md b/README.md
index 2c01aa7..d83e870 100644
--- a/README.md
+++ b/README.md
@@ -1,2 +1,8 @@
 # SAP
 Collection of SAP pluginis
+
+### E2E automation framework
+For e2e automation execution of SAP plugins, maven profile e2e-tests have been configured. Important note ragrding it:
+1) For it to work, github actions have to be configured (not a special action, just run a below mentioned shell command):
+
+   `/snap/bin/gsutil cp gs://jcoconnector-sapautomation/*.jar ${project.basedir}/src/e2e-test/java/io/cdap/plugin/odp/lib`
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index 8c11ef8..5e35720 100644
--- a/pom.xml
+++ b/pom.xml
@@ -88,6 +88,7 @@
     <olingo.version>4.6.0</olingo.version>
     <olingo2.version>2.0.11</olingo2.version>
     <wiremock.version>1.49</wiremock.version>
+    <testSourceLocation>${project.basedir}/src/test/java/</testSourceLocation>
   </properties>
 
   <dependencies>
@@ -333,6 +334,7 @@
   </dependencies>
 
   <build>
+    <testSourceDirectory>${testSourceLocation}</testSourceDirectory>
     <pluginManagement>
       <plugins>
       </plugins>
@@ -450,6 +452,10 @@
               <consoleOutput>true</consoleOutput>
               <failsOnError>true</failsOnError>
               <includeTestSourceDirectory>true</includeTestSourceDirectory>
+              <testSourceDirectories>
+                <testSourceDirectory>src/test/java</testSourceDirectory>
+                <testSourceDirectory>src/e2e-test/java</testSourceDirectory>
+              </testSourceDirectories>
               <excludes>**/org/apache/cassandra/**,**/org/apache/hadoop/**</excludes>
             </configuration>
             <goals>
@@ -512,4 +518,134 @@
       </plugin>
     </plugins>
   </build>
+
+  <profiles>
+    <profile>
+      <id>e2e-tests</id>
+      <!-- Please refer README.md for a prerequisite to execute this profile -->
+      <properties>
+        <testSourceLocation>src/e2e-test/java</testSourceLocation>
+      </properties>
+      <build>
+        <plugins>
+          <plugin>
+            <groupId>org.apache.maven.plugins</groupId>
+            <artifactId>maven-dependency-plugin</artifactId>
+            <version>3.2.0</version>
+            <executions>
+              <execution>
+                <id>copy-dependencies</id>
+                <phase>package</phase>
+                <goals>
+                  <goal>copy-dependencies</goal>
+                </goals>
+                <configuration>
+                  <outputDirectory>${project.build.directory}</outputDirectory>
+                </configuration>
+              </execution>
+            </executions>
+          </plugin>
+          <plugin>
+            <groupId>org.apache.maven.plugins</groupId>
+            <artifactId>maven-surefire-plugin</artifactId>
+            <version>2.18.1</version>
+            <configuration>
+              <skipTests>true</skipTests>
+            </configuration>
+          </plugin>
+
+          <plugin>
+            <groupId>org.apache.maven.plugins</groupId>
+            <artifactId>maven-failsafe-plugin</artifactId>
+            <version>3.0.0-M5</version>
+            <configuration>
+              <includes>
+                <include>TestRunner.java</include>
+              </includes>
+            </configuration>
+            <executions>
+              <execution>
+                <goals>
+                  <goal>integration-test</goal>
+                </goals>
+              </execution>
+            </executions>
+          </plugin>
+
+          <plugin>
+            <groupId>net.masterthought</groupId>
+            <artifactId>maven-cucumber-reporting</artifactId>
+            <version>5.5.0</version>
+
+            <executions>
+              <execution>
+                <id>execution</id>
+                <phase>verify</phase>
+                <goals>
+                  <goal>generate</goal>
+                </goals>
+                <configuration>
+                  <projectName>Cucumber Reports</projectName> <!-- Replace with project name -->
+                  <outputDirectory>target/cucumber-reports/advanced-reports</outputDirectory>
+                  <buildNumber>1</buildNumber>
+                  <skip>false</skip>
+                  <inputDirectory>${project.build.directory}/cucumber-reports</inputDirectory>
+                  <jsonFiles> <!-- supports wildcard or name pattern -->
+                    <param>**/*.json</param>
+                  </jsonFiles> <!-- optional, defaults to outputDirectory if not specified -->
+                  <classificationDirectory>${project.build.directory}/cucumber-reports</classificationDirectory>
+                  <checkBuildResult>true</checkBuildResult>
+                </configuration>
+              </execution>
+            </executions>
+          </plugin>
+        </plugins>
+      </build>
+      <dependencyManagement>
+        <dependencies>
+          <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>31.0.1-jre</version>
+            <scope>compile</scope>
+          </dependency>
+        </dependencies>
+      </dependencyManagement>
+      <dependencies>
+        <dependency>
+          <groupId>io.cdap.tests.e2e</groupId>
+          <artifactId>cdap-e2e-framework</artifactId>
+          <version>0.0.1-SNAPSHOT</version>
+          <scope>test</scope>
+        </dependency>
+        <dependency>
+          <groupId>org.ehcache</groupId>
+          <artifactId>ehcache</artifactId>
+          <version>3.8.1</version>
+        </dependency>
+        <dependency>
+          <groupId>com.sap.conn.jco</groupId>
+          <artifactId>sapjco3</artifactId>
+          <version>3.0.14</version>
+          <scope>system</scope>
+          <systemPath>${basedir}/src/e2e-test/java/io/cdap/plugin/odp/lib/sapjco3.jar</systemPath>
+        </dependency>
+        <dependency>
+          <groupId>com.sap.conn.idoc</groupId>
+          <artifactId>sapidoc3</artifactId>
+          <version>3.0.12</version>
+          <scope>system</scope>
+          <systemPath>${basedir}/src/e2e-test/java/io/cdap/plugin/odp/lib/sapidoc3.jar</systemPath>
+        </dependency>
+        <dependency>
+          <groupId>com.google.adaptor</groupId>
+          <artifactId>cs</artifactId>
+          <version>0.0.1</version>
+          <scope>system</scope>
+          <systemPath>${basedir}/src/e2e-test/java/io/cdap/plugin/odp/lib/com.google.adapter.cs-0.0.1.jar</systemPath>
+        </dependency>
+      </dependencies>
+
+    </profile>
+  </profiles>
 </project>
diff --git a/src/e2e-test/features/DesignTimeODP.feature b/src/e2e-test/features/DesignTimeODP.feature
new file mode 100644
index 0000000..c01975b
--- /dev/null
+++ b/src/e2e-test/features/DesignTimeODP.feature
@@ -0,0 +1,85 @@
+# Copyright © 2021 Cask Data, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may not
+# use this file except in compliance with the License. You may obtain a copy of
+# the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations under
+# the License.
+Feature: Design Time ODP Scenario
+
+  @ODP @DesignTime-TC-ODP-DSGN-01(Direct)
+  Scenario:User configured direct connection parameters and Security parameters by providing values on SAP UI(ENV)
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsMasterAttr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then Connection is established
+
+  @ODP @DesignTime-TC-ODP-DSGN-01(LOAD)
+  Scenario:User configured Load connection parameters and Security parameters by providing values on SAP UI(ENV)
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When LoadProp "s4Client" "s4AsHost" "s4MsServ" "s4SystemId" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize" "s4Lgrp"
+    When Username and Password is provided
+    Then Connection is established
+
+  @ODP @DesignTime-TC-ODP-DSGN-01.02
+  Scenario: User is able to configure Security parameters using macros in direct connection
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsMasterAttr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    When User has selected Sap client macro to configure
+    Then User is validate without any error
+    When User has selected Sap language macro to configure
+    Then User is validate without any error
+    When User has selected Sap server as host macro to configure
+    Then User is validate without any error
+    When User has selected System Number macro to configure
+    Then User is validate without any error
+    When User has selected datasource macro to configure
+    Then User is validate without any error
+    When User has selected gcsPath macro to configure
+    Then User is validate without any error
+
+  @ODP @DesignTime-TC-ODP-DSGN-01.05
+  Scenario: User is able to configure Security parameters using macros in load connection
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When LoadProp "s4Client" "s4AsHost" "s4MsServ" "s4SystemId" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize" "s4Lgrp"
+    When Username and Password is provided
+    When User has selected Sap msHost macro to configure
+    Then User is validate without any error
+    When User has selected Sap msServ macro to configure
+    Then User is validate without any error
+    When User has selected UserName and Password macro to configure
+    Then User is validate without any error
+
+  @ODP @DesignTime-TC-ODP-DSGN-05.01
+  Scenario:User is able to get the schema of the datasources supporting all the datatype
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then Validate the Schema created
+
+
+  @ODP @DesignTime-TC-ODP-DSGN-09.01
+  Scenario Outline: User is able to get the schema of the SAP Datasource
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    When data source as "<datasource>" is added
+    Then Validate the Schema created
+    Examples:
+      | datasource          |
+      | 2LIS_02_ITM         |
+      | 2LIS_11_VAITM       |
+      | 0MATERIAL_LPRH_HIER |
diff --git a/src/e2e-test/features/DesignTimeODPError.feature b/src/e2e-test/features/DesignTimeODPError.feature
new file mode 100644
index 0000000..4c7e2d6
--- /dev/null
+++ b/src/e2e-test/features/DesignTimeODPError.feature
@@ -0,0 +1,173 @@
+# Copyright © 2021 Cask Data, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may not
+# use this file except in compliance with the License. You may obtain a copy of
+# the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations under
+# the License.
+Feature: User has entered all the details of the connection with below mentioned wrong parameter
+  and by pressing validate button all the parameters are validated and error is thrown.
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if empty referenceName parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    Then "referenceName" as "" and getting "noRefName"
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if empty client parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    Then "jco.client.client" as "" and getting "noJcoClient"
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if empty lang parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then "jco.client.lang" as "" and getting "noJcoLang"
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if empty ashost parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then "jco.client.ashost" as "" and getting "sapAppServerHostRequired"
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if empty sysnr parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then "jco.client.sysnr" as "" and getting "sapSystemNumberRequired"
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if empty sapSourceObjName parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then "sapSourceObjName" as "" and getting "noSapSource"
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if empty user parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then "jco.client.user" as "" and getting "noJcoUser"
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if empty gcsPath parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then "gcsPath" as "" and getting "noGcsPath"
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if wrong client parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then User is able to set parameter "jco.client.client" as "abc" and getting "wrongJcoCLientConfig" for wrong input
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if wrong lang parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then User is able to set parameter "jco.client.lang" as "Eq" and getting "wrongLogonLang" for wrong input
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if wrong ashost parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then User is able to set parameter "jco.client.ashost" as "10.132.0.300" and getting "sapgatewayFailure" for wrong input
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if wrong user parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then User is able to set parameter "jco.client.user" as "invalid" and getting "wrongCreds" for wrong input
+    Then User is able to validate the text box is highlighted
+
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario: User is able to view error messages if wrong gcs parameter is provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then User is able to set parameter "gcsPath" as "gs://invalid" and getting "missingBillingAc" for wrong input
+    Then User is able to validate the text box is highlighted
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario Outline: User is able to view error messages if wrong advanced options are provided
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then User is able to set parameter <option> as <input> and getting row <errorMessage> for wrong input
+    Examples:
+      | option         | input           | errorMessage          |
+      | subscriberName | subscriber-Name | invalidSubscriberName |
+      | numSplits      | -1              | invalidSplits         |
+      | packageSize    | -1              | invalidPackSize       |
+
+  @DesignTime-TC-ODP-DSGN-03.02
+  Scenario Outline: User is able to view error messages if wrong filter options are given
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then User is able to set parameters filterEqualKey as <filterOption> and its filterEqualVal as <query> and getting row <errorMessage> for wrong input
+    Then User is able to validate the text box is highlighted
+    Examples:
+      | filterOption | query    | errorMessage       |
+      | BALANCE      | "&*^%$#" | invalidDSCondition |
+
+  @ODP @DesignTime-TC-ODP-DSGN-03.02
+  Scenario Outline: User is able to view error messages if wrong filter options are given in range
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then User is able to set parameters filterRangeKey as <filterOption> and its filterRangeVal as <query> and getting row <errorMessage> for wrong input
+    Then User is able to validate the text box is highlighted
+    Examples:
+      | filterOption | query     | errorMessage              |
+      | BALANCE      | 10 AND 15 | invalidRangeCondition     |
+      | RYEAR        | 10  15    | invalidDateRangeCondition |
+
+
+
+
diff --git a/src/e2e-test/features/LoadAndDirectConn.feature b/src/e2e-test/features/LoadAndDirectConn.feature
new file mode 100644
index 0000000..dfb21d2
--- /dev/null
+++ b/src/e2e-test/features/LoadAndDirectConn.feature
@@ -0,0 +1,35 @@
+# Copyright © 2021 Cask Data, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may not
+# use this file except in compliance with the License. You may obtain a copy of
+# the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations under
+# the License.
+Feature: Optional Properties
+
+  @LOADnDIR
+  Scenario:Load And Direct Connection EventHandler Trial
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When Configure Connection "s4Client" "s4Sysnr" "s4AsHost" "allTypeDsName" "s4GcsPath" "s4Splitrow" "s4PkgSize" "load.S4msServ" "load.S4systemID" "load.S4Lgrp"
+    When Username and Password is provided
+    Then Validate the Schema created
+    Then Close the ODP Properties
+    Then delete table "tableDemo" in BQ if not empty
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then link source and target
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
diff --git a/src/e2e-test/features/RuntimeODP.feature b/src/e2e-test/features/RuntimeODP.feature
new file mode 100644
index 0000000..1c331e7
--- /dev/null
+++ b/src/e2e-test/features/RuntimeODP.feature
@@ -0,0 +1,236 @@
+# Copyright © 2021 Cask Data, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may not
+# use this file except in compliance with the License. You may obtain a copy of
+# the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations under
+# the License.
+Feature: Run Time E2E
+
+  @ODP @RunTime-TC-ODP-RNTM-07-01
+  Scenario:User configured Load connection parameters and Security parameters by providing values on SAP UI(ENV)
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When LoadProp "s4Client" "s4AsHost" "s4MsServ" "s4SystemId" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize" "s4Lgrp"
+    When Username and Password is provided
+    Then Validate the Schema created
+    Then Close the ODP Properties
+    Then delete table "tableDemo" in BQ if not empty
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then link source and target
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the full load transfer is successful
+    Then Reset the parameters
+
+
+  @ODP @RunTime-TC-ODP-RNTM-01(Direct)
+  Scenario: Multi subscriber Create Update Delete 2LIS_02_HDR
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsHdr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    When Subscriber is entered
+    When Run one Mode is Sync mode
+    Then Validate the Schema created
+    Then Close the ODP Properties
+    Then delete table "tableDemo" in BQ if not empty
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then link source and target
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the full load transfer is successful
+    Then "Create" the "4" records with "rfc_2LIS_02_HDR" in the ODP datasource from JCO
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsHdr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    When Subscriber is entered
+    When Run one Mode is Sync mode
+    Then Validate the Schema created
+    Then Close the ODP Properties
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then link source and target
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline to capture delta logs
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the Delta load transfer is successful in "tableDemo" on basis of "EBELN"
+    Then "update" the "4" records with "rfc_2LIS_02_HDR" in the ODP datasource from JCO
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsHdr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    When Subscriber is entered
+    When Run one Mode is Sync mode
+    Then Validate the Schema created
+    Then Close the ODP Properties
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then link source and target
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline to capture delta logs
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the Delta load transfer is successful in "tableDemo" on basis of "EBELN"
+    Then "delete" the "4" records with "rfc_2LIS_02_HDR" in the ODP datasource from JCO
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsHdr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    When Subscriber is entered
+    When Run one Mode is Sync mode
+    Then Validate the Schema created
+    Then Close the ODP Properties
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then link source and target
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline to capture delta logs
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the Delta load transfer is successful in "tableDemo" on basis of "EBELN"
+    Then Reset the parameters
+
+  @ODP @RunTime-TC-ODP-RNTM-03-00
+  Scenario: All the supported data types are getting to BQ
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsAllDataType" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    Then Validate the Schema created
+    Then Close the ODP Properties
+    Then delete table "tableDemo" in BQ if not empty
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then link source and target
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the full load transfer is successful
+    Then Reset the parameters
+
+
+  @ODP @RunTime-TC-ODP-RNTM-09-02(Deletion)
+   Scenario: Validate creation and deletion delta data data picked up in master attribute datasource
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsMasterAttr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    When Run one Mode is Sync mode
+    Then Validate the Schema created
+    Then Close the ODP Properties
+    Then delete table "tableDemo" in BQ if not empty
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then link source and target
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the full load transfer is successful
+    Then Close the log window
+    Then "create" the "10" records with "rfc_matnr" in the ODP datasource from JCO
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is successful again
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then Open Logs of ODP Pipeline to capture delta logs
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the Delta load transfer is successful in "tableDemo" on basis of "MATNR"
+    Then Close the log window
+    Then "delete" the "10" records with "rfc_matnr" in the ODP datasource from JCO
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is successful again
+    Then Open Logs of ODP Pipeline to capture delta logs
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the Delta load transfer is successful in "tableDemo" on basis of "MATNR"
+    Then Close the log window
+    Then Reset the parameters
+
+  @ODP @RunTime-TC-ODP-RNTM-09-02(update)
+  Scenario: validate updated delta data data can be picked up in master attribute datasource
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsMasterAttr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username and Password is provided
+    When Run one Mode is Sync mode
+    Then Validate the Schema created
+    Then Close the ODP Properties
+    Then delete table "tableDemo" in BQ if not empty
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then link source and target
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the full load transfer is successful
+    Then Close the log window
+    Then "create" the "10" records with "rfc_matnr" in the ODP datasource from JCO
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is successful again
+    Then Open Logs of ODP Pipeline to capture delta logs
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the Delta load transfer is successful in "tableDemo" on basis of "MATNR"
+    Then Close the log window
+    Then "update" the "10" records with "rfc_matnr" in the ODP datasource from JCO
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is successful again
+    Then Open Logs of ODP Pipeline to capture delta logs
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the Delta load transfer is successful in "tableDemo" on basis of "MATNR"
+    Then Close the log window
+    Then Reset the parameters
diff --git a/src/e2e-test/features/SecureODP.feature b/src/e2e-test/features/SecureODP.feature
new file mode 100644
index 0000000..dcfe856
--- /dev/null
+++ b/src/e2e-test/features/SecureODP.feature
@@ -0,0 +1,81 @@
+# Copyright © 2021 Cask Data, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may not
+# use this file except in compliance with the License. You may obtain a copy of
+# the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations under
+# the License.
+@Security
+Feature: Secured macros can be configured and used for the login credentials
+
+  @ODP @Security-TC-ODP-SECU-01
+  Scenario: User is able to configure security macros with auth user and no errors while validating the credentials plus connection parameter
+    Given Open "httpCall" link to configure macros
+    Then Select "PUT" service to configure
+    Then enter variable for "testuserqa" of the macro
+    Then enter the "AUTH_USERNAME" of the service username and password
+    Then send request and verify success message
+    Then enter variable for "testpasswordqa" of the macro
+    Then enter the "AUTH_PASSWORD" of the service username and password
+    Then send request and verify success message
+    Then enter variable for "testjcoclient" of the macro
+    Then enter the "macroS4_jco_client" of the service
+    Then send request and verify success message
+    Then enter variable for "testjcoserver" of the macro
+    Then enter the "macroS4_jco_server" of the service
+    Then send request and verify success message
+    Then enter variable for "testjcosysnr" of the macro
+    Then enter the "macroS4_jco_sysnr" of the service
+    Then send request and verify success message
+    Then enter variable for "testjcodatasourcename" of the macro
+    Then enter the "macroS4_jco_DataSourceName" of the service
+    Then send request and verify success message
+    Then enter variable for "testjcosplit" of the macro
+    Then enter the "macroS4_jco_split" of the service
+    Then send request and verify success message
+    Then enter variable for "testjcopackagesize" of the macro
+    Then enter the "macroS4_jco_packageSize" of the service
+    Then send request and verify success message
+    Then enter variable for "testgcspath" of the macro
+    Then enter the "macroS4_jco_gcspath" of the service
+    Then send request and verify success message
+    Then enter variable for "testlang" of the macro
+    Then enter the "macroS4_jco_lang" of the service
+    Then send request and verify success message
+    Then enter variable for "testloadtype" of the macro
+    Then enter the "macroS4_jco_load" of the service
+    Then send request and verify success message
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    Then link source and target
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsHdr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    Then enter the secured created variable
+    Then Close the ODP Properties
+    Then Enter the BigQuery Properties for ODP datasource "tableDemo"
+    Then Close the BQ Properties
+    Then Save and Deploy ODP Pipeline
+    Then Run the ODP Pipeline in Runtime
+    Then Wait till ODP pipeline is in running state
+    Then Open Logs of ODP Pipeline
+    Then Verify the ODP pipeline status is "Succeeded"
+    Then validate successMessage is displayed for the ODP pipeline
+    Then Get Count of no of records transferred from ODP to BigQuery in "tableDemo"
+    Then Verify the full load transfer is successful
+
+  @ODP @Security-TS-ODP-SECU-06
+  Scenario: Unauthorized user gets an Error message on trying to initiate data transfer  (User dont have access to RFC)
+    Given Open CDF application to configure pipeline
+    When Source is SAP ODP
+    When Target is BigQuery for ODP data transfer
+    When Configure Direct Connection "s4Client" "s4Sysnr" "s4AsHost" "dsHdr" "s4GcsPath" "s4Splitrow" "s4PkgSize"
+    When Username "testNoAuthUsername" and Password "testNoAuthPwd" is provided
+    When Run one Mode is Sync mode
+    Then RFC auth error is displayed "rfcError"
+    Then User is able to validate the error no auth error
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/actions/ODPActions.java b/src/e2e-test/java/io/cdap/plugin/odp/actions/ODPActions.java
new file mode 100644
index 0000000..5ff8ff5
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/actions/ODPActions.java
@@ -0,0 +1,126 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.actions;
+
+import io.cdap.e2e.utils.SeleniumDriver;
+import io.cdap.e2e.utils.SeleniumHelper;
+import io.cdap.plugin.odp.locators.ODPLocators;
+import io.cdap.plugin.odp.utils.CDAPUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.openqa.selenium.JavascriptExecutor;
+import org.openqa.selenium.support.PageFactory;
+
+import java.io.IOException;
+import java.util.UUID;
+
+/**
+ * ODPActions.
+ */
+public class ODPActions {
+  public static ODPLocators odpLocators;
+  private static JavascriptExecutor js;
+
+  static {
+    js = (JavascriptExecutor) SeleniumDriver.getDriver();
+    odpLocators = SeleniumHelper.getPropertiesLocators(ODPLocators.class);
+  }
+
+  public static void selectODPSource() {
+    odpLocators.sapODPSource.click();
+  }
+
+  public static void getODPProperties() {
+    odpLocators.sapODPProperties.click();
+  }
+
+  public static void enterConnectionProperties(
+    String client, String sysnr, String asHost, String dsName, String gcsPath, String splitRow,
+    String packSize, String msServ, String systemID, String lgrp) throws IOException, InterruptedException {
+    odpLocators.referenceName.sendKeys(UUID.randomUUID().toString());
+    odpLocators.sapClient.sendKeys(CDAPUtils.getPluginProp(client));
+    if (null != CDAPUtils.getPluginProp(msServ)) {
+      /*For load connection*/
+      odpLocators.loadServer.click();
+      odpLocators.msHost.sendKeys(null != CDAPUtils.getPluginProp(asHost) ?
+                                    CDAPUtils.getPluginProp(asHost) : StringUtils.EMPTY);
+      odpLocators.portNumber.sendKeys(null != CDAPUtils.getPluginProp(msServ) ?
+                                        CDAPUtils.getPluginProp(msServ) : StringUtils.EMPTY);
+      odpLocators.systemID.sendKeys(null != CDAPUtils.getPluginProp(systemID) ?
+                                      CDAPUtils.getPluginProp(systemID) : StringUtils.EMPTY);
+      odpLocators.logonGroup.sendKeys(null != CDAPUtils.getPluginProp(lgrp) ?
+                                        CDAPUtils.getPluginProp(lgrp) : StringUtils.EMPTY);
+    } else {
+      /*For direct connection*/
+      odpLocators.systemNumber.sendKeys(CDAPUtils.getPluginProp(sysnr));
+      odpLocators.sapApplicationServerHost.sendKeys(CDAPUtils.getPluginProp(asHost));
+    }
+    odpLocators.dataSourceName.sendKeys(CDAPUtils.getPluginProp(dsName));
+    js.executeScript("window.scrollBy(0,350)", StringUtils.EMPTY);
+    odpLocators.gcsPath.sendKeys(CDAPUtils.getPluginProp(gcsPath));
+    odpLocators.splitRow.sendKeys(CDAPUtils.getPluginProp(splitRow));
+    odpLocators.packageSize.sendKeys(null != CDAPUtils.getPluginProp(packSize) ?
+                                       CDAPUtils.getPluginProp(packSize) : StringUtils.EMPTY);
+  }
+
+  public static void enterDirectConnectionProperties(String client, String sysnr, String asHost, String dsName
+    , String gcsPath, String splitRow, String packSize) throws IOException, InterruptedException {
+    odpLocators.referenceName.sendKeys(UUID.randomUUID().toString());
+    odpLocators.sapClient.sendKeys(CDAPUtils.getPluginProp(client));
+    odpLocators.systemNumber.sendKeys(CDAPUtils.getPluginProp(sysnr));
+    odpLocators.sapApplicationServerHost.sendKeys(CDAPUtils.getPluginProp(asHost));
+    odpLocators.dataSourceName.sendKeys(CDAPUtils.getPluginProp(dsName));
+    js.executeScript("window.scrollBy(0,350)", StringUtils.EMPTY);
+    odpLocators.gcsPath.sendKeys(CDAPUtils.getPluginProp(gcsPath));
+    odpLocators.splitRow.sendKeys(CDAPUtils.getPluginProp(splitRow));
+    odpLocators.packageSize.sendKeys(null != CDAPUtils.getPluginProp(packSize) ?
+                                       CDAPUtils.getPluginProp(packSize) : StringUtils.EMPTY);
+  }
+
+  public static void enterLoadConnectionProperties(String client, String asHost, String msServ, String systemID,
+                                                   String lgrp, String dsName, String gcsPath, String splitrow,
+                                                   String packageSize) throws IOException, InterruptedException {
+    odpLocators.referenceName.sendKeys(UUID.randomUUID().toString());
+    odpLocators.sapClient.sendKeys(CDAPUtils.getPluginProp(client));
+    odpLocators.loadServer.click();
+    odpLocators.msHost.sendKeys(CDAPUtils.getPluginProp(asHost));
+    odpLocators.portNumber.sendKeys(CDAPUtils.getPluginProp(msServ));
+    odpLocators.systemID.sendKeys(CDAPUtils.getPluginProp(systemID));
+    odpLocators.logonGroup.sendKeys(CDAPUtils.getPluginProp(lgrp));
+    odpLocators.dataSourceName.sendKeys(CDAPUtils.getPluginProp(dsName));
+
+    js.executeScript("window.scrollBy(0,350)", StringUtils.EMPTY);
+    odpLocators.gcsPath.sendKeys(CDAPUtils.getPluginProp(gcsPath));
+    odpLocators.splitRow.sendKeys(CDAPUtils.getPluginProp(splitrow));
+    odpLocators.packageSize.sendKeys(CDAPUtils.getPluginProp(packageSize));
+  }
+
+  public static void enterUserNamePassword(String username, String password) throws IOException {
+    odpLocators.usernameCredentials.sendKeys(username);
+    odpLocators.passwordCredentials.sendKeys(password);
+  }
+
+  public static void selectSync() {
+    odpLocators.syncRadio.click();
+  }
+
+  public static void getSchema() {
+    odpLocators.getSchemaButton.click();
+  }
+
+  public static void closeButton() {
+    odpLocators.closeButton.click();
+  }
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/actions/package-info.java b/src/e2e-test/java/io/cdap/plugin/odp/actions/package-info.java
new file mode 100644
index 0000000..b135572
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/actions/package-info.java
@@ -0,0 +1,19 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * contains ODP actions.
+ */
+package io.cdap.plugin.odp.actions;
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/locators/ODPLocators.java b/src/e2e-test/java/io/cdap/plugin/odp/locators/ODPLocators.java
new file mode 100644
index 0000000..524b52d
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/locators/ODPLocators.java
@@ -0,0 +1,203 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.locators;
+
+import org.openqa.selenium.WebElement;
+import org.openqa.selenium.support.FindBy;
+import org.openqa.selenium.support.How;
+
+import java.util.List;
+
+/**
+ * ODPLocators.
+ */
+public class ODPLocators {
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"plugin-SapOdp-batchsource\"]")
+  public static WebElement sapODPSource;
+
+  @FindBy(how = How.XPATH, using = "//*[@title=\"SAP ODP\"]/following-sibling::div")
+  public static WebElement sapODPProperties;
+
+  @FindBy(how = How.XPATH, using = "//*[@placeholder='Name used to identify this source for lineage']")
+  public static WebElement referenceName;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='project' and @class='MuiInputBase-input']")
+  public static WebElement projectID;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='jco.client.client' and @class='MuiInputBase-input']")
+  public static WebElement sapClient;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='jco.client.sysnr' and @class='MuiInputBase-input']")
+  public static WebElement systemNumber;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='gcsPath' and @class='MuiInputBase-input']")
+  public static WebElement gcsPath;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='jco.client.ashost' and @class='MuiInputBase-input']")
+  public static WebElement sapApplicationServerHost;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='sapSourceObjName' and @class='MuiInputBase-input']")
+  public static WebElement dataSourceName;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='numSplits' and @class='MuiInputBase-input']")
+  public static WebElement splitRow;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='packageSize' and @class='MuiInputBase-input']")
+  public static WebElement packageSize;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='jco.client.user' and @class='MuiInputBase-input']")
+  public static WebElement usernameCredentials;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='jco.client.passwd' and  @type='password']")
+  public static WebElement passwordCredentials;
+
+  @FindBy(how = How.XPATH, using = "//*[contains(text(),'Get Schema')]")
+  public static WebElement getSchemaButton;
+
+  @FindBy(how = How.XPATH, using = "//*[@name='extractType' and @value='Sync']")
+  public static WebElement syncRadio;
+
+  @FindBy(how = How.XPATH, using = "//*[@class='fa fa-remove']")
+  public static WebElement closeButton;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='plugin-endpoint-SapOdp-batchsource-right']")
+  public static WebElement fromODP;
+
+  @FindBy(how = How.XPATH, using = "//*[@value='msgServer']")
+  public static WebElement loadServer;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.mshost\" and @type='text']")
+  public static WebElement msHost;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.msserv\" and @type='text']")
+  public static WebElement portNumber;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='jco.client.r3name' and @class='MuiInputBase-input']")
+  public static WebElement systemID;
+
+  @FindBy(how = How.XPATH, using = "//*[contains(text(),'M') and contains(@class,'jss')]")
+  public static List<WebElement> macros;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='plugin-properties-validate-btn']")
+  public static WebElement validateButton;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='plugin-validation-success-msg']")
+  public static WebElement pluginValidationSuccessMessage;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='jco.client.lang' and @class='MuiInputBase-input']")
+  public static WebElement language;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.group\" and @type='text']")
+  public static WebElement logonGroup;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='property-row-error']")
+  public static WebElement rowError;
+
+  @FindBy(how = How.XPATH, using = "//*[contains(text(),\"SAP connection test failed\")]")
+  public static WebElement mainStreamError;
+
+  @FindBy(how = How.XPATH, using = "//*[@class=\"text-danger\"]")
+  public static WebElement jcoError;
+
+  @FindBy(how = How.XPATH, using = "(//*[@data-cy='filterOptionsRange'])[2]/div/div/div[1]/input")
+  public static WebElement filterRangeKey;
+
+  @FindBy(how = How.XPATH, using = "(//*[@data-cy='filterOptionsRange'])[2]")
+  public static WebElement filterRangeMacros;
+
+  @FindBy(how = How.XPATH, using = "//*[@placeholder=\"'ACT-DCD-00' AND 'ACT-DCD-12'\"]")
+  public static WebElement filterRangeVal;
+
+  @FindBy(how = How.XPATH, using = "(//*[@data-cy=\"filterOptionsEq\"])[2]/div/div/div[1]/input")
+  public static WebElement filterEqualKey;
+
+  @FindBy(how = How.XPATH, using = "//*[@placeholder=\"'FERT'\"]")
+  public static WebElement filterEqualVal;
+
+  @FindBy(how = How.XPATH, using = "(//*[@data-cy='filterOptionsEq'])[2]")
+  public static WebElement filterEqualMacros;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='jco.client.passwd' and  @type='text']")
+  public static WebElement macroPass;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='extractType' and @class='MuiInputBase-input']")
+  public static WebElement extractType;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='jco.client.saprouter' and  @type='text']")
+  public static WebElement sapRouter;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='gcpProjectId' and  @type='text']")
+  public static WebElement gcsProjectID;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy='subscriberName' and  @type='text']")
+  public static WebElement subsName;
+
+  /* macros */
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.client\"]//child::button//span//span//strong")
+  public static WebElement macroSapClient;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.lang\"]//child::button//span//span//strong")
+  public static WebElement macroSapLanguage;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.ashost\"]//child::button//span//span//strong")
+  public static WebElement macroSapASHost;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.mshost\"]//child::button//span//span//strong")
+  public static WebElement macroSapMSHost;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.sysnr\"]//child::button//span//span//strong")
+  public static WebElement macroSapSysNumber;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.saprouter\"]//child::button//span//span//strong")
+  public static WebElement macroSapRouter;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.msserv\"]//child::button//span//span//strong")
+  public static WebElement macroSapMsserv;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"sapSourceObjName\"]//child::button//span//span//strong")
+  public static WebElement macroSapDsName;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"extractType\"]//child::button//span//span//strong")
+  public static WebElement macroSapExtractType;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.user\"]//child::button//span//span//strong")
+  public static WebElement macroSapUserName;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"jco.client.passwd\"]//child::button//span//span//strong")
+  public static WebElement macroSapUserPazwrd;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"gcpProjectId\"]//child::button//span//span//strong")
+  public static WebElement macroSapGcsProjId;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"gcsPath\"]//child::button//span//span//strong")
+  public static WebElement macroSapGcsPath;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"subscriberName\"]//child::button//span//span//strong")
+  public static WebElement macroSapSubsName;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"filterOptionsEq\"]//child::button//span//span//strong")
+  public static WebElement macroFilterOptionEqual;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"filterOptionsRange\"]//child::button//span//span//strong")
+  public static WebElement macroFilterOptionRange;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"numSplits\"]//child::button//span//span//strong")
+  public static WebElement macroSplits;
+
+  @FindBy(how = How.XPATH, using = "//*[@data-cy=\"packageSize\"]//child::button//span//span//strong")
+  public static WebElement macroPackSize;
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/locators/package-info.java b/src/e2e-test/java/io/cdap/plugin/odp/locators/package-info.java
new file mode 100644
index 0000000..d8dd421
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/locators/package-info.java
@@ -0,0 +1,19 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * contains ODP locators.
+ */
+package io.cdap.plugin.odp.locators;;
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/DesignTimeODP.java b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/DesignTimeODP.java
new file mode 100644
index 0000000..2402374
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/DesignTimeODP.java
@@ -0,0 +1,121 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.stepsdesign;
+
+import io.cdap.e2e.pages.actions.CdfGcsActions;
+import io.cdap.e2e.utils.SeleniumDriver;
+import io.cdap.e2e.utils.SeleniumHelper;
+import io.cdap.plugin.odp.actions.ODPActions;
+import io.cdap.plugin.odp.locators.ODPLocators;
+import io.cdap.plugin.odp.utils.CDAPUtils;
+import io.cucumber.java.en.Then;
+import io.cucumber.java.en.When;
+import org.junit.Assert;
+import org.openqa.selenium.By;
+import org.openqa.selenium.support.ui.ExpectedConditions;
+import org.openqa.selenium.support.ui.WebDriverWait;
+
+import java.io.IOException;
+
+/**
+ * DesignTimeODP.
+ */
+public class DesignTimeODP {
+
+  @Then("Connection is established")
+  public void connectionIsEstablished() throws InterruptedException {
+    CdfGcsActions.getSchema();
+    WebDriverWait wait = new WebDriverWait(SeleniumDriver.getDriver(), 20000);
+    wait.until(ExpectedConditions.numberOfElementsToBeMoreThan(By.xpath("//*[@placeholder=\"Field name\"]"), 2));
+    Assert.assertEquals(true, CDAPUtils.schemaValidation());
+  }
+
+  @When("LoadProp {string} {string} {string} {string} {string} {string} {string} {string} {string}")
+  public void loadConnection(String client, String asHost, String msServ, String systemID, String dsName,
+                             String gcsPath, String splitRow, String pkgSize, String lgrp)
+    throws IOException, InterruptedException {
+    ODPActions.getODPProperties();
+    ODPActions.enterLoadConnectionProperties(
+      client, asHost, msServ, systemID, lgrp, dsName, gcsPath, splitRow, pkgSize);
+  }
+
+  @When("User has selected Sap client macro to configure")
+  public void userHasSelectedSapClientMacroToConfigure() {
+    ODPLocators.macroSapClient.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.sapClient, "${client}");
+  }
+
+  @Then("User is validate without any error")
+  public void userIsValidateWithoutAnyError() throws InterruptedException {
+    ODPLocators.validateButton.click();
+    Assert.assertTrue(ODPLocators.pluginValidationSuccessMessage.isDisplayed());
+  }
+
+  @When("User has selected Sap language macro to configure")
+  public void userHasSelectedSapLagMacroToConfigure() {
+    ODPLocators.macroSapLanguage.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.language, "${lang}");
+  }
+
+  @When("User has selected Sap server as host macro to configure")
+  public void userHasSelectedSapServerAsHostMacroToConfigure() {
+    ODPLocators.macroSapASHost.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.sapApplicationServerHost, "${host}");
+  }
+
+  @When("User has selected System Number macro to configure")
+  public void userHasSelectedSystemNumberMacroToConfigure() {
+    ODPLocators.macroSapSysNumber.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.systemNumber, "${sysnr}");
+  }
+
+  @When("User has selected datasource macro to configure")
+  public void userHasSelectedDatasourceMacroToConfigure() {
+    ODPLocators.macroSapDsName.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.dataSourceName, "${dsname}");
+  }
+
+  @When("User has selected gcsPath macro to configure")
+  public void userHasSelectedGcsPathMacroToConfigure() {
+    ODPLocators.macroSapGcsPath.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.gcsPath, "${gcs}");
+  }
+
+  @When("User has selected Sap msHost macro to configure")
+  public void userHasSelectedSapMsHostMacroToConfigure() {
+    ODPLocators.macroSapMSHost.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.msHost, "${msHost}");
+  }
+
+  @When("User has selected Sap msServ macro to configure")
+  public void userHasSelectedSapMsServMacroToConfigure() {
+    ODPLocators.macroSapMsserv.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.portNumber, "${portNo}");
+  }
+
+  @When("User has selected UserName and Password macro to configure")
+  public void userHasSelectedUserNameAndPasswordMacroToConfigure() {
+    ODPLocators.macroSapGcsPath.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.usernameCredentials, "${userName}");
+  }
+
+  @When("data source as {string} is added")
+  public void dataSourceAsIsAdded(String datasource) throws InterruptedException {
+    SeleniumHelper.replaceElementValue(ODPLocators.dataSourceName, datasource);
+    ODPLocators.validateButton.click();
+    ODPLocators.pluginValidationSuccessMessage.isDisplayed();
+  }
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/DesignTimeODPError.java b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/DesignTimeODPError.java
new file mode 100644
index 0000000..d136e76
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/DesignTimeODPError.java
@@ -0,0 +1,121 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.stepsdesign;
+
+import io.cdap.e2e.utils.SeleniumDriver;
+import io.cdap.plugin.odp.locators.ODPLocators;
+import io.cdap.plugin.odp.utils.CDAPUtils;
+import io.cucumber.java.en.Then;
+import org.junit.Assert;
+import org.openqa.selenium.By;
+import org.openqa.selenium.Keys;
+import org.openqa.selenium.WebElement;
+import stepsdesign.BeforeActions;
+
+/**
+ * DesignTimeODPError.
+ */
+public class DesignTimeODPError {
+  static boolean errorExist = false;
+  static String color;
+
+  @Then("{string} as {string} and getting {string}")
+  public void userIsAbleToSetParameterAsAndGettingErrorMessage(String configParam, String input, String errorMessage) {
+    WebElement elementIn = SeleniumDriver.getDriver().findElement(
+      By.xpath("//*[@data-cy='" + configParam + "' and @class='MuiInputBase-input']"));
+    CDAPUtils.clearField(elementIn);
+    ODPLocators.validateButton.click();
+    color = ODPLocators.rowError.getCssValue("border-color");
+    errorExist = CDAPUtils.getErrorProp(errorMessage).toLowerCase().contains(ODPLocators.rowError.getText()
+                                                                               .toLowerCase());
+    Assert.assertTrue(errorExist);
+  }
+
+  @Then("User is able to set parameter {string} as {string} and getting {string} for wrong input")
+  public void userIsAbleToSetParameterAsAndGettingForWrongInput(String element, String input, String errorMessage) {
+    errorExist = false;
+    WebElement elementIn = SeleniumDriver.getDriver().findElement(
+      By.xpath("//*[@data-cy='" + element + "' and @class='MuiInputBase-input']"));
+    CDAPUtils.clearField(elementIn);
+    elementIn.sendKeys(input);
+    ODPLocators.validateButton.click();
+    errorExist = CDAPUtils.getErrorProp(errorMessage).toLowerCase().contains(ODPLocators.jcoError.getText()
+                                                                               .toLowerCase());
+    Assert.assertTrue(errorExist);
+  }
+
+  @Then("User is able to set parameter {string} as {string} and getting {string} for wrong input of password")
+  public void userIsAbleToSetParameterAsAndGettingForWrongInputOfPassword(String element, String input1,
+                                                                          String errorMessage) {
+    errorExist = false;
+    WebElement elementPass = SeleniumDriver.getDriver().findElement(
+      By.xpath("//*[@data-cy='" + element + "' and @type='password']"));
+    CDAPUtils.clearField(elementPass);
+    ODPLocators.validateButton.click();
+    errorExist = CDAPUtils.getErrorProp(errorMessage).toLowerCase().contains(ODPLocators.jcoError.getText()
+                                                                               .toLowerCase());
+    color = ODPLocators.rowError.getCssValue("border-color");
+    Assert.assertTrue(errorExist);
+  }
+
+  @Then("^User is able to set parameter (.+) as (.+) and getting row (.+) for wrong input$")
+  public void userIsAbleToSetParameterAsAndGettingRowForWrongInput(
+    String option, String input, String errorMessage) {
+    errorExist = false;
+    WebElement element = SeleniumDriver.getDriver().findElement(
+      By.xpath("//*[@data-cy='" + option + "' and @class='MuiInputBase-input']"));
+    CDAPUtils.clearField(element);
+    SeleniumDriver.getDriver().findElement(By.xpath("//*[@data-cy='" + option + "' and @class='MuiInputBase-input']")).
+      sendKeys(input);
+    ODPLocators.validateButton.click();
+    errorExist = CDAPUtils.getErrorProp(errorMessage).toLowerCase().contains(ODPLocators.rowError.getText()
+                                                                               .toLowerCase());
+    color = ODPLocators.rowError.getCssValue("border-color");
+    Assert.assertTrue(errorExist);
+    BeforeActions.scenario.write("Color of the text box" + color);
+    Assert.assertTrue(color.toLowerCase().contains("rgb(164, 4, 3)"));
+  }
+
+  @Then("^User is able to set parameters filterEqualKey as (.+) and its filterEqualVal " +
+    "as (.+) and getting row (.+) for wrong input$")
+  public void userIsAbleToSetParametersFilterequalkeyAsAndItsFilterequalvalAsAndGettingError
+    (String filterOption, String query, String errorMessage) throws Throwable {
+    errorExist = false;
+    ODPLocators.filterEqualKey.sendKeys(filterOption);
+    ODPLocators.filterEqualVal.sendKeys(query);
+    ODPLocators.validateButton.click();
+    errorExist = ODPLocators.rowError.getText().toLowerCase().contains(CDAPUtils.getErrorProp(errorMessage)
+                                                                         .toLowerCase());
+    color = ODPLocators.rowError.getCssValue("border-color");
+    Assert.assertTrue(errorExist);
+  }
+
+  @Then("User is able to validate the text box is highlighted")
+  public void userIsAbleToValidateTheTextBoxIsHighlighted() {
+    BeforeActions.scenario.write("Color of the text box" + color);
+    Assert.assertTrue(color.toLowerCase().contains("rgb(164, 4, 3)"));
+  }
+
+  @Then("^User is able to set parameters filterRangeKey as (.+) and its filterRangeVal " +
+    "as (.+) and getting row (.+) for wrong input$")
+  public void filterRangeKeyAsFilterOptionAndItsFilterRangeValAsQueryAndGettingRowErrorMessageForWrongInput
+    (String filterOption, String query, String errorMessage) throws Throwable {
+    ODPLocators.filterRangeKey.sendKeys(filterOption);
+    ODPLocators.filterRangeVal.sendKeys(query);
+    ODPLocators.validateButton.click();
+    color = ODPLocators.rowError.getCssValue("border-color");
+  }
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/RuntimeODP.java b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/RuntimeODP.java
new file mode 100644
index 0000000..2bd6ba5
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/RuntimeODP.java
@@ -0,0 +1,400 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.stepsdesign;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.google.adapter.connector.SAPAdapterImpl;
+import com.google.adapter.connector.SAPProperties;
+import com.google.adapter.exceptions.SystemException;
+import com.google.adapter.util.ErrorCapture;
+import com.google.adapter.util.ExceptionUtils;
+import com.sap.conn.jco.JCoException;
+import io.cdap.e2e.pages.actions.CdfBigQueryPropertiesActions;
+import io.cdap.e2e.pages.actions.CdfGcsActions;
+import io.cdap.e2e.pages.actions.CdfLogActions;
+import io.cdap.e2e.pages.actions.CdfPipelineRunAction;
+import io.cdap.e2e.pages.actions.CdfStudioActions;
+import io.cdap.e2e.pages.locators.CdfBigQueryPropertiesLocators;
+import io.cdap.e2e.pages.locators.CdfPipelineRunLocators;
+import io.cdap.e2e.pages.locators.CdfStudioLocators;
+import io.cdap.e2e.utils.CdfHelper;
+import io.cdap.e2e.utils.GcpClient;
+import io.cdap.e2e.utils.SeleniumDriver;
+import io.cdap.e2e.utils.SeleniumHelper;
+import io.cdap.plugin.odp.actions.ODPActions;
+import io.cdap.plugin.odp.locators.ODPLocators;
+import io.cdap.plugin.odp.utils.CDAPUtils;
+import io.cucumber.java.en.Given;
+import io.cucumber.java.en.Then;
+import io.cucumber.java.en.When;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.log4j.Logger;
+import org.junit.Assert;
+import org.openqa.selenium.By;
+import org.openqa.selenium.support.ui.ExpectedConditions;
+import org.openqa.selenium.support.ui.WebDriverWait;
+import stepsdesign.BeforeActions;
+
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+
+import static io.cdap.plugin.odp.utils.AutoConstants.ACT_CREATE;
+import static io.cdap.plugin.odp.utils.AutoConstants.ACT_DELETE;
+import static io.cdap.plugin.odp.utils.AutoConstants.ACT_UPDATE;
+import static io.cdap.plugin.odp.utils.AutoConstants.DATASOURCE_LISHDR;
+import static io.cdap.plugin.odp.utils.AutoConstants.DATASOURCE_MAT;
+import static io.cdap.plugin.odp.utils.AutoConstants.TABLE_ODP;
+
+
+/**
+ * RuntimeODP.
+ */
+public class RuntimeODP implements CdfHelper {
+  private static final Logger logger = Logger.getLogger(RuntimeODP.class);
+  GcpClient gcpClient = new GcpClient();
+  private SAPProperties sapProps;
+  private ErrorCapture errorCapture;
+  private SAPAdapterImpl sapAdapterImpl;
+  private ExceptionUtils exceptionUtils;
+  static int dsRecordsCount;
+  static int countRecords;
+  static int presentRecords;
+  static int counter = 0;
+  static String datasource;
+  static String number;
+  static String action;
+  static int noOfRecords;
+  static String deltaLog;
+  static String rawLog;
+  static PrintWriter out;
+  private List<String> fields = new ArrayList<>();
+  private static Properties connection = new SAPProperties();
+  public static CdfPipelineRunLocators cdfPipelineRunLocators =
+    SeleniumHelper.getPropertiesLocators(CdfPipelineRunLocators.class);
+
+  static {
+    try {
+      out = new PrintWriter(BeforeActions.myObj);
+    } catch (FileNotFoundException e) {
+      logger.error("Failed while printWriter : " + e);
+    }
+
+    Properties prop = new Properties();
+    try {
+      prop.load(new FileInputStream("src/e2e-test/resources/Google_SAP_Connection.properties"));
+    } catch (IOException e) {
+      logger.error("Failed while reading SAP properties file" + e);
+    }
+    for (String property : prop.stringPropertyNames()) {
+      connection.put(property, prop.getProperty(property));
+    }
+  }
+
+  public RuntimeODP() throws FileNotFoundException {
+    number = RandomStringUtils.randomAlphanumeric(7);
+  }
+
+  @Given("Open CDF application to configure pipeline")
+  public void openCDFApplicationToConfigurePipeline() throws IOException, InterruptedException {
+    openCdf();
+  }
+
+  @When("Source is SAP ODP")
+  public void sourceIsSAPODP() {
+    ODPActions.selectODPSource();
+  }
+
+  @When("Target is BigQuery for ODP data transfer")
+  public void targetIsBigQueryForODPDataTransfer() {
+    CdfStudioActions.sinkBigQuery();
+  }
+
+  @When("Configure Direct Connection {string} {string} {string} {string} {string} {string} {string}")
+  public void configureDirectConnection(String client, String sysnr, String asHost, String dsName, String gcsPath,
+                                        String splitRow, String packageSize) throws IOException, InterruptedException {
+    datasource = CDAPUtils.getPluginProp(dsName);
+    ODPActions.getODPProperties();
+    ODPActions.enterDirectConnectionProperties(client, sysnr, asHost, dsName, gcsPath, splitRow, packageSize);
+  }
+
+  @When(
+    "Configure Connection {string} {string} {string} {string} {string} {string} {string} {string} {string} {string}")
+  public void configureConnection(String client, String sysnr, String asHost, String dsName, String gcsPath,
+                                  String splitRow, String packageSize, String msServ, String systemID,
+                                  String lgrp) throws IOException, InterruptedException {
+    ODPActions.getODPProperties();
+    ODPActions.enterConnectionProperties(client, sysnr, asHost, dsName, gcsPath, splitRow, packageSize,
+                                         msServ, systemID, lgrp);
+  }
+
+  @When("Username and Password is provided")
+  public void usernameAndPasswordIsProvided() throws IOException {
+    ODPActions.enterUserNamePassword(CDAPUtils.getPluginProp("AUTH_USERNAME"),
+                                     CDAPUtils.getPluginProp("AUTH_PASSWORD"));
+  }
+
+  @When("Run one Mode is Sync mode")
+  public void runOneModeIsSyncMode() {
+    ODPActions.selectSync();
+  }
+
+  @Then("Validate the Schema created")
+  public void validateTheSchemaCreated() throws InterruptedException {
+    ODPActions.getSchema();
+    WebDriverWait wait = new WebDriverWait(SeleniumDriver.getDriver(), 20000);
+    wait.until(ExpectedConditions.numberOfElementsToBeMoreThan
+      (By.xpath("//*[@placeholder=\"Field name\"]"), 2));
+    Assert.assertEquals(true, CDAPUtils.schemaValidation());
+  }
+
+  @Then("Close the ODP Properties")
+  public void closeTheODPProperties() {
+    ODPActions.closeButton();
+  }
+
+  @Then("Delete the existing Odp table {string} in bigquery")
+  public void deleteTheExistingOdpTableInBigquery(String table) throws IOException, InterruptedException {
+    gcpClient.dropBqQuery(CDAPUtils.getPluginProp(table));
+    BeforeActions.scenario.write("Table Deleted Successfully");
+  }
+
+  @Then("link source and target")
+  public void linkSourceAndTarget() {
+    SeleniumHelper.dragAndDrop(ODPLocators.fromODP, CdfStudioLocators.toBigQiery);
+  }
+
+  @Then("{string} the {string} records with {string} in the ODP datasource from JCO")
+  public void createTheRecordsInTheODPDatasourceFromJCO(String process, String recordcount, String rfcName)
+    throws IOException, JCoException, InterruptedException {
+    action = process;
+    if (action.equalsIgnoreCase("create")) {
+      action = ACT_CREATE;
+    } else if (action.equalsIgnoreCase("delete")) {
+      action = ACT_DELETE;
+    } else if (action.equalsIgnoreCase("update")) {
+      action = ACT_UPDATE;
+    }
+    dsRecordsCount = Integer.parseInt(recordcount);
+    sapProps = SAPProperties.getDefault(connection);
+    errorCapture = new ErrorCapture(exceptionUtils);
+    sapAdapterImpl = new SAPAdapterImpl(errorCapture, connection);
+    Map opProps = new HashMap<>();
+    opProps.put("RFC", CDAPUtils.getPluginProp(rfcName));
+    opProps.put("autoCommit", "true");
+    try {
+
+      ObjectMapper mapper = new ObjectMapper();
+      ObjectNode objectNode = mapper.createObjectNode();
+      objectNode.put(action, recordcount);
+      JsonNode response = sapAdapterImpl.executeRFC(objectNode.toString(), opProps, "", "");
+      noOfRecords = Integer.parseInt(response.get("EX_COUNT").asText());
+      Iterator<JsonNode> iteratedData = response.get("EX_DATA").iterator();
+      while (iteratedData.hasNext()) {
+        JsonNode object = iteratedData.next();
+        Iterator<String> fieldName = object.fieldNames();
+        if (fieldName.hasNext()) {
+          fields.add(object.get(fieldName.next()).asText());
+        }
+      }
+      BeforeActions.scenario.write("No of records :-" + noOfRecords + Arrays.toString(fields.toArray()));
+      Assert.assertEquals(noOfRecords, Integer.parseInt(recordcount));
+    } catch (Exception e) {
+      throw SystemException.throwException(e.getMessage(), e);
+    }
+    Thread.sleep(60000); //sleep required to wait for SAP record creation
+  }
+
+  @Then("Enter the BigQuery Properties for ODP datasource {string}")
+  public void enterTheBigQueryPropertiesForODPDatasource(String tableName) throws IOException, InterruptedException {
+    CdfStudioLocators.bigQueryProperties.click();
+    CdfBigQueryPropertiesActions cdfBigQueryPropertiesActions = new CdfBigQueryPropertiesActions();
+    SeleniumHelper.replaceElementValue(CdfBigQueryPropertiesLocators.projectID,
+                                       CDAPUtils.getPluginProp("odpProjectId"));
+    CdfBigQueryPropertiesLocators.bigQueryReferenceName.sendKeys("automation_test");
+    CdfBigQueryPropertiesLocators.datasetProjectID.sendKeys(CDAPUtils.getPluginProp("odpProjectId"));
+    CdfBigQueryPropertiesLocators.dataset.sendKeys(CDAPUtils.getPluginProp("dataSetOdp"));
+    CdfBigQueryPropertiesLocators.bigQueryTable.sendKeys(CDAPUtils.getPluginProp(tableName));
+    CdfBigQueryPropertiesLocators.truncatableSwitch.click();
+    CdfBigQueryPropertiesLocators.updateTable.click();
+    CdfBigQueryPropertiesLocators.validateBttn.click();
+    SeleniumHelper.waitElementIsVisible(CdfBigQueryPropertiesLocators.textSuccess, 1L);
+  }
+
+  @Then("Close the BQ Properties")
+  public void closeTheBQProperties() {
+    CdfGcsActions.closeButton();
+  }
+
+  @Then("Run the ODP Pipeline in Runtime")
+  public void runTheODPPipelineInRuntime() throws InterruptedException {
+    CdfPipelineRunAction.runClick();
+  }
+
+  @Then("Wait till ODP pipeline is in running state")
+  public void waitTillODPPipelineIsInRunningState() {
+    WebDriverWait wait = new WebDriverWait(SeleniumDriver.getDriver(), 1000000);
+    wait.until(ExpectedConditions.or(
+      ExpectedConditions.visibilityOfElementLocated(By.xpath("//*[@data-cy='Succeeded']")),
+      ExpectedConditions.visibilityOfElementLocated(By.xpath("//*[@data-cy='Failed']"))));
+  }
+
+  @Then("Open Logs of ODP Pipeline")
+  public void openLogsOfODPPipeline() throws InterruptedException, FileNotFoundException {
+    CdfPipelineRunAction.logsClick();
+    Thread.sleep(5000); //TODO
+    rawLog = CdfPipelineRunAction.captureRawLogs();
+    BeforeActions.scenario.write(rawLog);
+    out.println(rawLog);
+    out.close();
+  }
+
+  @Then("Verify the ODP pipeline status is {string}")
+  public void verifyTheODPPipelineStatusIs(String status) {
+    boolean webelement = SeleniumHelper.verifyElementPresent("//*[@data-cy='" + status + "']");
+    Assert.assertTrue(webelement);
+  }
+
+  @Then("validate successMessage is displayed for the ODP pipeline")
+  public void validateSuccessMessageIsDisplayedForTheODPPipeline() {
+    CdfLogActions.validateSucceeded();
+  }
+
+  @Then("Get Count of no of records transferred from ODP to BigQuery in {string}")
+  public void getCountOfNoOfRecordsTransferredFromODPToBigQueryIn(String table) throws
+    IOException, InterruptedException {
+    countRecords = gcpClient.countBqQuery(CDAPUtils.getPluginProp(table));
+  }
+
+  @Then("Verify the Delta load transfer is successful in {string} on basis of {string}")
+  public void verifyTheDeltaLoadTransferIsSuccessfull(String table, String field) throws IOException,
+    InterruptedException {
+    int i = 0;
+    String projectId = CDAPUtils.getPluginProp("odpProjectId");
+    String datasetName = CDAPUtils.getPluginProp("dataSetOdp");
+    String selectQuery = "SELECT count(*)  FROM `" + projectId + "." + datasetName + "." + CDAPUtils.getPluginProp
+      (table) + "` WHERE " +
+      field.toUpperCase();
+    switch (datasource) {
+      case DATASOURCE_MAT:
+        for (String element : fields) {
+          Assert.assertTrue(GcpClient.executeQuery(selectQuery.concat("=" + "\"" + element + "\"")) == 1);
+        }
+        countRecords = gcpClient.countBqQuery(CDAPUtils.getPluginProp(table));
+        Assert.assertTrue(countRecords == noOfRecords);
+        break;
+      case DATASOURCE_LISHDR:
+        if (action == ACT_CREATE) {
+          for (String element : fields) {
+            Assert.assertTrue(GcpClient.executeQuery(selectQuery.concat("=" + "\"" + element + "\"")) == 1);
+          }
+          countRecords = gcpClient.countBqQuery(CDAPUtils.getPluginProp(table));
+          Assert.assertTrue(countRecords == noOfRecords);
+        } else {
+          for (String element : fields) {
+            Assert.assertTrue(GcpClient.executeQuery(selectQuery.concat("=" + "\"" + element + "\"")) == 2);
+          }
+          countRecords = gcpClient.countBqQuery(CDAPUtils.getPluginProp(table));
+          Assert.assertTrue(countRecords == 2 * noOfRecords);
+        }
+        break;
+    }
+
+  }
+
+  @Then("Close the log window")
+  public void closeTheLogWindow() {
+    SeleniumDriver.getDriver().findElement(By.xpath("//*[@data-cy=\"log-viewer-close-btn\"]")).click();
+    fields.clear();
+  }
+
+  @Then("delete table {string} in BQ if not empty")
+  public void deleteTableInBQIfNotEmpty(String table) throws IOException, InterruptedException {
+    try {
+      int existingRecords = gcpClient.countBqQuery(CDAPUtils.getPluginProp(table));
+      if (existingRecords > 0) {
+        gcpClient.dropBqQuery(CDAPUtils.getPluginProp(table));
+        BeforeActions.scenario.write("Table Deleted Successfully");
+      }
+    } catch (Exception e) {
+      BeforeActions.scenario.write(e.toString());
+    }
+  }
+
+  @Then("Wait till ODP pipeline is successful again")
+  public void waitTillODPPipelineIsSuccessfulAgain() {
+    SeleniumHelper.isElementPresent(SeleniumDriver.getDriver().findElement(By.xpath("//*[@data-cy='Running']")));
+    WebDriverWait wait = new WebDriverWait(SeleniumDriver.getDriver(), 1000000);
+    SeleniumDriver.getDriver().get(SeleniumDriver.getDriver().getCurrentUrl());
+    wait.until(ExpectedConditions.or(
+      ExpectedConditions.visibilityOfElementLocated(By.xpath("//*[@data-cy='Succeeded']")),
+      ExpectedConditions.visibilityOfElementLocated(By.xpath("//*[@data-cy='Failed']"))));
+  }
+
+  @Then("Verify the full load transfer is successful")
+  public void verifyTheFullLoadTransferIssuccessful() {
+    String rec = String.valueOf(countRecords);
+    int resultrec = Integer.valueOf(rec.replaceAll(",", "").toString());
+    Assert.assertTrue(resultrec == recordOut());
+  }
+
+  @Then("Open Logs of ODP Pipeline to capture delta logs")
+  public void openLogsOfODPPipelineToCaptureDeltaLogs() throws InterruptedException, FileNotFoundException {
+    PrintWriter out = new PrintWriter(BeforeActions.myObj);
+    WebDriverWait wait = new WebDriverWait(SeleniumDriver.getDriver(), 10000);
+    wait.until(ExpectedConditions.refreshed(ExpectedConditions.visibilityOfElementLocated(By.
+      xpath("//*[@class=\"run-logs-btn\"]"))));
+    CdfPipelineRunAction.logsClick();
+    wait.until(ExpectedConditions.refreshed(ExpectedConditions.visibilityOfElementLocated(By.
+      xpath("(//*[@type=\"button\"])[7]"))));
+    deltaLog = CdfPipelineRunAction.captureRawLogs();
+    BeforeActions.scenario.write(deltaLog);
+    out.println(rawLog.concat("********************+delta" + deltaLog));
+    out.close();
+  }
+
+  @When("Subscriber is entered")
+  public void subscriberIsEntered() {
+    ODPLocators.subsName.sendKeys(number);
+  }
+
+  @Then("Save and Deploy ODP Pipeline")
+  public void saveAndDeployODPPipeline() throws InterruptedException {
+    saveAndDeployPipeline();
+  }
+
+  @Then("Reset the parameters")
+  public void resetTheParameters() {
+    countRecords = 0;
+    presentRecords = 0;
+    dsRecordsCount = 0;
+    counter = 0;
+    BeforeActions.scenario.write("countRecords=0;\n" +
+                                   "    presentRecords=0;\n" +
+                                   "    dsRecordsCount=0;");
+  }
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/Security.java b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/Security.java
new file mode 100644
index 0000000..5dd8c8d
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/Security.java
@@ -0,0 +1,176 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.stepsdesign;
+
+import io.cdap.e2e.pages.actions.CdfSysAdminActions;
+import io.cdap.e2e.pages.locators.CdfStudioLocators;
+import io.cdap.e2e.pages.locators.CdfSysAdminLocators;
+import io.cdap.e2e.utils.CdfHelper;
+import io.cdap.e2e.utils.SeleniumDriver;
+import io.cdap.e2e.utils.SeleniumHelper;
+import io.cdap.plugin.odp.actions.ODPActions;
+import io.cdap.plugin.odp.locators.ODPLocators;
+import io.cdap.plugin.odp.utils.CDAPUtils;
+import io.cucumber.java.en.Given;
+import io.cucumber.java.en.Then;
+import io.cucumber.java.en.When;
+import org.junit.Assert;
+import org.openqa.selenium.NoAlertPresentException;
+
+import java.io.IOException;
+
+/**
+ * Security.
+ */
+public class Security implements CdfHelper {
+
+  String arr[] = new String[11];
+  private static int countarr = 0;
+  private static boolean errorExist;
+
+  @Given("Open {string} link to configure macros")
+  public void openLinkToConfigureMacros(String link) throws IOException {
+    SeleniumDriver.getDriver().get(CDAPUtils.getPluginProp(link));
+    SeleniumDriver.waitForPageToLoad();
+    try {
+      SeleniumDriver.getDriver().switchTo().alert().accept();
+      SeleniumDriver.waitForPageToLoad();
+    } catch (NoAlertPresentException var3) {
+      SeleniumDriver.waitForPageToLoad();
+    }
+  }
+
+  @Then("Select {string} service to configure")
+  public void selectServiceToConfigure(String service) {
+    CdfSysAdminActions.selectMacroAPIService(service);
+  }
+
+  @Then("enter variable for {string} of the macro")
+  public void enterVariableForOfTheMacro(String param) {
+    countarr = param.length();
+    CDAPUtils.clearField(CdfSysAdminLocators.apiInputURI);
+    CdfSysAdminActions.enterURI("namespaces/default/securekeys/" + param);
+  }
+
+  @Then("enter the {string} of the service")
+  public void enterTheOfTheService(String request) throws IOException {
+    CDAPUtils.clearField(CdfSysAdminLocators.requestBody);
+    CdfSysAdminActions.enterRequestBody(CDAPUtils.getPluginProp(request));
+  }
+
+  @Then("send request and verify success message")
+  public void sendRequestAndVerifySuccessMessage() throws IOException {
+    CdfSysAdminActions.clearRequest();
+    CdfSysAdminActions.clearAllRequest();
+    CdfSysAdminActions.sendRequest();
+    CdfSysAdminActions.verifySuccess();
+  }
+
+  @Then("Link Source and Sink table")
+  public void linkSourceAndSinkTable() throws InterruptedException {
+    SeleniumHelper.dragAndDrop(CdfStudioLocators.fromSAPODP, CdfStudioLocators.toBigQiery);
+  }
+
+  @Then("enter the macro variable in fields")
+  public void enterTheMacroVariableInFields() throws InterruptedException {
+    ODPLocators.macroSapUserName.click();
+    ODPLocators.macroSapUserPazwrd.click();
+    ODPLocators.macroSapClient.click();
+    ODPLocators.macroSapSysNumber.click();
+    ODPLocators.macroSapASHost.click();
+    ODPLocators.macroSapDsName.click();
+    ODPLocators.macroPackSize.click();
+    ODPLocators.macroSplits.click();
+    ODPLocators.macroSapGcsPath.click();
+    ODPLocators.macroSapGcsProjId.click();
+    ODPLocators.macroSapLanguage.click();
+    ODPLocators.macroSapExtractType.click();
+    SeleniumHelper.replaceElementValue(ODPLocators.usernameCredentials, "${usermacro}");
+    SeleniumHelper.replaceElementValue(ODPLocators.macroPass, "${passmacro}");
+    SeleniumHelper.replaceElementValue(ODPLocators.sapClient, "${clientmacro}");
+    SeleniumHelper.replaceElementValue(ODPLocators.systemNumber, "${sysnrmacro}");
+    SeleniumHelper.replaceElementValue(ODPLocators.sapApplicationServerHost, "${serverhostmacro}");
+    SeleniumHelper.replaceElementValue(ODPLocators.dataSourceName, "${datasourcemacro}");
+    SeleniumHelper.replaceElementValue(ODPLocators.packageSize, "${packagesize}");
+    SeleniumHelper.replaceElementValue(ODPLocators.splitRow, "${numbersplit}");
+    SeleniumHelper.replaceElementValue(ODPLocators.gcsPath, "${gcsbucket}");
+    SeleniumHelper.replaceElementValue(ODPLocators.projectID, "${gcpprojectid}");
+    SeleniumHelper.replaceElementValue(ODPLocators.language, "${languagemacro}");
+    SeleniumHelper.replaceElementValue(ODPLocators.extractType, "${loadtype}");
+  }
+
+  @Then("enter the secured created variable")
+  public void enterTheSecuredCreatedVariable() throws InterruptedException {
+    ODPLocators.macroSapUserName.click();
+    ODPLocators.macroSapUserPazwrd.click();
+    ODPLocators.macroSapClient.click();
+    ODPLocators.macroSapSysNumber.click();
+    ODPLocators.macroSapASHost.click();
+    ODPLocators.macroSapDsName.click();
+    ODPLocators.macroPackSize.click();
+    ODPLocators.macroSplits.click();
+    ODPLocators.macroSapGcsPath.click();
+    ODPLocators.macroSapGcsProjId.click();
+    ODPLocators.macroSapLanguage.click();
+    ODPLocators.macroSapExtractType.click();
+    ODPLocators.macroFilterOptionEqual.click();
+    CDAPUtils.clearField(ODPLocators.sapRouter);
+    CDAPUtils.clearField(ODPLocators.subsName);
+    CDAPUtils.clearField(ODPLocators.filterEqualMacros);
+    SeleniumHelper.replaceElementValue(ODPLocators.sapClient, "${secure(testjcoclient)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.language, "${secure(testlang)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.sapApplicationServerHost, "${secure(testjcoserver)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.systemNumber, "${secure(testjcosysnr)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.dataSourceName, "${secure(testjcodatasourcename)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.extractType, "${secure(testloadtype)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.usernameCredentials, "${secure(testuserqa)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.macroPass, "${secure(testpasswordqa)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.gcsProjectID, "auto-detect");
+    SeleniumHelper.replaceElementValue(ODPLocators.packageSize, "${secure(testjcopackagesize)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.splitRow, "${secure(testjcosplit)}");
+    SeleniumHelper.replaceElementValue(ODPLocators.gcsPath, "${secure(testgcspath)}");
+    ODPLocators.validateButton.click();
+    ODPLocators.pluginValidationSuccessMessage.isDisplayed();
+  }
+
+  @Then("enter the {string} of the service username and password")
+  public void enterTheOfTheServiceUsernameAndPassword(String request) throws IOException {
+    try {
+      CDAPUtils.clearField(CdfSysAdminLocators.requestBody);
+    } finally {
+      CDAPUtils.clearField(CdfSysAdminLocators.requestBody);
+    }
+    CdfSysAdminActions.enterRequestBody("{\"description\": \"secure login creds\",\"data\": \"" + CDAPUtils.
+      getPluginProp(request) + "\",\"properties\": {}}");
+  }
+
+  @When("Username {string} and Password {string} is provided")
+  public void usernameAndPasswordIsProvided(String userName, String password) throws IOException {
+    ODPActions.enterUserNamePassword(CDAPUtils.getPluginProp(userName), CDAPUtils.getPluginProp(password));
+  }
+
+  @Then("RFC auth error is displayed {string}")
+  public void rfcAuthErrorIsDisplayed(String rfcError) {
+    ODPActions.getSchema();
+    errorExist = ODPLocators.mainStreamError.getText().toLowerCase().contains(CDAPUtils.getErrorProp(rfcError)
+            .toLowerCase());
+  }
+
+  @Then("User is able to validate the error no auth error")
+  public void userIsAbleToValidateTheValidateTheErrorNoAuthError() {
+      Assert.assertTrue(errorExist);
+  }
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/package-info.java b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/package-info.java
new file mode 100644
index 0000000..ed66503
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/stepsdesign/package-info.java
@@ -0,0 +1,21 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * Package contains the stepDesign for the GCP features.
+ */
+package io.cdap.plugin.odp.stepsdesign;
+
+
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/tests/runner/TestRunner.java b/src/e2e-test/java/io/cdap/plugin/odp/tests/runner/TestRunner.java
new file mode 100644
index 0000000..b7be23b
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/tests/runner/TestRunner.java
@@ -0,0 +1,36 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.tests.runner;
+
+import io.cucumber.junit.Cucumber;
+import io.cucumber.junit.CucumberOptions;
+import org.junit.runner.RunWith;
+
+
+/**
+ * Test Runner to execute cases.
+ */
+@RunWith(Cucumber.class)
+@CucumberOptions(
+  features = {"src/e2e-test/features"},
+  glue = {"io.cdap.plugin.odp.stepsdesign", "stepsdesign"},
+  tags = {"@ODP"},
+  monochrome = true,
+  plugin = {"pretty", "html:target/cucumber-html-report", "json:target/cucumber-reports/cucumber.json",
+    "junit:target/cucumber-reports/cucumber.xml"}
+)
+public class TestRunner {
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/tests/runner/package-info.java b/src/e2e-test/java/io/cdap/plugin/odp/tests/runner/package-info.java
new file mode 100644
index 0000000..de6c089
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/tests/runner/package-info.java
@@ -0,0 +1,21 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * Package contains the runner for the GCP features.
+ */
+package io.cdap.plugin.odp.tests.runner;
+
+
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/mandate/TestRunner.java b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/mandate/TestRunner.java
new file mode 100644
index 0000000..5f9aa4d
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/mandate/TestRunner.java
@@ -0,0 +1,36 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.tests.runneroptional.mandate;
+
+import io.cucumber.junit.Cucumber;
+import io.cucumber.junit.CucumberOptions;
+import org.junit.runner.RunWith;
+
+
+/**
+ * Test Runner to execute cases.
+ */
+@RunWith(Cucumber.class)
+@CucumberOptions(
+  features = {"src/e2e-test/features"},
+  glue = {"io.cdap.plugin.odp.stepsdesign", "stepsdesign"},
+  tags = {"@LOADnDIR"},
+  monochrome = true,
+  plugin = {"pretty", "html:target/cucumber-html-report", "json:target/cucumber-reports/cucumber.json",
+    "junit:target/cucumber-reports/cucumber.xml"}
+)
+public class TestRunner {
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/mandate/package-info.java b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/mandate/package-info.java
new file mode 100644
index 0000000..9fa2d79
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/mandate/package-info.java
@@ -0,0 +1,21 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * Package contains the runner for the ODP mandatory features.
+ */
+package io.cdap.plugin.odp.tests.runneroptional.mandate;
+
+
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/optional/PropModifier.java b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/optional/PropModifier.java
new file mode 100644
index 0000000..ed9a79d
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/optional/PropModifier.java
@@ -0,0 +1,54 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.tests.runneroptional.optional;
+
+import cucumber.api.event.EventListener;
+import cucumber.api.event.EventPublisher;
+import io.cdap.plugin.odp.utils.CDAPUtils;
+import org.apache.log4j.Logger;
+
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.util.Properties;
+
+/**
+ * Event listener to update properties on the run, called as a plugin by TestRunner.
+ */
+public class PropModifier implements EventListener {
+
+  private static final Logger logger = Logger.getLogger(PropModifier.class);
+
+  private static Properties pluginPropBackup;
+
+  public PropModifier(String fileRelativePath) {
+    appendToProps(fileRelativePath);
+  }
+
+  private void appendToProps(String fileRelativePath) {
+    try {
+      pluginPropBackup = (Properties) CDAPUtils.pluginProp.clone();
+      CDAPUtils.pluginProp.load(new FileInputStream(fileRelativePath));
+    } catch (IOException e) {
+      logger.error("Error while reading file: " + e);
+    }
+  }
+
+  @Override
+  public void setEventPublisher(EventPublisher eventPublisher) {
+    //post action: reset properties to default
+    CDAPUtils.pluginProp = pluginPropBackup;
+  }
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/optional/TestRunner.java b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/optional/TestRunner.java
new file mode 100644
index 0000000..e93d91a
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/optional/TestRunner.java
@@ -0,0 +1,37 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.tests.runneroptional.optional;
+
+import io.cucumber.junit.Cucumber;
+import io.cucumber.junit.CucumberOptions;
+import org.junit.runner.RunWith;
+
+/**
+ * Test Runner to execute cases.
+ */
+@RunWith(Cucumber.class)
+@CucumberOptions(
+  features = {"src/e2e-test/features"},
+  glue = {"io.cdap.plugin.odp.stepsdesign", "stepsdesign"},
+  tags = {"@LOADnDIR"},
+  monochrome = true,
+  plugin = {"pretty", "html:target/cucumber-html-report", "json:target/cucumber-reports/cucumber.json",
+    "junit:target/cucumber-reports/cucumber.xml",
+    "io.cdap.plugin.odp.tests.runneroptional.optional.PropModifier:" +
+      "src/e2e-test/resources/additional/optional_odploadconnect.properties"}
+)
+public class TestRunner {
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/optional/package-info.java b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/optional/package-info.java
new file mode 100644
index 0000000..4842891
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/tests/runneroptional/optional/package-info.java
@@ -0,0 +1,21 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * Package contains the runner for the ODP optional features.
+ */
+package io.cdap.plugin.odp.tests.runneroptional.optional;
+
+
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/utils/AutoConstants.java b/src/e2e-test/java/io/cdap/plugin/odp/utils/AutoConstants.java
new file mode 100644
index 0000000..a02466d
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/utils/AutoConstants.java
@@ -0,0 +1,29 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.utils;
+
+/**
+ * constants file.
+ */
+public class AutoConstants {
+
+  public static final String DATASOURCE_MAT = "0MATERIAL_ATTR";
+  public static final String DATASOURCE_LISHDR = "2LIS_02_HDR";
+  public static final String ACT_CREATE = "I_NUM_C";
+  public static final String ACT_DELETE = "I_NUM_D";
+  public static final String ACT_UPDATE = "I_NUM_U";
+  public static final String TABLE_ODP = "tab_src01";
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/utils/CDAPUtils.java b/src/e2e-test/java/io/cdap/plugin/odp/utils/CDAPUtils.java
new file mode 100644
index 0000000..4605101
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/utils/CDAPUtils.java
@@ -0,0 +1,71 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.odp.utils;
+
+import io.cdap.e2e.utils.SeleniumDriver;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.log4j.Logger;
+import org.openqa.selenium.By;
+import org.openqa.selenium.Keys;
+import org.openqa.selenium.WebElement;
+
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.util.List;
+import java.util.Properties;
+
+/**
+ * CDAPUtils.
+ */
+public class CDAPUtils {
+
+  private static final Logger logger = Logger.getLogger(CDAPUtils.class);
+  private static Properties errorProp = new Properties();
+  public static Properties pluginProp = new Properties();
+
+  static {
+    try {
+      errorProp.load(new FileInputStream("src/e2e-test/resources/error_message.properties"));
+      pluginProp.load(new FileInputStream("src/e2e-test/resources/PluginParameters.properties"));
+    } catch (IOException e) {
+      logger.error("Error while reading file: " + e);
+    }
+  }
+
+  public static String getPluginProp(String property) throws IOException {
+    return pluginProp.getProperty(property);
+  }
+
+  public static boolean schemaValidation() {
+    boolean schemaCreated = false;
+    List<WebElement> elements = SeleniumDriver.getDriver().findElements(By.xpath("//*[@placeholder='Field name']"));
+    if (elements.size() > 2) {
+      schemaCreated = true;
+      return schemaCreated;
+    }
+    return false;
+  }
+
+  public static String getErrorProp(String errorMessage) {
+    return errorProp.getProperty(errorMessage);
+  }
+
+  public static void clearField(WebElement element) {
+    while (!element.getAttribute("value").equals(StringUtils.EMPTY)) {
+      element.sendKeys(Keys.BACK_SPACE);
+    }
+  }
+}
diff --git a/src/e2e-test/java/io/cdap/plugin/odp/utils/package-info.java b/src/e2e-test/java/io/cdap/plugin/odp/utils/package-info.java
new file mode 100644
index 0000000..13f41c7
--- /dev/null
+++ b/src/e2e-test/java/io/cdap/plugin/odp/utils/package-info.java
@@ -0,0 +1,19 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * contains ODP utils.
+ */
+package io.cdap.plugin.odp.utils;;
diff --git a/src/e2e-test/resources/Google_SAP_Connection.properties b/src/e2e-test/resources/Google_SAP_Connection.properties
new file mode 100644
index 0000000..4fd714b
--- /dev/null
+++ b/src/e2e-test/resources/Google_SAP_Connection.properties
@@ -0,0 +1,9 @@
+jco.client.client=100
+jco.client.lang=EN
+jco.client.sysnr=00
+jco.client.ashost=10.132.0.30
+jco.destination.peak_limit=10
+jco.destination.pool_capacity=3
+jco.client.user=<username>
+jco.client.passwd=<password>
+jco.server.connection_count =3
diff --git a/src/e2e-test/resources/PluginParameters.properties b/src/e2e-test/resources/PluginParameters.properties
new file mode 100644
index 0000000..1f5915c
--- /dev/null
+++ b/src/e2e-test/resources/PluginParameters.properties
@@ -0,0 +1,43 @@
+httpCall=http://localhost:11011/cdap/httpexecutor
+
+#Direct Connection Parameters
+s4Client=100
+s4Sysnr=00
+s4AsHost=10.132.0.30
+allTypeDsName=ZDSO_DATATYPE
+#TODO to be removed after moving it to system props
+AUTH_USERNAME=<username>
+AUTH_PASSWORD=<password>
+rfc_2LIS_02_HDR=ZFM_PO_DATA_LOAD
+dsHdr=2LIS_02_HDR
+
+#Load Connection Parameters
+s4MsHost=10.132.0.30
+s4MsServ=3601
+s4SystemId=DS4
+s4Lgrp=LB_DS4_00
+
+#field values
+s4GcsPath=gs://cdf-sap-dependent-files-cdapio
+s4Splitrow=1
+s4PkgSize=10000
+testNoAuthUsername=noauthuser
+testNoAuthPwd=Welcome@1
+tableDemo=tab_src01
+odpProjectId=cdf-athena
+dataSetOdp=test_automation
+dsAllDataType=ZDSO_DATATYPE
+dstransact=2LIS_12_VCITM
+dsMasterAttr=0MATERIAL_ATTR
+rfc_matnr=ZFM_0MATERIAL_ATTR_DML
+
+#request
+macroS4_jco_client={"description": "secure login creds","data": "100","properties": {}}
+macroS4_jco_server={"description": "secure login creds","data": "10.132.0.30","properties": {}}
+macroS4_jco_sysnr={"description": "secure login creds","data": "00","properties": {}}
+macroS4_jco_DataSourceName={"description": "secure login creds","data": "2LIS_02_HDR","properties": {}}
+macroS4_jco_split={"description": "secure login creds","data": "1","properties": {}}
+macroS4_jco_packageSize={"description": "secure login creds","data": "100","properties": {}}
+macroS4_jco_gcspath={"description": "secure login creds","data": "gs://cdf-sap-dependent-files-cdapio","properties": {}}
+macroS4_jco_lang={"description": "secure login creds","data": "en","properties": {}}
+macroS4_jco_load={"description": "secure login creds","data": "full","properties": {}}
diff --git a/src/e2e-test/resources/additional/optional_odploadconnect.properties b/src/e2e-test/resources/additional/optional_odploadconnect.properties
new file mode 100644
index 0000000..05ffae8
--- /dev/null
+++ b/src/e2e-test/resources/additional/optional_odploadconnect.properties
@@ -0,0 +1,3 @@
+load.S4msServ=3601
+load.S4systemID=123
+load.S4Lgrp=LB_DS4_00
diff --git a/src/e2e-test/resources/error_message.properties b/src/e2e-test/resources/error_message.properties
new file mode 100644
index 0000000..1795bb4
--- /dev/null
+++ b/src/e2e-test/resources/error_message.properties
@@ -0,0 +1,20 @@
+noRefName=Required property 'referenceName' has no value.
+noJcoClient=Required property 'jco.client.client' has no value.
+noJcoLang=Required property 'jco.client.lang' has no value.
+noJcoUser=Required property 'jco.client.user' has no value.
+sapAppServerHostRequired=Required property 'SAP Application Server Host' for connection type 'Direct (via SAP Application Server)'. An actual value or a macro variable is expected.
+sapSystemNumberRequired=Required property 'SAP System Number' for connection type 'Direct (via SAP Application Server)'. An actual value or a macro variable is expected.
+noSapSource=Required property 'sapSourceObjName' has no value.
+noGcsPath=Required property 'gcsPath' has no value.
+wrongJcoCLientConfig=CDF_SAP_01404 - SAP connection test failed. Please verify the connection parameters. Root Cause: JCO_ERROR_CONFIGURATION - Parameter SAP client ('jco.client.client') needs to be a three digit number string instead of 'abc'
+wrongLogonLang=CDF_SAP_01404 - SAP connection test failed. Please verify the connection parameters. Root Cause: JCO_ERROR_LOGON_FAILURE - Select one of the installed languages
+sapgatewayFailure=CDF_SAP_01404 - SAP connection test failed. Please verify the connection parameters. Root Cause: JCO_ERROR_COMMUNICATION - Connect to SAP gateway failed
+wrongCreds=CDF_SAP_01404 - SAP connection test failed. Please verify the connection parameters. Root Cause: JCO_ERROR_LOGON_FAILURE - Name or password is incorrect (repeat logon)
+missingBillingAc=Error encountered while configuring the stage: 'The project to be billed is associated with an absent billing account.'
+invalidSubscriberName=Subscriber name 'subscriber-Name' should only contain alphanumeric, _ and / characters and must not exceed 32 characters.
+invalidSplits=Invalid value for property 'Number of Splits to Generate'. A non-negative number (0 or greater, without a decimal) or a macro variable is expected.
+invalidPackSize=Invalid value for property 'Package Size'. A non-negative number (0 or greater, without a decimal) or a macro variable is expected.
+invalidDSCondition=Field(s) 'BALANCE' are not allowed for equality based condition in datasource 
+invalidRangeCondition=are not allowed for range based condition in datasource
+invalidDateRangeCondition=are not allowed for range based condition in datasource
+rfcError=No RFC authorization for function module
\ No newline at end of file