Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.10.0
Description
Use the following code in scala shell to reproduce this issue.
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()
Attachments
Attachments
Issue Links
- links to