> When I check the expansion service docker container, normally it
downloads a JAR file and starts SDK Fn Harness
To clarify the terminology here, I think you meant the Java SDK harness
container not the expansion service. Expansion service is only needed
during job submission and your failure is
Hello,
Attached includes more logging details.
WARNING:root:Waiting for grpc channel to be ready at localhost:45371.
INFO:root:Building pipeline ...
INFO:apache_beam.runners.worker.worker_pool_main:Listening for workers at
localhost:36959
INFO:apache_beam.runners.portability.fn_api_runner.transla
Hello,
✔️ I have a simple pipeline that transforms data with *SqlTransform*. I use
the *FlinkRunner *and, when I don't specify the *flink_master *option and
use an embedded flink cluster, it works fine. However, if I use a local
flink cluster and specify the *flink_master *option to *localhost:808
