Hi All, Do we required to add any image for flink-main-container in pod-template.yaml file because it giving an error saying "spec.containers(0).image value required.
Could anyone help with this please Thanks, Priyanka Manickam On Thu, 22 Apr 2021, 08:41 Milind Vaidya, <kava...@gmail.com> wrote: > Hi > > I see MemoryStateBackend being used in TM Log > > org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend > has been configured, using default (Memory / JobManager) > MemoryStateBackend (data in heap memory / checkpoints to JobManager) > (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, > maxStateSize: 5242880) > > > > I am logging checkpointed value which is just message count > > Snapshot the state 500 > Snapshot the state 1000 > > > When I restart the job i.e. new TM but the job manager is same I see > > Snapshot the state 500 > > In the JM logs I see following entries > > Triggering checkpoint 1 > Triggering checkpoint 2 > > After restarting job hence new TM > > Triggering checkpoint 1 > > As per my understanding JM should hold the checkpointed > <https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/state/state_backends.html#the-memorystatebackend> > state across TM ? Am I correct? > > I have not configured anything special and using default. Do I need to add > any setting to make it work ? > I want to maintain message count across the TMs. > > > > > >
