老师，你好，最近遇到了一个问题：create table source( id STRING, name STRING )with (); create table sink( id STRING, name STRING ,primary key (id) not ENFORCED )with (); create view newData as select a.id,a.name from source as a left JOIN sink as b on a.id = b.id where b.id is null; insert into sink select * from newData where id is not null; 执行完这条sql之后，将原来sink表的数据覆盖了，这是怎么回事呢？

老师，有些疑惑，希望老师有时间可以给些指点， 比如：1、在类中定义一个静态变量map,然后在任务执行前给map中添加一些值，任务开始执行后处理流的算子在这个map中取值取不到，这个是为什么呢？ 2、flink中定义的bean是否都需要实现Serializable，为了性能考虑，使用了Janino来处理了一些不变的内容其中用到了匿名内部类，在启动任务时会出现匿名内部类无法加载的异常。