Hi Beam! After I have my pipeline created and the execution started on the Spark master I get this strange nugget:
java.lang.IllegalStateException: No TransformEvaluator registered for BOUNDED transform Read(CompressedSource) I'm reading from a HDFS file (hdfs:///input/customers-noheader-1M.txt) It's the exact same file and pipeline I've been testing on local files in the direct runner and on Google Storage in DataFlow without a problem. What could I have missed in the Spark case? Thanks again for any suggestions! Matt --- Matt Casters <m <[email protected]>[email protected]> Senior Solution Architect, Kettle Project Founder
