Skip to content

[FEA] Support registering python listener when running NDS over spark connect #228

@wbo4958

Description

@wbo4958

Spark Connect doesn't support Py4j, so in that case, we can't register JVM listener to monitor the task failures when running NDS over Spark Connect.

Instead, we may leverage "spark.extraListeners" which specifies the extra listeners which will be loaded and registered during the SparkContext initialization.

If the listener detects the task failure, the listener can write the failed task information to disk on the connect server. Then nds can read it from client

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions