Hello Igniters,

The IgniteSparkSession class extends SparkSession and overrides the
cloneSession() method. The contract for cloneSession() explicitly states
that it should clone all state (ie. the sharedState and sessionState
fields), however the IgniteSparkSession implementation doesn't clone its
state fields.


This has the side-effect of breaking stateful operations for anything which
uses cloneSession(), for example a Spark streaming job will not be able to
use cached data across streaming microbatches, which is a significant issue
for such applications.


I’ve created the following Jira for this issue:


https://issues.apache.org/jira/browse/IGNITE-9180


If there are no comments, I’ll create a pull request with a fix over the
next few days.


Stuart.

Reply via email to