Hello,

I have a code that access a state store in order to get the latest value of
a specific key. In a case of a regular KTable<K,> the store name is the
same store name that was passed together with the aggregator and there is
no problem accessing this store.
In the case of a Windowed KTable, I can't access the sate store and I get
following error

"the state store, STORAGE, may have migrated to another instance."

I am using a daily window:
Windows<TimeWindow> windows = TimeWindows
          .of(TimeUnit.DAYS.toMillis(1))
          .until(TimeUnit.DAYS.toMillis(31));

I don't know if it is matter but I noticed that the the file structure on
the disk is different.
Without windowed it is: 1_0/rocksdb/STORAGE
With windowed it i: 1_0/STORAGE/STORAGE-201701231200
and the date at the end, had nothing to do with my records.

I am assuming that the state store is given a different name when used with
time widows. The question is how to get a hold on that name?

Thanks,
Shimi

Reply via email to