flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai" <tzuli...@apache.org>
Subject Re: Stateful-fun-Basic-Hello
Date Tue, 26 May 2020 04:29:06 GMT

You're right, maybe the documentation needs a bit more directions there,
especially for people who are newer to Flink.

1. How to increase parallelism

There are two ways to do this. Either set the `parallelism.default` also in
the flink-conf.yaml, or use the -p command line option when starting the
application via packaged Docker images.

2. How to enable checkpointing

You would have to set execution.checkpointing.mode and
execution.checkpointing.interval configs, also in flink-conf.yaml.

For example, the mode can be set to `EXACTLY_ONCE` and interval to `5sec`
to have exactly-once mode checkpoints at 5 second intervals.

In general, the Statefun specific configurations are listed here [1].
All other configurations available in Flink are also available in Stateful
Functions as well.



On Tue, May 26, 2020, 11:42 AM C DINESH <dinesh.kittu99@gmail.com> wrote:

> Hi Team,
> I mean to say that know I understood. but in the documentation page
> flink-conf.yaml is not mentioned
> On Mon, May 25, 2020 at 7:18 PM C DINESH <dinesh.kittu99@gmail.com> wrote:
>> Thanks Gordon,
>> I read the documentation several times. But I didn't understand at that
>> time, flink-conf.yaml is not there.
>> can you please suggest
>> 1. how to increase parallelism
>> 2. how to give checkpoints to the job
>> As far as I know there is no documentation regarding this. or Are these
>> features are not there yet?
>> Cheers,
>> Dinesh.

View raw message