Hi, I am trying to test a simple kafka consumer using Apache Hop v1.2. When I run the pipeline using the local runner, it works fine. But if I run it using the flink runner I get the following error
You can only have one copy of the injector transform 'output' to accept the Kafka messages I have tried debugging the Hop code and looks like the root cause is the initSubPipeline() method being invoked multiple times while using the Flink runner. That's not the case when I use the local runner. Am I missing something here? Thanks Monajit Choudhury Linkedin <https://www.linkedin.com/in/monajit-choudhury-b1409a2/>
