最近在做Processing Framework的性能比较,做到Flink时,测出的数据性能变得及其差。细看之后发现瓶颈出现在 Collector.collect() 方法, 可能是序列化,对象的复制话费了大量的时间。在我的例子中,collect(SINGLE OBJECGT)甚至要多到100ms (我这的OBJECT大概有500Bytes) 经过一番搜寻,这篇文章给了我答案 https://ww
Continue Reading

  • page 1 of 1

Consiiii

China


老板,我什么都能干


China