Reo-LEI opened a new pull request #3552:
URL: https://github.com/apache/iceberg/pull/3552
This PR is tring to fix #3551.
To fix this problem, you need to do these few steps:
Step-1: Patch this PR to your iceberg.
Step-2: Register `ClosureSerializer` to flink env to prevent NPE when Kryo
serialize lambda expr.
```
import com.twitter.chill.java.ClosureSerializer;
...
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.getConfig().registerTypeWithKryoSerializer(ClosureSerializer.Closure.class,
ClosureSerializer.class);
}
```
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
