Jeff Zhang created FLINK-15093:
----------------------------------
Summary: 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.9.1, 1.10.0
Reporter: Jeff Zhang
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)
