[flink] Close refresh executor before lookup table is closed - Githubissues

apache / paimon

Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.

https://paimon.apache.org/

Apache License 2.0

2.12k stars 839 forks source link

[flink] Close refresh executor before lookup table is closed #3564

Closed FangYongs closed 1 week ago

FangYongs commented 2 weeks ago

Purpose

Linked issue: close #xxx

Close refresh executor before lookup table is closed to avoid writing data into invalid directory

Tests

API and Format

no

Documentation

no

FangYongs commented 2 weeks ago

@JingsongLi Please help to review this PR, thanks

JingsongLi commented 1 week ago

+1