Spring Cloud Data Flow：Java DSL 只返回最后 20 个任务执行实例

如何解决Spring Cloud Data Flow：Java DSL 只返回最后 20 个任务执行实例

我正在使用 SCDF Java DSL 在 Kubernetes 上以编程方式启动任务。我面临的问题是 Task#executions 方法返回的值不超过 20 个。例如，当我启动 25 个任务时，此方法返回一个包含 20 个元素的 Collection，而不是返回一个包含 25 个元素的集合。

代码示例：

URI dataFlowUri = URI.create(dataFlowServerUri);
DataFlowOperations dataFlowOperations = new DataFlowTemplate(dataFlowUri);
Task task = Task.builder(dataFlowOperations).name(taskNameWithBatchIdInstanceId).deFinition(taskdefintion).description(taskDescription).build();

Map<String,String> taskLaunchProperties = new DeploymentPropertiesBuilder()
                    .put("deployer.task.kubernetes.limits.cpu",cpuLimit)
                    .put("deployer.task.kubernetes.limits.memory",memoryLimit)
                    .put("deployer.task.kubernetes.requests.cpu",cpuRequest)
                    .put("deployer.task.kubernetes.requests.memory",memoryRequest).build();

//Sample code to reproduce the issue : 
int maxTasks = 20;
int tasksLaunched = 0;
//Let's launch 25 task instances for our task
for(int i=0;i<25;i++) {       
    task.launch(taskLaunchProperties,Arrays.asList("index="+i));
    tasksLaunched++;
    //pendingCount is the difference of tasks launched and tasks completed.
    int pendingCount = tasksLaunched - task.executions().stream().filter(
            taskExecutionResource -> taskExecutionResource.getTaskExecutionStatus() == TaskExecutionStatus.COMPLETE)
            .count();
    //wait until pending count is less than maxTasks.
    while(pendingCount>=maxTasks) {
    //infinite loop if we launch more than 20 tasks (i.e i>20) 

            Thread.sleep(10000);
            //task.exectuions() returns 20 elements even if all 25 tasks completed. 
            pendingCount = (tasksLaunched - task.executions().stream().filter(
            taskExecutionResource -> taskExecutionResource.getTaskExecutionStatus() == TaskExecutionStatus.COMPLETE)
            .count());

    }
}

上面的代码以无限的 while 循环结束。根本原因是 task.executions() 方法似乎仅限于返回任务的最后 20 个实例，而不是所有 25 个已执行的实例。

我检查了数据库中的 TASK_EXECUTION 表，我看到所有 25 个任务都完成了（EXIT_STATUS 为 0）。出于某种原因，即使 25 个任务完成得很好，task.executions() 方法似乎也返回 20。

如果我更改 for 循环，使我始终启动不超过 20 个任务（例如：for(int i=0;i<=20;i++)，代码完成得很好（即 ​​JVM 进程终止）。

注意：我认为最大并发任务属性可能与此有关；但是，设置 deployer.task.kubernetes.maximumConcurrentTasks=30 并没有解决问题。

问题：为什么 task.exectuions() 方法的上限是只返回 20 个元素？是否有某种方法可以使用我缺少的这个 API？