streaming

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

Aug	SEP	Oct
	05
2019	2020	2021

streaming

Here are 2,112 public repositories matching this topic...

webtorrent / webtorrent

FFmpeg / FFmpeg

koel / koel

elastic / logstash

akka / akka

streamaserver / streama

video-dev / hls.js

zhisheng17 / flink-learning

webtorrent / webtorrent-desktop

mediaelement / mediaelement

apache / pulsar

bnb / awesome-developer-streams

nukeop / nuclear

pion / webrtc

popcorn-official / popcorn-desktop

streamlink / streamlink

butterproject / butter-desktop

apache / beam

travisjeffery / jocko

anacrolix / torrent

Tribler / tribler

flink-china / flink-training-course

fanout / pushpin

Red5 / red5-server

adaltas / node-csv

webtorrent / instant.io

stream-labs / streamlabs-obs

spotify / scio

onyx-platform / onyx

atomashpolskiy / bt

Improve this page

Add this topic to your repo