Hello Team, I was hoping to get anyones help with an error I'm encountering in running SDF.
Posted the question imn stack overflow (includes code) https://stackoverflow.com/questions/63252327/error-in-running-apache-beam-python-splittabledofn However I am receiving a error RuntimeError: Transform node AppliedPTransform(ParDo(TestDoFn)/ProcessKeyedElements/GroupByKey/GroupByKey, _GroupByKeyOnly) was not replaced as expected. when trying to apply a SDF to a pubsubIO source Thanks in advance!! Really!! Mayank
