Hi,I have come across an issue using PubsubIO with flink runner. The problem is described at [1]. I also created PR for this: [2], but there are some doubts described in comment in the JIRA issue. Would someone have time to walk through it and/or provide some insights?
Thanks, Jan [1] https://issues.apache.org/jira/browse/BEAM-6873. [2] https://github.com/apache/beam/pull/8105
