Hi,
Its an application that maintains some state from the DStream using
updateStateByKey() operation. It then selects some of the records from
current batch using some criteria over current values and the state and
carries over the remaining values to next batch.
Following is the pseudo code :
va
Can you tell us more about streaming app? DStream operation that you are
using?
On Sun, Aug 2, 2015 at 9:14 PM, Anand Nalya wrote:
> Hi,
>
> I'm writing a Streaming application in Spark 1.3. After running for some
> time, I'm getting following execption. I'm sure, that no other process is
> modi
