search

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.13k stars 842 forks source link

[flink] Introduce RepairTable Action for flink #3652

Closed xuzifu666 closed 5 days ago

xuzifu666 commented 6 days ago

Purpose

Currently Flink Action not support RepairTable，so introduce RepairTable Action for flink

Linked issue: close #xxx

Tests

API and Format

Documentation

zhuangchong commented 6 days ago

The action function input parameters should ideally be consistent with the Procedure.

-- repair all databases and tables in catalog
CALL sys.repair()

-- repair all tables in a specific database
CALL sys.repair('databaseName')

-- repair a table
CALL sys.repair('databaseName.tableName')
xuzifu666 commented 5 days ago

The action function input parameters should ideally be consistent with the Procedure.

-- repair all databases and tables in catalog
CALL sys.repair()

-- repair all tables in a specific database
CALL sys.repair('databaseName')

-- repair a table
CALL sys.repair('databaseName.tableName')

Done @zhuangchong

JingsongLi commented 5 days ago

+1 thanks @xuzifu666 @zhuangchong