flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tamara Mendt <tammyme...@gmail.com>
Subject Using collect and accessing accumulator results
Date Thu, 18 Jun 2015 13:57:10 GMT
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,

Mime
View raw message