@Override
    public Iterable<DefaultResultPartition> getProducedResults() {
        return producedResults;
    }
@Test
    void testGetProducedResultPartitions() {
        IntermediateResultPartitionID partitionIds1 =
                IterableUtils.toStream(producerVertex.getProducedResults())
                        .findAny()
                        .map(SchedulingResultPartition::getId)
                        .orElseThrow(
                                () ->
                                        new IllegalArgumentException(
                                                "can not find result partition"));
        assertThat(intermediateResultPartitionId).isEqualTo(partitionIds1);
    }