Re: Python SDK ReadFromKafka: Timeout expired while fetching topic metadata

I'd like to bump this thread up since I get the same error when trying to read from Kafka in Python SDK: *java.lang.UnsupportedOperationException: The ActiveBundle does not have a registered bundle checkpoint handler.* Can someone familiar with cross-language and Flink verify the problem? I use t

Re: Python SDK ReadFromKafka: Timeout expired while fetching topic metadata

Never mind, I found this thread on user list: https://lists.apache.org/thread.html/raeb69afbd820fdf32b3cf0a273060b6b149f80fa49c7414a1bb60528%40%3Cuser.beam.apache.org%3E, which answers my question. On Mon, Jul 13, 2020 at 4:10 PM Kamil Wasilewski < kamil.wasilew...@polidea.com> wrote: >

Re: Is there an equivalent for --numberOfWorkerHarnessThreads in Python SDK?

/github.com/apache/beam/blob/017936f637b119f0b0c0279a226c9f92a2cf4f15/sdks/python/apache_beam/options/pipeline_options.py#L834 >> >> On Thu, Aug 20, 2020 at 7:33 AM Kamil Wasilewski < >> kamil.wasilew...@polidea.com> wrote: >> >>> Hi all, >>> >>> As

Re: BeamSQL and Beam equivalent -- examples?

Hi Austin, Did you take a look at Nexmark tests? Some of them have two versions: Beam and BeamSQL. It sounds like this is what you are looking for. For example: https://github.com/kamilwu/beam/blob/master/sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query0.java http

Re: [REMOTE WORKSHOPS] Introduction to Apache Beam - remote workshops Dec 3rd and Dec 10th

S at >> Polidea and I'm working with great Apache Beam committers Michał Walenia & >> Kamil Wasilewski who will be carrying out the introductory remote workshops >> to Apache Beam on *Dec 3rd* and *Dec 10th*. >> >> If you're interested in taking part in the