进一步的调查似乎是keyby（）进入keyedstream操作造成的，当对流进行键控时，性能下降了近40%，如果有多个keyedstream，则性能会继续下降。

DataStream<Tuple2<String, MyObj>> testStream = finalizedStream
            .map(new RichMapFunction<MyObj, Tuple2<String, MyObj>>() {

                @Override
                public Tuple2<String, MyObj> map(MyObj value) throws Exception {
                    return new Tuple2<String, MyObj>(value.getCustomKey(), value);
                }
            });

    KeyedStream<Tuple2<String, MyObj>, Tuple> keyedStream = testStream.keyBy(0);
    keyedStream.map(new MapFunction<Tuple2<String, MyObj>, MyObj>() {

        @Override
        public MyObj map(Tuple2<String, MyObj> tuple) throws Exception {
            return tuple.f1;
        }
    }).name("keyed stream");

不管怎样，我能把表演做得更好吗？似乎使用键控是不可避免的。我也不知道为什么我们也尝试在我们的环境中扩展工作，性能只是限制在一个数字，而不管我们提供了多少并行性。cpu利用率和内存显示，当监视器使用nmon时，它并不处于临界状态。
如有任何意见和帮助，我们将不胜感激。