flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ted Yu <yuzhih...@gmail.com>
Subject Re: Replaying logs with microsecond delay
Date Tue, 15 May 2018 18:11:43 GMT
Please see the following:

http://www.rationaljava.com/2015/10/measuring-microsecond-in-java.html

https://stackoverflow.com/questions/11498585/how-to-suspend-a-java-thread-for-a-small-period-of-time-like-100-nanoseconds

On Tue, May 15, 2018 at 10:40 AM, Dhruv Kumar <gargdhruv36@gmail.com> wrote:

> Hi
>
> I am trying to replay a log file in which each record has a timestamp
> associated with it. The time difference between the records is of the order
> of microseconds. I am trying to replay this log maintaining the same delay
> between the records (using Thread.sleep()) and sending it to a socket. And
> then the Flink program reads the incoming data from this socket. Currently,
> replay of the entire log file takes much more time (3 times) then the
> expected time (last_timstamp - first_timstamp).
>
> I wanted to know what are the standard ways of replaying log files if one
> wants to maintain the same arrival delay between the records.
>
> Let me know if I am not clear above.
>
> Thanks
> --------------------------------------------------
> *Dhruv Kumar*
> PhD Candidate
> Department of Computer Science and Engineering
> University of Minnesota
> www.dhruvkumar.me
>
>

Mime
View raw message