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)
