flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject [DISCUSS] Change semantics of print() to "eager"
Date Tue, 28 Apr 2015 08:18:26 GMT
Hi Folks,
right now .print() on DataSet creates a DataSink that prints to the
local stdout of a TaskManager. This is not very helpful when running
in a distributed environment, especially when using something like an
interactive Scala Shell in a cluster.

I propose to change print() to use collect() internally and therefore
eagerly execute without requiring env.execute().

What do you think?


View raw message