acoustic-carpenter-78188
11/02/2023, 9:26 PME0126 09:21:12.800044 1 workers.go:102] error syncing 'flytesnacks-development/f4fbbb51f24e6436695b': failed at
Node[n0]. RuntimeExecutionError: failed during plugin execution, caused by: failed to execute handle for plugin [spark]:
[BadTaskSpecification] invalid TaskSpecification [fields:{key:"sparkConf" value:{struct_value:{fields:
{key:"spark.driver.cores" value:{string_value:"1"}} fields:{key:"spark.driver.memory" value:{string_value:"1000M"}} fields:
{key:"spark.executor.cores" value:{string_value:"1"}} fields:{key:"spark.executor.instances" value:{string_value:"2"}} fields:
{key:"spark.executor.memory" value:{string_value:"1000M"}}}}}]., caused by: either MainApplicationFile or MainClass must
be set
Expected behavior
Remote clients should be able to execute the spark workflow
Additional context to reproduce
from flytekit.remote import FlyteRemote
import spark_dataframe.workflows.example
remote = FlyteRemote(
flyte_admin_url=localhost:30081,
insecure=True,
default_project="flytesnacks",
default_domain="development",
image_config=ImageConfig(
default_image=Image(name="default", fqn="spark", tag="v1")
)
)
remote.execute(spark_dataframe.workflows.example.my_smart_schema, inputs={}, version=version, wait=False)
Screenshots
image▾
acoustic-carpenter-78188
11/02/2023, 9:26 PM