You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/26 12:34:00 UTC

[jira] [Created] (FLINK-24004) Introduce a source/sink testing harness

Ingo Bürk created FLINK-24004:
---------------------------------

             Summary: Introduce a source/sink testing harness
                 Key: FLINK-24004
                 URL: https://issues.apache.org/jira/browse/FLINK-24004
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / API, Table SQL / Planner
            Reporter: Ingo Bürk
            Assignee: Ingo Bürk


For many tests we require some source/sink + factory with specific features and/or abilities. Currently, the "values" source exists for this, but has become quite bloated. Specifically implementing a specific set of abilities is very difficult to reflect there. On the other hand, implementing new factories for individual tests is a lot of bloat and requires a lot of factories to be registered.

We want to introduce a new factory (alongside the existing "values" one) which simply loads a user-defined class as the source to remove a bunch of that boilerplate.

Additional tasks:
 * Use this harness in PushProjectIntoTableSourceScanRuleTest
 * Migrate the "values" factory to the new config options class pattern so options can be used programmatically.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)