Hi, I just encountered, that the (new streaming API) SourceFunction interface method cancel() states in the JavaDoc, that one might have a "volatile field 'isRunning'". Why should this member be volatile? I do not see why different thread should access this field (I would claim, it will be implemented as a private/protected member variable), and thus, declaring it volatile should not be necessary.
Do I miss anything? -Matthias
signature.asc
Description: OpenPGP digital signature
