Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
Currently, the runner will cache any PCollection implementation - RDD or DStream - if accessed for the second time.
This can be further optimized to cache after the first evaluation, if accessed again, and also solve issues in BEAM-1206.