These configs are part of the "adding Logstash to filebeat modules getting started experience" and therefore its very likely the first time a user will see a LS config.

For the best experience we should add a fair few comments to better inform what is going on. The user sees the nested field reference for the first time and there is a try three grok pattern scheme with two mutate renames that w

Description of Improvement
Currently, the only way to delete an album from the favorite albums tab is to click on the album to go into the album page and unstar it as seen in the second screenshot.

As show on the first screenshot below, there is no option to delete it in

this issue should be taken seriously

When using e.g. AvroSortedBucketIO, if a file pattern is passed as part of the input path, scio should output a helpful error message. Current behavior in 0.9.3 leads to a NullPointerException.

val myEntityPaths: List[String] = List(
  "gs://bucket/dir1/*.avro",
  "gs://bucket/dir2/*.avro",
)
sc.sortMergeCoGroup(
  classOf[String],
  AvroSortedBucketIO
    .read(new TupleTag[MyE

Because in CliClient.resume() we don't account for the case, when there is an exception in one of the async processing stages:

void resume() {
	...
	try {
		client.startAsync(state -> {
			printer.ifPresent(p -> p.print(state));
			if (!options.shouldSeedAfterDownloaded() && state.getPiecesRemaining() == 0) {
				runtime.shutdown();
			}
		}, 1000); // <-- CompletableFuture.w