flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ufuk Celebi <...@apache.org>
Subject Re: Limit buffer size for a job
Date Mon, 11 Apr 2016 15:02:55 GMT
Hey Andrew,

take a look at this here:
https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/index.html#controlling-latency

Does this help?

– Ufuk

On Thu, Apr 7, 2016 at 3:04 PM, Andrew Ge Wu <andrew.ge-wu@eniro.com> wrote:
> Hi guys
>
> We have a prioritized queue, where high priority item can jump the queue and we do not
want to cache too much record in the buffer.
> Is there a way to configure my streaming source to use less buffer? so source always
fetch and get latest high prio records?
>
> Any suggestion? thanks!
>
>
> Andrew
> --
> Confidentiality Notice: This e-mail transmission may contain confidential
> or legally privileged information that is intended only for the individual
> or entity named in the e-mail address. If you are not the intended
> recipient, you are hereby notified that any disclosure, copying,
> distribution, or reliance upon the contents of this e-mail is strictly
> prohibited and may be unlawful. If you have received this e-mail in error,
> please notify the sender immediately by return e-mail and delete all copies
> of this message.

Mime
View raw message