You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@beam.apache.org by azhar mirza <az...@gmail.com> on 2021/10/19 20:57:52 UTC
Apache beam. question
I have few question regarding apache beam.
if apache beam is using its own stateful processing then which runner will
be used?
if we are using Java SDK which runner is flexible whether is classic apache
flink runner or portable flink runner.
Suppose we are using apache flink runner who does take care take care of
stateful processing for fault tolerance.
How is Back pressure is handled in Apace beam.
if we integrate apache beam with flink and then use apache flink runner
what are the overheads?
Could you please response at the earliest kindly would be helpful.
Thanks
Azhar
Re: Apache beam. question
Posted by Robert Bradshaw <ro...@google.com>.
These sound like questions more suited to the user list; forwarding there.
On Tue, Oct 19, 2021 at 2:04 PM azhar mirza <az...@gmail.com> wrote:
>
> I have few question regarding apache beam.
>
> if apache beam is using its own stateful processing then which runner will be used?
>
> if we are using Java SDK which runner is flexible whether is classic apache flink runner or portable flink runner.
>
> Suppose we are using apache flink runner who does take care take care of stateful processing for fault tolerance.
>
> How is Back pressure is handled in Apace beam.
>
> if we integrate apache beam with flink and then use apache flink runner what are the overheads?
>
> Could you please response at the earliest kindly would be helpful.
>
> Thanks
> Azhar
Re: Apache beam. question
Posted by Robert Bradshaw <ro...@google.com>.
These sound like questions more suited to the user list; forwarding there.
On Tue, Oct 19, 2021 at 2:04 PM azhar mirza <az...@gmail.com> wrote:
>
> I have few question regarding apache beam.
>
> if apache beam is using its own stateful processing then which runner will be used?
>
> if we are using Java SDK which runner is flexible whether is classic apache flink runner or portable flink runner.
>
> Suppose we are using apache flink runner who does take care take care of stateful processing for fault tolerance.
>
> How is Back pressure is handled in Apace beam.
>
> if we integrate apache beam with flink and then use apache flink runner what are the overheads?
>
> Could you please response at the earliest kindly would be helpful.
>
> Thanks
> Azhar