[hotfix][docs] Fix Scala code example in Controlling Latency section

This closes apache#5299.
laubersder · Jan 29, 2018 · d2211ed · d2211ed
1 parent 71dee4e
commit d2211ed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/docs/dev/datastream_api.md b/docs/dev/datastream_api.md
@@ -487,7 +487,7 @@ env.generateSequence(1,10).map(new MyMapper()).setBufferTimeout(timeoutMillis);
 </div>
 <div data-lang="scala" markdown="1">
 {% highlight scala %}
-LocalStreamEnvironment env = StreamExecutionEnvironment.createLocalEnvironment
+val env: LocalStreamEnvironment = StreamExecutionEnvironment.createLocalEnvironment
 env.setBufferTimeout(timeoutMillis)
 
 env.generateSequence(1,10).map(myMap).setBufferTimeout(timeoutMillis)