[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989540#comment-16989540 ]
Kurt Young commented on FLINK-15093: ------------------------------------ cc [~kkloudas] > FLINK-13708 still exist in StreamExecutionEnvironment > ----------------------------------------------------- > > Key: FLINK-15093 > URL: https://issues.apache.org/jira/browse/FLINK-15093 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner > Affects Versions: 1.10.0, 1.9.1 > Reporter: Jeff Zhang > Priority: Critical > > Use the following code in scala shell to reproduce this issue. > {code} > val data = senv.fromElements("hello world", "hello flink", "hello hadoop") > data.flatMap(line => line.split("\\s")). > map(w => (w, 1)). > keyBy(0). > sum(1). > print > senv.execute() > data.flatMap(line => line.split("\\s")). > map(w => (w, 1)). > keyBy(0). > sum(1). > print > senv.execute() > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)