[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kurt Young reassigned FLINK-15093: ---------------------------------- Assignee: Danny Chen > StreamExecutionEnvironment does not clear transformations when executing > ------------------------------------------------------------------------ > > Key: FLINK-15093 > URL: https://issues.apache.org/jira/browse/FLINK-15093 > Project: Flink > Issue Type: Bug > Components: API / DataStream > Affects Versions: 1.10.0, 1.9.1 > Reporter: Jeff Zhang > Assignee: Danny Chen > Priority: Critical > Fix For: 1.10.0 > > Attachments: screenshot-1.png > > > 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)