Either Create or DirectRunner fails to produce all elements to the following transform

private static final int COUNT = 100;

private static AtomicInteger CREATED_COUNT = new AtomicInteger();

public static void run(Pipeline pipeline) {
  PCollection<Integer> indexes = pipeline.apply( "createIndexes",
      Create.of(IntStream.range(0, COUNT).boxed().collect(Collectors.toList())));

indexes.apply(
 "createMessages",
 MapElements.via(
     new SimpleFunction<Integer, Integer>(
         index -> {
           System.err.println("Created message index " + createdCount.incrementAndGet());
           return index;
         }) {}));

  pipeline.run().waitUntilFinish();  // Never terminates
}