TheNeuralBit commented on issue #22709:
URL: https://github.com/apache/beam/issues/22709#issuecomment-1224930608
I tried sql_taxi on FlinkRunner on various released SDKs, it's failing even
on 2.24.0, when it was first introduced. So I guess I was imagining running it
with Flink. Note the error is different in 2.24.0 though:
```
INFO:apache_beam.utils.subprocess_server:b'[flink-runner-job-invoker] INFO
org.apache.beam.runners.flink.FlinkPipelineRunner - Translating pipeline to
Flink program.'
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STOPPED
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STARTING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
RUNNING
INFO:apache_beam.utils.subprocess_server:b'[flink-runner-job-invoker] ERROR
org.apache.beam.runners.jobsubmission.JobInvocation - Error during job
invocation
BeamApp-bhulette-0823215552-533f1c9e_b699066c-ad87-4224-8dd4-f2a7da741b13.
'
INFO:apache_beam.utils.subprocess_server:b'java.lang.IllegalArgumentException:
GreedyPipelineFuser requires all root nodes to be runner-implemented
beam:transform:impulse:v1 or beam:transform:read:v1 primitives, but transform
ref_Ap
pliedPTransform_ReadFromPubSub/Read_3 executes in environment Optional[urn:
"beam:env:external:v1"'
INFO:apache_beam.utils.subprocess_server:b'payload:
"\\n\\021\\n\\017localhost:46343"'
INFO:apache_beam.utils.subprocess_server:b'capabilities:
"beam:coder:bytes:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities:
"beam:coder:string_utf8:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: "beam:coder:kv:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities:
"beam:coder:bool:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities:
"beam:coder:varint:v1"'
...
```
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
