@Override
  public List<Map<String, String>> taskConfigs(int maxTasks) {
    String txnSuffix = "-txn-" + UUID.randomUUID() + "-";
    return IntStream.range(0, maxTasks)
        .mapToObj(
            i -> {
              Map<String, String> map = Maps.newHashMap(props);
              map.put(IcebergSinkConfig.INTERNAL_TRANSACTIONAL_SUFFIX_PROP, txnSuffix + i);
              return map;
            })
        .collect(Collectors.toList());
  }
@Test
  public void testTaskConfigs() {
    SinkConnector connector = new IcebergSinkConnector();
    connector.start(ImmutableMap.of());
    List<Map<String, String>> configs = connector.taskConfigs(3);
    assertThat(configs).hasSize(3);
    configs.forEach(
        map -> assertThat(map).containsKey(IcebergSinkConfig.INTERNAL_TRANSACTIONAL_SUFFIX_PROP));
  }