Skip to content

[Feature][core] Flink sql task support customized test case input #3975

@MactavishCui

Description

@MactavishCui

Search before asking

  • I had searched in the issues and found no similar feature requirement.

Description

Mock sink has been implemented in dinky-1.2.0. This issue is for the discussion of mock the source part of flink sql. Currently, dinky only support get table inputs from the real production environment, but most kind of test cases, especially edge condition cases cannot be caught in a short time. As a result, it will be more helpful for users to submit customized test cases and test their tasks as comprehensive as possible.

Use case

Provide a form for users to submit customized test cases. Flink sql tasks can read these test cases as input when some mock-source options is set.
Based on MockStatmentExplainer.class, the connector of source tables can also be changed to the customized one, which help users can submit customized test cases. Here lists my scheme:
image
An open-api is designed for getting the test cases submitted by users. Then all test cases will be collected to next operators
I have submitted a Draft PR, which contains most of the implement code for this scheme.
If this scheme is acceptable, I will complete the development these days and ready for review. If there are better schemes for this feature, I'm also willing to implement them and contribute!

Looking forward to your discussion and reply.

Related issues

#3893

Are you willing to submit a PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

Status

Doing

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions