Hi Trevor,
As Nikolaas pointed out, this is a regression in the recent master.
The current implementation of code in the ExecutionConfig doesn't
expect multiple executions. We have a pending fix [1] which should be
in soon.
Cheers,
Max
[1] https://github.com/apache/flink/pull/1913
On Tue, Apr 1
Hi Trevor,
this is a bug and was introduced before the streaming shell:
https://issues.apache.org/jira/browse/FLINK-3701
I suspect something changed somewhere else in the Flink code that breaks
the scala shell.
In the scala shell tests executing the same program twice is not done so it
went unnot
I was trying out the new scala-shell with streaming support...
The following code executes correctly the first time I run it:
val survival = benv.readCsvFile[(String, String, String,
String)]("file:///home/trevor/gits/datasets/haberman/haberman.data")
survival.count()
However, if I call survival
