我已经在IDE (Intellij)和独立集群中运行了我的Flink程序(在Scala中)。在我的程序中,我打印出运行时间。在IDE中运行时,我得到了20多个,在独立集群中运行的是74s。我非常困惑,为什么在一个具有10个并行性的集群中运行这么多次。我试图比较Flink性能与火花基本上。有人能帮我弄清楚怎么会发生这种事吗?谢谢。我的程序示例可以找到。运行flink jar : flink -class flinkutils.generated.Test2Agg2Spark f
我在100万行(每行1KB)上运行基准测试。还修改了源代码,以生成100万个不同的值,就像最初一样,此代码生成单个值,并为每行提供相同的值给Bigtable。我在控制台上看到的内容与执行性能测试实用程序时看到的内容之间存在差异,有什么具体的原因吗?这篇堆栈概述参考表明,我看到的性能可能不会不寻常-- Google Bigtable performance: QPS vs CPU utilization 有没有其他方法或实用程序可以帮助我对Bigtable写、读和扫描性能进行基准<