AbsaOSS / AbsaOSS/pramen

Allow specifying Spark resources per Python-Py Transformer

Abierto
#36 0 comentarios 1 reacción 0 asignados Ver en GitHub
enhancement help wanted Pramen-Py
Lenguaje dominante
Scala
Estrellas
31
Forks
4
Merge medio
1 d 10 min
PR fusionados (30 d)
4

Descripción

## Background

Currently, Python transformations run with Spark resource settings configured per environment.
This is good if the cluster has dynamic resource allocation enabled. But for clusters that don't have dynamic resource allocation enabled it is not possible to fine-tune resources for each transformer.

## Solution
Pramen-Py already supports specifying resources per transformer #30. Need to add the capability to Pramen.

## Example
```conf
{
name = "Python transformer"
type = "python_transformation"
python.class = "SomeTransformer"
schedule.type = "daily"

info.date.expr = "@runDate"

output.table = "transformed_python"

dependencies = [
{
tables = [ table1 ]
date.from = "@infoDate"
}
]

spark.config {
spark.executor.instances = 4
spark.executor.cores = 1
spark.executor.memory = "4g"
}
}
```
Generated YAML:
```yaml
run_transformers:
- info_date: 2022-02-18
output_table: transformed_python
name: SomeTransformer
spark_config:
spark.executor.cores: 1
spark.executor.instances: 4
spark.executor.memory: 4g
```

Docs on Spark config: https://spark.apache.org/docs/latest/configuration.html

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.