Skip to content
#

streaming

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

guyboertje
guyboertje commented Oct 25, 2017

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

flink-learning

flink learning blog. http://www.flink-learning.com 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

  • Updated Aug 11, 2020
  • Java
nuclear
josharian
josharian commented May 22, 2020

It's possible I'm misunderstanding something, but...

When you send media to a track with no peers, you get io.ErrClosedPipe back. Many of the examples use this to suppress unimportant error messages.

When you send data to a data channel that is closed, you get data channel not open.

It would be nice if data channels also returned io.ErrClosedPipe in this situation, for consistency.

yangju2011
yangju2011 commented Aug 10, 2020

I am aggregating some events for 7 days from a partitioned table, and want to use mockTable for integration tests of my SQL.
SELECT flight_id AS flightId, campaign_id AS campaignId, ad_format FROM ad-selfserve.ad_platform_services.clean_flights_* WHERE _TABLE_SUFFIX >= $START_DATE AND _TABLE_SUFFIX < $END_DATE)

tests:
`
val CLEAN_FLIGHTS_TABLE_REF = "ad-selfserve:ad

atomashpolskiy
atomashpolskiy commented Dec 16, 2019

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

Improve this page

Add a description, image, and links to the streaming topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the streaming topic, visit your repo's landing page and select "manage topics."

Learn more

You can’t perform that action at this time.