saiteja2021 opened a new issue, #30400:
URL: https://github.com/apache/beam/issues/30400
```
test_records = p | 'Read CSV' >> beam.dataframe.io.read_csv(input_csv) |
'Parse CSV' >> beam.ParDo(ProcessCSV())
test_records | 'write data' >>beam.ParDo(PrintData())
class ProcessCSV(beam.DoFn):
def process(self, element):
callid, recording_url=element.call_id, element.url
print( callid, recording_url)
return str(callid), str(recording_url)
class PrintData(beam.DoFn):
def process(self, element):
print(element)
```
error --> RuntimeError: A transform with label "ToPCollection(self)" already
exists in the pipeline. To apply a transform with a specified label write
pvalue | "label" >> transform
i am using different labels and tried multiple ways to figure out the issue.
But No luck.
Any help is highly appreciated ..!!
--
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]
