StefanRRichter commented on issue #7009: [FLINK-10712] Support to restore state 
when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7009#issuecomment-456105318
 
 
   I think I agree with the assessment of the existing operators. 
   
   About adding a `RecoveryMode` to consider, would that mean that we would 
prevent all jobs that use union state to work with partial recovery? I think if 
we just consider a few popular operators like `KafkaConsumer`, that would 
already prevent a lot of jobs from using different recovery modes.
   
   I can see that this comes from the concern about existing code that uses 
union state. However, stricly speaking it should not be a regression because 
those recovery modes previously did not support state recovery at all. We also 
cannot prevent users from making wrong implementations, so I feel like a good 
thing to do is document what to care care for union state when using such 
recovery modes.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to