[hotfix][docs] Fix missing closing symbol in joining.md. This closes a…

…pache#21119
mbalassi · Oct 20, 2022 · c0737e1 · c0737e1
1 parent a6db6ee
commit c0737e1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/docs/content.zh/docs/dev/datastream/operators/joining.md b/docs/content.zh/docs/dev/datastream/operators/joining.md
@@ -251,7 +251,7 @@ orangeStream
  .keyBy(<KeySelector>)
  .intervalJoin(greenStream.keyBy(<KeySelector>))
  .between(Time.milliseconds(-2), Time.milliseconds(1))
- .process (new ProcessJoinFunction<Integer, Integer, String(){
+ .process (new ProcessJoinFunction<Integer, Integer, String>(){
 
  @Override
  public void processElement(Integer left, Integer right, Context ctx, Collector<String> out) {

diff --git a/docs/content/docs/dev/datastream/operators/joining.md b/docs/content/docs/dev/datastream/operators/joining.md
@@ -251,7 +251,7 @@ orangeStream
  .keyBy(<KeySelector>)
  .intervalJoin(greenStream.keyBy(<KeySelector>))
  .between(Time.milliseconds(-2), Time.milliseconds(1))
- .process (new ProcessJoinFunction<Integer, Integer, String(){
+ .process (new ProcessJoinFunction<Integer, Integer, String>(){
 
  @Override
  public void processElement(Integer left, Integer right, Context ctx, Collector<String> out) {