Re: Spark Stream is corrupted

Any solutions for this problem please . Sent from my iPhone > On Jan 17, 2018, at 10:39 PM, KhajaAsmath Mohammed > wrote: > > Hi, > > I have created a streaming object from checkpoint but it always through up > error as stream corrupted when I restart spark

Spark Stream is corrupted

Hi, I have created a streaming object from checkpoint but it always through up error as stream corrupted when I restart spark streaming job. any solution for this? private def createStreamingContext( sparkCheckpointDir: String, sparkSession: SparkSession, batchDuration: Int, config: