boyuanzz commented on pull request #14801: URL: https://github.com/apache/beam/pull/14801#issuecomment-845327802
Sorry that I misunderstood the execution of `Transform.expand()`. The transform expansion happens during applying a PTransform to a certain PCollection before we calling `runner.run(pipeline)`. So populating experiments doesn't work for our need. Another way I'm thinking about is to have KafkaIO run expansion based on the given runner. It can be done via checking runner class prefix. -- 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. For queries about this service, please contact Infrastructure at: [email protected]
