Flink管道如下：
阅读Kafka主题中的消息（字符串）。
通过grok转换为json格式进行模式匹配。
在json中提取的字段上的时间窗口聚合。
下面是使用grok进行模式匹配的代码。

SingleOutputStreamOperator<JSONObject> mainStream = messageStream.rebalance()
                    .map(new MapFunction<String, JSONObject>() {    
                        private static final long serialVersionUID = 6;

                        @Override
                        public JSONObject map(String value) throws Exception {
                            JSONObject logJson = new JSONObject();  
                            grok.compile(pattern); //pattern is some pattern defined in the class
                            Match gm = grok.match(value);
                            gm.captures();
                            logJson.putAll(gm.toMap());
                            return logJson;
                        }})

在上面的代码编写中 grok.compile(pattern) 在map函数内部工作正常。不这样做会产生以下错误
mapfunction的实现不可序列化
原因：java.io.notserializableexception:com.google.code.regexp.pattern
有没有什么方法可以把grok.compile从Map上删除。根据我的理解，不需要编译每个消息的模式，如果消息的数量变得相当大，可能会造成瓶颈。
附言：我已经进口了 Package oi.thekraken.grok.api.grok
编辑：
我查看了grok实现，grok类实现了serializable。https://github.com/thekrakken/java-grok/blob/master/src/main/java/io/thekraken/grok/api/grok.java