Hi, I would like to:
1. Group elements
2. Then filter-out some groups
3. Then iterate and calculate on filtered-in grouped
Under Spark execution environments, I get an exception:
Caused by: java.lang.IllegalStateException: ValueIterator can't be iterated
more than once,otherwise there could be data lost
at
org.apache.beam.runners.spark.translation.GroupNonMergingWindowsFunctions$GroupByKeyIterator$ValueIterator.iterator(GroupNonMergingWindowsFunctions.java:221)
at java.lang.Iterable.spliterator(Iterable.java:101)
at com.company.Main$2.processElement(Main.java:65)
Code attached
[citi_logo_mail][citi_logo_mail]Noam Gershi
Software Developer
T: +972 (3) 7405718
[Mail_signature_blue]
Main.java
Description: Main.java
