mysql - 在 flink table api 中应用 flink tumble 窗口时没有结果

Question

我在学习https://nightlies.apache.org/flink/flink-docs-release-1.14/zh/docs/try-flink/table_api/时遇到了同样的问题。当我使用翻滚窗口时，我在 MySQL 接收器中什么也没有。

return transactions
            .window(Tumble.over(lit(1).hour()).on($("transaction_time")).as("log_ts"))
            .groupBy($("account_id"), $("log_ts"))
            .select(
                    $("account_id"),
                    $("log_ts").start().as("log_ts"),
                    $("amount").sum().as("amount"));

当我使用默认的 8 并行度时，我发现一些子任务在 web 前端没有收到来自上游的记录。

但是当我添加tEnv.getConfig().addConfiguration(new Configuration().set(CoreOptions.DEFAULT_PARALLELISM, 1));main 函数时，我在 MySQL sink 中得到了结果，Web 前端如下所示：

谁能告诉我为什么？