[PLUGIN-1572] Added error message when Wrangler uses SQL filters and …

…the wrangler stage has more than 1 inputs
data-integrations · Apr 5, 2023 · 5de6b5f · 5de6b5f
1 parent 240bd32
commit 5de6b5f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java b/wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java
@@ -381,6 +381,12 @@ public void destroy() {
    */
   @Override
   public void transform(StructuredRecord input, Emitter<StructuredRecord> emitter) throws Exception {
+    if (PRECONDITION_LANGUAGE_SQL.equals(config.getPreconditionLanguage())) {
+      throw new IllegalArgumentException("SQL filters are not supported with "
+          + "multiple input stages. Please ensure the Wrangler stages with SQL "
+          + "filters have only one input.");
+    }
+
     long start = 0;
     List<StructuredRecord> records;