AbsaOSS / AbsaOSS/spline-spark-agent

RDD lineage support

未关闭
#33 17 条评论 0 个 reaction 已指派 1 人 已被 @cerveada 认领 在 GitHub 查看
Epic
主要语言
Scala
星标
210
派生
102
平均合并
1 天 1 小时
30 天内合并 PR
1

描述

Currently there is no one easy solution to provide lineage for RDDs, but there are several ways how to provide at lease some of it or define it manually. This ticket will group all of them.

Subtasks:
| Task | Ticket |
| --- | --- |
| partial RDD support (Write - LogicalPlan, Read - RDD) | https://github.com/AbsaOSS/spline-spark-agent/issues/498 |
| RDD Read support |
| RDD manual lineage metadata enrichment |

---
_Original message:_

I am using the latest spline version. When I enable spline, I see incomplete lineage, my code reads the file from parquet and creates a temporary view, performs some transformations and creates a new view which is then finally written to a parquet. However I am not able to see lineages for my transformations.

![lineage](https://user-images.githubusercontent.com/52342684/60380541-46ca9280-99fc-11e9-8167-577ffe84e9a4.png)

Are there any constraints like all the intermediate RDD's should be in memory? or any specific spark config apart from that mentioned in the documentation which needs to enabled?

贡献指南

这个仓库没有索引到贡献指南

评估

这个 Issue 还没有评估数据。

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。