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
