Hello, Is there a way to change subscription offse...
# troubleshooting
n
Hello, Is there a way to change subscription offset in flink source state (pulsar-flink connector)? State processor api does not allow for processing state of pulsar source from a savepoint. I am using flink version 1.16.0. Or i dont know how to access pulsar source state with state processor api.
When i try to use
Copy code
SavepointWritter.fromExistingSavepoint(...)
.removeOperator(operatorUid)
.write(outputDir)
This fails with
Savepoint must contain at least one operator
We should be allowed to only remove operator and save existing savepoint. Workaround is to add some kind of dummy operator state. This seems like a bug in state processor api
m
Please don't resend your messages to the channel
It's not a bug in the State Processor API; it's just not supported
n
It was a separate question, but related to my first, thats why i send it to channel. Thanks for the info.