Behavior change for Gradle build target

Hi, I just noticed that the result jars produced by command "./gradlew :sdks:java:io:expansion-service:build" went from both shaded [1] and unshaded [2] jars for Beam 2.24.0 branch to just the unshaded jar [3] for Beam 2.25.0 branch. Does anyone know what resulted in this behaviour change ?

Re: contributor permission for Beam Jira tickets

Thanks Alexey! From: Alexey Romanenko Sent: Monday, September 28, 2020 3:31 AM To: dev Subject: Re: contributor permission for Beam Jira tickets Hi Yichuan, I added you to contributors list. Welcome to the project! Alexey On 27 Sep 2020, at 01:11, Yichuan

Re: How to write a Python wrapper for MQTT io

It is also very important to document the URN and describe its configuration payload so that a new Beam SDK who wants to use the XLang transform knows what the spec is and that if the XLang implementation were to change it can still honor the original spec. +Chamikara Jayalath , is there a good

Re: How to write a Python wrapper for MQTT io

Hi Carolyn, welcome to the dev list :) I'm assuming you're interested in making Java's MqttIO [1] available in Python as a cross-language transform? Unfortunately I don't think there's a concise guide for this yet. It definitely makes sense to follow KafkaIO as an example, but I know there's a

How to write a Python wrapper for MQTT io

Greetings, I need Python MQTT IO support for a project I'm working on. I've looked at the Kafka IO module, and planned to follow it, but I'm having trouble finding the URN to use, and how to configure the input parameters. Is there any documentation about this? If not, I'd appreciate an

How to write a Python wrapper for MQTT io

Greetings, I need Python MQTT IO support for a project I'm working on. I've looked at the Kafka IO module, and planned to follow it, but I'm having trouble finding the URN to use, and how to configure the input parameters. Is there any documentation about this? If not, I'd appreciate an

Re: [External] Re: DISCUSS: Sorted MapState API

On Wed, Sep 16, 2020 at 8:48 AM Tyson Hamilton wrote: > The use case is to support an unbounded stream-stream join, where the > elements are arriving in roughly time sorted order. Removing a specific > element from the timestamp indexed collection is necessary when a match is > found. > Just

How to write a Python wrapper for MQTT io

Greetings, I need Python MQTT IO support for a project I'm working on. I've looked at the Kafka IO module, and planned to follow it, but I'm having trouble finding the URN to use, and how to configure the input parameters. Is there any documentation about this? If not, I'd appreciate an

Beam Dependency Check Report (2020-09-28)

ERROR: File 'src/build/dependencyUpdates/beam-dependency-check-report.html' does not exist

Re: contributor permission for Beam Jira tickets

Hi Yichuan, I added you to contributors list. Welcome to the project! Alexey > On 27 Sep 2020, at 01:11, Yichuan Wang wrote: > > Hi Team, > > This is Yichuan Wang. I'd like to contribute to Apache Beam for learning > experience. Can someone add me as a contributor for Beam's Jira issue >