between "start-time" and "now".
Regards,
Robert
On Wed, Nov 18, 2015 at 10:17 PM, Saleh wrote:
> Hi rmetzger0,
>
> Thanx for the response. I didn't know that I had to register before I could
> receive responses for my posts.
> Now I am registered. But the problem is not resolved yet. I know it might
> not be intuitive to get execution time from a long running streaming job
> but
> it is possible to get total execution time after let say I stop the program
> from running. Can I programatically compute this information? Or can I
> retrieve it from Flink web UI?
>
> cheers.
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-execution-time-benchmark-tp3258p3573.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
o get total execution time after let say I stop the program
from running. Can I programatically compute this information? Or can I
retrieve it from Flink web UI?
cheers.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-execution-time-benc
g for help?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-execution-time-benchmark-tp3258p3397.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
Hi Giacomo,
You are currently using the Flink Streaming API. Is that your intention or
would you like to measure batch execution?
Regarding your code: StreamExecutionEnvironment.readTextStream(filePath)
monitors a file/directory and streams the updates to that location [1] -
potentially indefinit
Hi Robert,
I can see the timestamp when the process starts but it seems doesn't stop
executing.
I have:
DataStream dataStream = env
.readTextStream(filePath)
.flatMap(new Splitter());
WindowedDataStream dataWindow =
dataStream.window(Time.of(5, Time
Hi,
The execute() method returns an execution result object that also contains the
runtime of the job.
Sent from my iPhone
> On 21.03.2015, at 11:09, Giacomo Licari wrote:
>
> Hi guys,
> I'm trying to execute a benchmark reading a 1GB file and applying a reduce
> function.
>
> I'd like to
Hi guys,
I'm trying to execute a benchmark reading a 1GB file and applying a reduce
function.
I'd like to get the overall execution time.
I put that code before applying the reduce function:
long startTime = System.currentTimeMillis();
and after env.execute("Flink Processor"); I put the code to
