我有一个 Apache Flink 设置,其中包含一个 TaskManager 和两个处理槽。当我执行并行度设置为 1 的应用程序时,该作业的执行时间约为 33 秒。当我将并行度增加到 2 时,该作业需要 45 秒才能完成。
我在 Windows 机器上使用 Flink,配置为 10 个计算核心(4C + 6G)。我想用 2 个插槽取得更好的结果。我能做些什么?
我在Postgres有一个表X,其中包含以下条目
A B C
2 3 1
3 3 1
0 4 1
1 4 1
2 4 1
3 4 1
0 5 1
1 5 1
2 5 1
3 5 1
0 2 2
1 2 3
Run Code Online (Sandbox Code Playgroud)
我想找出对于每种A和B都具有最大C列的条目,即(由B组分组),并且可以进行最有效的查询,并返回相应的A和B.
预期产出:
A B C
1 2 3
2 3 1
0 4 1
0 5 1
Run Code Online (Sandbox Code Playgroud)
请帮我解决这个问题.谢谢