please update me if any one knows how to handle it. On Sun, Jul 21, 2019 at 7:18 PM Amit Sharma <resolve...@gmail.com> wrote:
> Hi , I wrote a code in future block which read data from dataset and cache > it which is used later in the code. I faced a issue that data.cached() data > will be replaced by concurrent running thread . Is there any way we can > avoid this condition. > > val dailyData = callDetailsDS.collect.toList > val adjustedData = dailyData.map(callDataPerDay => Future{ > > > > val data = callDetailsDS.filter((callDetailsDS(DateColumn) geq (some > conditional date )) > data.cache() > > .................... > > } > > >