Hi Max,
Filed https://issues.apache.org/jira/browse/BEAM-8112 to track this. It'll
be nice to also point it out in the python documentation here that it's not
supported yet: https://beam.apache.org/documentation/runners/flink/.
Thanks,
Catlyn
On Wed, Aug 28, 2019 at 2:50 AM Maximilian Michels w
Hi Catlyn,
I granted you contributor permissions in JIRA which allows you to
create/assign tickets.
Cheers,
Max
On 27.08.19 19:54, Catlyn Kong wrote:
Hi Max,
Thanks for getting back to me. Will create a ticket, my username is catlynk.
Cheers,
Catlyn
On Tue, Aug 27, 2019 at 3:50 AM Maximil
Hi Max,
Thanks for getting back to me. Will create a ticket, my username is catlynk.
Cheers,
Catlyn
On Tue, Aug 27, 2019 at 3:50 AM Maximilian Michels wrote:
> Hi Catlyn,
>
> This option has never worked outside the Java SDK where it originates
> from. For the upcoming Beam 2.16.0 release, we
Hi Catlyn,
This option has never worked outside the Java SDK where it originates
from. For the upcoming Beam 2.16.0 release, we have replaced this option
with a factory class:
https://github.com/apache/beam/blob/da6c1a8f435f5583811785050808a2311db94047/runners/flink/src/main/java/org/apache/be
Hi all,
I'm experimenting with checkpoints/savepoints in Beam (version 2.14) when
using a Flink (version 1.6.4) runner. Flink was able to take periodic
checkpoints when I setup the flink-conf.yaml correctly. But I was thinking
if it's possible to set the StateBackend on a per job level by flagging
