File tree 1 file changed +9
-0
lines changed
wrangler-transform/src/main/java/io/cdap/wrangler
1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -381,6 +381,15 @@ public void destroy() {
381
381
*/
382
382
@ Override
383
383
public void transform (StructuredRecord input , Emitter <StructuredRecord > emitter ) throws Exception {
384
+ // The Transform function should never execute if SQL filters are enabled. SQL filters are
385
+ // handled by the LinearRelationalTransform implementation. If this code is reached, it means
386
+ // the LinearRelationalTransform could not be executed correctly.
387
+ if (PRECONDITION_LANGUAGE_SQL .equals (config .getPreconditionLanguage ())) {
388
+ throw new IllegalArgumentException ("SQL filters are not supported with "
389
+ + "multiple input stages. Please ensure the Wrangler stages with SQL "
390
+ + "filters have only one input." );
391
+ }
392
+
384
393
long start = 0 ;
385
394
List <StructuredRecord > records ;
386
395
You can’t perform that action at this time.
0 commit comments