@Ufuk, probably should. yes.
On Thu, 18 Jun 2015 at 16:18 Tamara Mendt tammyme...@gmail.com wrote:
Great, thanks!
On Thu, Jun 18, 2015 at 4:16 PM, Ufuk Celebi u...@apache.org wrote:
Should we add this to the Javadoc of the eagerly executed operations?
On 18 Jun 2015, at 16:11, Maximilian Michels m...@apache.org wrote:
Hi Tamara!
Yes, there is. Since count/collect/print trigger an execution of the
ExecutionEnvironment, you can get the result afterwards using
env.getLastExecutionResult().
Best,
Max
On Thu, Jun 18, 2015 at 3:57 PM, Tamara Mendt tammyme...@gmail.com
wrote:
Hey!
I am currently running a job in which I wish to use collect to trigger
my job execution, but I also need to have access to the final accumulator
results. Up until now I have been accessing the accumulator results through
the JobExecutionResult that the function execute() returns.
Not surprisingly, if I use collect() and execute() I get the following
exception:
java.lang.RuntimeException: No new data sinks have been defined since
the last execution. The last execution refers to the latest call to
'execute()', 'count()', 'collect()', or 'print()'.
at
org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:921)
at
org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:904)
at
org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:50)
Is there some way in which I can access the accumulator results while
using the collect method to trigger execution?
Cheers,
--
Tamara Mendt
