Skip to content

Commit

Permalink
[hotfix][documentation] Fix wrong time semantics description
Browse files Browse the repository at this point in the history
  • Loading branch information
yanghua authored and aljoscha committed Feb 6, 2020
1 parent d2ea1fc commit c0268ea
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion docs/dev/stream/testing.md
Original file line number Diff line number Diff line change
Expand Up @@ -578,7 +578,7 @@ A few remarks on integration testing with `MiniClusterWithClientResource`:
Communicating with operators instantiated by a local Flink mini cluster via static variables is one way around this issue.
Alternatively, you could write the data to files in a temporary directory with your test sink.

* You can implement a custom *parallel* source function for emitting watermarks if your job uses event timer timers.
* You can implement a custom *parallel* source function for emitting watermarks if your job uses event time timers.

* It is recommended to always test your pipelines locally with a parallelism > 1 to identify bugs which only surface for the pipelines executed in parallel.

Expand Down

0 comments on commit c0268ea

Please sign in to comment.