DataLinkDC / dinky

Dinky is a real-time data development platform based on Apache Flink, enabling agile data development, deployment and operation.
http://www.dinky.org.cn
Apache License 2.0
3.18k stars 1.17k forks source link

[Optimization-3917][core] Optimize explain and add test #3918

Closed aiwenmo closed 1 week ago

aiwenmo commented 2 weeks ago

Purpose of the pull request

1.Optimize explain sql to support select statement, etc. 2.Optimize get stream graph to support select statement, etc. 3.Optimize get job plan info to support select statement, etc. 4.Optimize get lineage to support select statement, etc. 5.Add test to check the new feature of statements. 6.Optimize debug task. 7.Optimize execution step tp support sort execution

Brief change log

Verify this pull request

This pull request is code cleanup without any test coverage.

(or)

This pull request is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

aiwenmo commented 2 weeks ago

The implementation of other Flink versions is on the way.

aiwenmo commented 2 weeks ago

@MactavishCui PTAL. Mocksink in flink 1.16,1.18,1.19, and other version is on the way.

MactavishCui commented 2 weeks ago

@MactavishCui PTAL. Mocksink in flink 1.16,1.18,1.19, and other version is on the way.

Thanks for the heads-up. I'll have a look

MactavishCui commented 1 week ago

@MactavishCui PTAL. Mocksink in flink 1.16,1.18,1.19, and other version is on the way.

Thanks for the heads-up. I'll have a look

LGTM