I'm sorry but i already cleaned up the logs. If i encounter the same
error again i will let you know
On 21.12.2017 17:12, Ufuk Celebi wrote:
Could you please share the complete logs of the initial failure? What
you describe in your second email should not happen ;-) If the
JobManager cannot bind to the port it should simply die and not
complain about checkpoint configuration.
– Ufuk
On Thu, Dec 21, 2017 at 1:21 PM, Plamen Paskov
<plamen.pas...@next-stream.com> wrote:
I inspected the log as you suggest and found that 6123 port was used by
another process. I free the port and restarted the job manager. Now
everything looks fine. The error message is little misleading as the real
cause is that 6123 is already bind but it says that state.checkpoints.dir is
not set.
Thanks
On 19.12.2017 17:55, Ufuk Celebi wrote:
When the JobManager/TaskManager are starting up they log what config
they are loading. Look for lines like
"Loading configuration property: {}, {}"
Do you find the required configuration as part of these messages?
– Ufuk
On Tue, Dec 19, 2017 at 3:45 PM, Plamen Paskov
<plamen.pas...@next-stream.com> wrote:
Hi,
I'm trying to enable externalized checkpoints like this:
env.enableCheckpointing(1000);
CheckpointConfig checkpointConfig = env.getCheckpointConfig();
checkpointConfig.enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);
checkpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);
env.setStateBackend(new
FsStateBackend("file:///tmp/flink-checkpoints-data/", true));
in flink-conf.yaml i set:
state.checkpoints.dir: file:///tmp/flink-checkpoints-meta/
but when i run the application i get this error:
java.lang.IllegalStateException: CheckpointConfig says to persist
periodic
checkpoints, but no checkpoint directory has been configured. You can
configure configure one via key 'state.checkpoints.dir'.
Any suggestions?
Thanks
