[GitHub] [flink] Aitozi commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function

[GitBox]

Aitozi commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle 
the wrapped function
URL: https://github.com/apache/flink/pull/8280#issuecomment-498920811
 
 
   One way to my mind: set the scattered `clean()` method with the `TOP_LEVEL` 
to keep the old way, And set `checkSerializable` to false. All the user 
function will be passed to clean by `environment#clean()`, we can config the 
clean level there and checkSerializable at the entrance.
   
   ```
   @Internal
   public <F> F clean(F f) {
        if (getConfig().isClosureCleanerEnabled()) {
                ClosureCleaner.clean(f, getConfig().getClosureCleanLevel(), 
true);
        }
        ClosureCleaner.ensureSerializable(f);
        return f;
   }
   ```

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


With regards,
Apache Git Services