Hi Jitendra, Could you give more details about your pipeline? Is it possible to share a code of this pipeline?
> On 5 Dec 2019, at 17:50, jitendra sharma <[email protected]> wrote: > > Hi, > > I am running beam job using Spark Runner and getting below error: > > 19/12/05 22:14:36 WARN UnboundedDataset: Provided StorageLevel: MEMORY_ONLY > is ignored for streams, using the default level: StorageLevel(memory, 1 > replicas) > [WARNING] > java.lang.IllegalStateException: No TransformEvaluator registered for > UNBOUNDED transform View.CreatePCollectionView > at > org.apache.beam.repackaged.beam_runners_spark.com.google.common.base.Preconditions.checkState > (Preconditions.java:518) > at > org.apache.beam.runners.spark.translation.streaming.StreamingTransformTranslator$Translator.translateUnbounded > (StreamingTransformTranslator.java:553) > at org.apache.beam.runners.spark.SparkRunner$Evaluator.translate > (SparkRunner.java:464) > > is any idea or help appreciated? > > > Regards, > Jitendra Sharma
