Hi Folks, I'm running Beam 2.33 using a JobServer on Flink on Kubernetes.
My client is unable to connect to the expansion service running on the job server. Connecting to the other services works fine and I can submit jobs that don't require the expansion service. When I debugged this it looks like the problem is that the code ends up trying to create a secure gRPC channel for the expansion service. I traced the problem to this line https://github.com/apache/beam/blob/4bd217c0d29f88b0b1e0b8211f7bd13a63a6157a/sdks/python/apache_beam/transforms/external.py#L328 When I hacked the code to use an insecure channel it worked. Is this working as intended? Thanks J
