ClosureCleaner is currently under flink-java. However, it doesn't stick to flink-java and used in flink-streaming-java. IMHO flink-streaming-java should not base on flink-java( flink-batch-java in fact ). Thus, I propose to move ClosureCleaner to flink-core.