From d74869f8a4642fec0064ae0d0a2911aa2dea3ce4 Mon Sep 17 00:00:00 2001
From: Xingcan Cui <xingcanc@gmail.com>
Date: Mon, 18 Dec 2017 21:55:30 +0800
Subject: [PATCH] [FLINK-8278] [docs] Fix Scala examples of metrics docs (var
 initialization).

---
 docs/dev/stream/state/state.md |  2 +-
 docs/monitoring/metrics.md     | 12 ++++++------
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/docs/dev/stream/state/state.md b/docs/dev/stream/state/state.md
index e9770bd757b..9956998ed6a 100644
--- a/docs/dev/stream/state/state.md
+++ b/docs/dev/stream/state/state.md
@@ -397,7 +397,7 @@ class BufferingSink(threshold: Int = 0)
     with CheckpointedRestoring[List[(String, Int)]] {
 
   @transient
-  private var checkpointedState: ListState[(String, Int)] = null
+  private var checkpointedState: ListState[(String, Int)] = _
 
   private val bufferedElements = ListBuffer[(String, Int)]()
 
diff --git a/docs/monitoring/metrics.md b/docs/monitoring/metrics.md
index 6c80036c459..eac73f7e94d 100644
--- a/docs/monitoring/metrics.md
+++ b/docs/monitoring/metrics.md
@@ -69,7 +69,7 @@ public class MyMapper extends RichMapFunction<String, String> {
 {% highlight scala %}
 
 class MyMapper extends RichMapFunction[String,String] {
-  @transient private var counter: Counter
+  @transient private var counter: Counter = _
 
   override def open(parameters: Configuration): Unit = {
     counter = getRuntimeContext()
@@ -119,7 +119,7 @@ public class MyMapper extends RichMapFunction<String, String> {
 {% highlight scala %}
 
 class MyMapper extends RichMapFunction[String,String] {
-  @transient private var counter: Counter
+  @transient private var counter: Counter = _
 
   override def open(parameters: Configuration): Unit = {
     counter = getRuntimeContext()
@@ -229,7 +229,7 @@ public class MyMapper extends RichMapFunction<Long, Long> {
 {% highlight scala %}
 
 class MyMapper extends RichMapFunction[Long,Long] {
-  @transient private var histogram: Histogram
+  @transient private var histogram: Histogram = _
 
   override def open(parameters: Configuration): Unit = {
     histogram = getRuntimeContext()
@@ -289,7 +289,7 @@ public class MyMapper extends RichMapFunction<Long, Long> {
 {% highlight scala %}
 
 class MyMapper extends RichMapFunction[Long, Long] {
-  @transient private var histogram: Histogram
+  @transient private var histogram: Histogram = _
 
   override def open(config: Configuration): Unit = {
     com.codahale.metrics.Histogram dropwizardHistogram =
@@ -342,7 +342,7 @@ public class MyMapper extends RichMapFunction<Long, Long> {
 {% highlight scala %}
 
 class MyMapper extends RichMapFunction[Long,Long] {
-  @transient private var meter: Meter
+  @transient private var meter: Meter = _
 
   override def open(config: Configuration): Unit = {
     meter = getRuntimeContext()
@@ -401,7 +401,7 @@ public class MyMapper extends RichMapFunction<Long, Long> {
 {% highlight scala %}
 
 class MyMapper extends RichMapFunction[Long,Long] {
-  @transient private var meter: Meter
+  @transient private var meter: Meter = _
 
   override def open(config: Configuration): Unit = {
     com.codahale.metrics.Meter dropwizardMeter = new com.codahale.metrics.Meter()
-- 
GitLab