distributed-systems

What happened?

If you don't pass a --name argument to your etcd processes, they will all have the name default and the cluster will operate normally. However, when you add a member, the generated ETCD_INITIAL_CLUSTER variable will have multiple entries with the name "default". When this environment variable is used, etcd will parse these into a mapping under a single key ("defau

Currently many more Python projects like dask and optuna are using Python type hints. With the Python package of xgboost gaining more and more features, we should also adopt mypy as a safe guard against some type errors and for better code documentation.

ActorAdapter will ignore null message with "Adapter function returned null which is not valid as an .."

However, this seems not be documented. For instance, scaladoc/javadoc of pipeToSelf could mention it as well as any other place where adapters are used.

Let's support at least reading "b3" header from a single string, most commonly traceid-spanid-1
It would also be nice to support optionally writing this, especially in message providers or others with constrained environments.

Expected behavior

As discussed on openzipkin/b3-propagation#21 and first implemented here: https://github.com/openzipkin/brave/blob/master/brave/src/main/java/bra

Is your feature request related to a problem? Please describe.

I'd like to be able to debug cadence's space usage by breaking down the size of history events by workflow type. But currently I cannot.

Proposed Solution

Proposed by @longquanzheng in the cadence slack: track a historySize in ES so we can query it for aggregation.

Additional context

https://uber-cadence.sl

The similar issue with https://github.com/trinodb/trino/issues/10857 and https://github.com/trinodb/trino/issues/11110

trino> CREATE VIEW accumulo .schema_not_found.test AS SELECT 1 AS c1;
CREATE VIEW

Describe the bug
The IMap.get() call will be blocked forever when a com.datastax.oss.driver.api.core.NoNodeAvailableException is thrown from the MapStore.

Setup:
Hazelcast v5.1.1
Cassandra SDK v4.14.1
Client-server setup
Read through cache, Cassandra DB gets called on a cache miss.

Test scenario: Read through cache, Cassandra server is down:

We tested the scenario whe

Need to fix this TODO in the code:

         // TODO: we need to consider adding execution time to mutable state
	// For now execution time will be calculated based on start time and cron schedule/retry policy
	// each time DescribeWorkflowExecution is called.

https://github.com/temporalio/temporal/blob/master/service/history/historyEngine.go#L1184

Is your feature request related to a problem? Please describe.

This is the logic currently implemented in the main branch:

If headers criteria are configured, a request is filtered in if it matches both headers and urls. If headers criteria are NOT configured, the probability options are used.

Describe the solution you'd like

I want to take the URL check when no header is

If you are using Conductor at the company you work with, add the name of your company and your Github handle to the list at https://github.com/netflix/conductor/blob/main/WHOSUSING.md