Lukasz Cwik

What tests are they? I'm curious if there is some trivial pattern to them that is causing the test to fail.

The ThreadPoolExecutor implementation uses a synchronous queue meaning that scheduling a task will block till a thread takes it. Could this be the difference?

@kellen Filed https://github.com/apache/beam/issues/23809 with a fix in https://github.com/apache/beam/pull/23811 based upon your supplied patch

@kellen If you could review the PR then we could have it merged. Comment LGTM on PR if it looks good to you.

The error seen in SCIO was: ``` input: KV(MaterializedCoder(StringUtf8Coder), MaterializedCoder(VarIntCoder)) expected output KV(MaterializedCoder(StringUtf8Coder), Iterable(MaterializedCoder(VarIntCoder)) actual output KV(MaterializedCoder(StringUtf8Coder), MaterializedCoder(Iterable(VarIntCoder)) ``` It seems as though there is logic already in SCIO to...

> I just stumbled upon this PR while searching for the ZstdCoder PR. I had been thinking of writing a PipelineVisitor to do this, so it's a fun surprise to...

Note that beam_fn_api uses Dataflow runner v2 as of https://github.com/apache/beam/pull/24513, is there a difference in the job graphs being generated between the two now?

Thanks for fixing this.

When they are in my maven repo it gets passed the `FAILED DOWNLOADS`. After removing them from my local maven repo, I get the `FAILED DOWNLOADS` when attempting to perform...

We are also interested in using this plugin as part of Apache Beam but Apache doesn't allow for LGPL licenses to be used, see: https://www.apache.org/legal/resolved.html#category-x Any possibility to swap to...