[
https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-15093:
-------------------------------
Description:
!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}
was:
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}
> 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
> Attachments: screenshot-1.png
>
>
> !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)
