From 136217a9c18f0523b75cbbfbed85499922e0be68 Mon Sep 17 00:00:00 2001
From: wangjunyou <594107385@qq.com>
Date: Thu, 3 Jun 2021 14:52:11 +0800
Subject: [PATCH] Modify the Flink variable name from the doc

---
 site/docs/flink.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/site/docs/flink.md b/site/docs/flink.md
index 6667cf264ecc..e7694695bb11 100644
--- a/site/docs/flink.md
+++ b/site/docs/flink.md
@@ -325,7 +325,7 @@ StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironme
 TableLoader tableLoader = TableLoader.fromHadooptable("hdfs://nn:8020/warehouse/path");
 DataStream<RowData> batch = FlinkSource.forRowData()
      .env(env)
-     .tableLoader(loader)
+     .tableLoader(tableLoader)
      .streaming(false)
      .build();
 
@@ -345,7 +345,7 @@ StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironme
 TableLoader tableLoader = TableLoader.fromHadoopTable("hdfs://nn:8020/warehouse/path");
 DataStream<RowData> stream = FlinkSource.forRowData()
      .env(env)
-     .tableLoader(loader)
+     .tableLoader(tableLoader)
      .streaming(true)
      .startSnapshotId(3821550127947089987L)
      .build();