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

Posted to dev@flink.apache.org by "David Anderson (Jira)" <ji...@apache.org> on 2021/08/05 20:44:00 UTC

[jira] [Created] (FLINK-23653) improve training exercises and tests so they are better examples

David Anderson created FLINK-23653:
--------------------------------------

             Summary: improve training exercises and tests so they are better examples
                 Key: FLINK-23653
                 URL: https://issues.apache.org/jira/browse/FLINK-23653
             Project: Flink
          Issue Type: Improvement
          Components: Documentation / Training / Exercises
            Reporter: David Anderson


The tests for the training exercises are implemented in a way that permits the same tests to be used for both the exercises and the solutions, and for both the Java and Scala implementations. The way that this was done is a bit awkward. 

It would be better to
 * eliminate the ExerciseBase class and its mechanisms for setting the source(s) and sink and parallelism
 * have tests that run with parallelism > 1
 * speed up the tests by using MiniClusterWithClientResource

It's also the case that the watermarking is done by calling emitWatermark in the sources. This is confusing; the watermarking should be visibly implemented in the exercises and solutions.



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