[flink] branch master updated: [FLINK-12339][example] Fix variable name

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new f3161bd  [FLINK-12339][example] Fix variable name
f3161bd is described below

commit f3161bd5f79364e337ee6d6f6a7d808db95e28eb
Author: mjl <543631...@qq.com>
AuthorDate: Sun Apr 28 03:21:39 2019 +0800

    [FLINK-12339][example] Fix variable name
---
 .../streaming/scala/examples/windowing/TopSpeedWindowing.scala      | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
 
b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
index d7c7014..bb66ead 100644
--- 
a/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
+++ 
b/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
@@ -101,7 +101,7 @@ object TopSpeedWindowing {
         })
       }
 
-    val topSeed = cars
+    val topSpeeds = cars
       .assignAscendingTimestamps( _.time )
       .keyBy("carId")
       .window(GlobalWindows.create)
@@ -115,10 +115,10 @@ object TopSpeedWindowing {
       .maxBy("speed")
 
     if (params.has("output")) {
-      topSeed.writeAsText(params.get("output"))
+      topSpeeds.writeAsText(params.get("output"))
     } else {
       println("Printing result to stdout. Use --output to specify output 
path.")
-      topSeed.print()
+      topSpeeds.print()
     }
 
     env.execute("TopSpeedWindowing")