You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/10 14:40:00 UTC
[jira] [Closed] (FLINK-15093) StreamExecutionEnvironment does not
clear transformations when executing
[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kostas Kloudas closed FLINK-15093.
----------------------------------
Resolution: Fixed
Merged on master with 9c44413a805d6d0d809fe2d497c84a3f653f4337
and on 1.10 with 9a15733e22fc4c88e6563e9f96f78f88dc0aafca
> 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
> Reporter: Jeff Zhang
> Assignee: Danny Chen
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.10.0
>
> Attachments: screenshot-1.png
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> 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)