Nikola Stanisavljevic
03/15/2023, 5:16 PMNikola Stanisavljevic
03/16/2023, 4:29 PMSavepointWritter.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 apiMartijn Visser
03/16/2023, 5:01 PMMartijn Visser
03/16/2023, 5:01 PMNikola Stanisavljevic
03/16/2023, 5:56 PM