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 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 stream = FlinkSource.forRowData() .env(env) - .tableLoader(loader) + .tableLoader(tableLoader) .streaming(true) .startSnapshotId(3821550127947089987L) .build();