You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
When trying to use kafka-gateway to ingest lineage data that was created from a spark job, I got the below error.
spline-demo-spline-kafka-server-1 | org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is java.lang.IllegalArgumentException: The class 'ExecutionPlan_1.2' is not in the trusted packages: [java.util, java.lang]. If you believe this class is safe to deserialize, please provide its name. If the serialization is only done by a trusted source, you can also enable trust all (*).
As a workaround you can configure the agent to use the older version API (v1_1) though you will lose labels added in v1_2. Otherwise, there is no big difference.
When trying to use kafka-gateway to ingest lineage data that was created from a spark job, I got the below error.
spline-demo-spline-kafka-server-1 | org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is java.lang.IllegalArgumentException: The class 'ExecutionPlan_1.2' is not in the trusted packages: [java.util, java.lang]. If you believe this class is safe to deserialize, please provide its name. If the serialization is only done by a trusted source, you can also enable trust all (*).
Versions
Spark Version: 3.3.0, Scala Version: 2.12
spark-spline-agent:2.0.0.
spline:0.7.8 / kafka-gateway:0.7.8
I went through the code (checkout to tag release/0.7.8) and in KafkaGatewayConfig
found ExecutionEvent_1.2 is not added to the typeMappings. but the mappings are present in develop branch.
one more thing to notice is the changes in develop branch are merged 2y back and yet not available on latest release tags.
The text was updated successfully, but these errors were encountered: