isSessionInvalidated

function isSessionInvalidated(err): boolean;

Defined in: errors.ts:207

True when err indicates the server-side session backing this client is no longer valid. Happens after a server restart, an explicit session close from the server, or a mid-session handoff to a different server. Recover by building a fresh SparkSession.

Parameters

Parameter	Type
err	unknown

Returns

boolean

Example

try {
  await df.collect();
} catch (err) {
  if (isSessionInvalidated(err)) {
    spark = SparkSessionBuilder.remote(REMOTE).getOrCreate();
    return retry();
  }
  throw err;
}