Hi Team, I am passing reference of StreamTableEnvironment and StreamExecutionEnvironment variable to class constructor(Map Class), I want to convert create a table from a String so I need StreamTableEnvironment, But I am getting below error, Can anyone help me? Exception in thread “main” org.apache.flink.api.common.InvalidProgramException: The implementation of the StreamExecutionEnvironment is not serializable. The object probably contains or references non serializable fields. at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:164) at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:132) at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:69) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.clean(StreamExecutionEnvironment.java:2317) at org.apache.flink.streaming.api.datastream.DataStream.clean(DataStream.java:202) at org.apache.flink.streaming.api.datastream.DataStream.map(DataStream.java:576) at org.abs.security.Main.main(Main.java:57) Caused by: java.io.NotSerializableException: org.apache.flink.streaming.api.environment.LocalStreamEnvironment at java.base/java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1175) at java.base/java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:345) at org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:548) at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:143) ... 6 more

HI @Keyur Makwana, Were you able to fix this? I’m facing the same exception

Yes, @Raghunadh Nittala I have created new environment in the method

Ahh okay. Actually I’m passing env to a class that implements RichAsyncFunction. for other classes its working fine.