AbsaOSS / spline-spark-agent

Spline agent for Apache Spark
https://absaoss.github.io/spline/
Apache License 2.0
185 stars 95 forks source link

`KafkaLineageDispatcher` closes `KafkaProducer` twice #639

Closed cerveada closed 1 year ago

cerveada commented 1 year ago

As result of wrong merge.

According to my previous analysis, the fixed implementation should always close resources after the lineage was procesed: https://github.com/AbsaOSS/spline-spark-agent/wiki/Spark-Intialization-&-Shut-down

Original issue, that fixed thsi problem: https://github.com/AbsaOSS/spline-spark-agent/issues/383