flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Changed the behavior of "DataSet.print()"
Date Fri, 22 May 2015 09:08:58 GMT
Hi all!

Me merged a patch yesterday that changed the API behavior of the
"DataSet.print()" function.

"print()" now prints to stdout on the client process, rather than the
TaskManager process, as before. This is much nicer for debugging and
exploring data sets.

One implication of this is that print() is now an eager method ( like
collect() or count() ). That means that calling "print()" immediately
triggers the execution, and no "env.execute()" is required any more.


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message