Commit 96939b06 authored by duanledexianxianxian's avatar duanledexianxianxian 😁

fix doc

parent ab702619
...@@ -35,7 +35,7 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; ...@@ -35,7 +35,7 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
public class StreamingJob { public class StreamingJob {
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
// set up the streaming execution environment // 创建执行环境上下文
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
/* /*
...@@ -58,6 +58,7 @@ public class StreamingJob { ...@@ -58,6 +58,7 @@ public class StreamingJob {
* *
*/ */
// execute program // execute program
env.execute("Flink Streaming Java API Skeleton"); env.execute("Flink Streaming Java API Skeleton");
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment