diff --git a/integration-test-remote/src/test/java/io/cdap/cdap/app/etl/wrangler/WranglerTest.java b/integration-test-remote/src/test/java/io/cdap/cdap/app/etl/wrangler/WranglerTest.java
index bdcd77b95..d5f922fa9 100644
--- a/integration-test-remote/src/test/java/io/cdap/cdap/app/etl/wrangler/WranglerTest.java
+++ b/integration-test-remote/src/test/java/io/cdap/cdap/app/etl/wrangler/WranglerTest.java
@@ -120,7 +120,8 @@ private void testWrangler(Engine engine) throws Exception {
       .put("precondition", "false")
       .put("threshold", "1")
       .put("schema", wranglerSchema.toString())
-      .put("directives", wranglerDirectives);
+      .put("directives", wranglerDirectives)
+      .put("on-error", "skip-error");
 
     ETLStage wranglerTransformStage =
       new ETLStage("Wrangler",