rickiesmooth opened a new issue, #23693:
URL: https://github.com/apache/beam/issues/23693
### What happened?
versions:
apache-beam==2.41.0
apache-beam[gcp, aws]==2.41.0
when starting a DataFlow streaming job that uses `ReadDataFromKinesis`, I
see that it registers the following transforms:
```
INFO:apache_beam.utils.subprocess_server:Oct 18, 2022 12:25:08 PM
org.apache.beam.sdk.expansion.service.ExpansionService loadRegisteredTransforms
INFO:apache_beam.utils.subprocess_server:INFO: Registering external
transforms: [beam:transform:org.apache.beam:kinesis_write:v1,
beam:transform:org.apache.beam:kinesis_read_data:v1,
beam:external:java:generate_sequence:v1]
```
But I finally see the following error
```
RuntimeError: java.lang.UnsupportedOperationException: Unknown urn:
beam:transform:org.apache.beam:kinesis_read:v1
```
So I tried patching the `ReadDataFromKinesis` class locally:
```
class ReadDataFromKinesis(ExternalTransform):
URN = 'beam:transform:org.apache.beam:kinesis_read_data:v1'
...
```
And that fixed the issue.
### Issue Priority
Priority: 1
### Issue Component
Component: io-py-aws
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
