The PIPELINE cannot be submitted to the Flink environment for running
- Dominant language
- Java
- Stars
- 1.5k
- Forks
- 476
- Avg merge
- 18h 33m
- Merged PRs (30d)
- 204
Description
### Apache Hop version?
2.4
### Java version?
11
### Operating system
Windows
### What happened?
environment: Flink->1.15.3 , Hop -> 2.4 , JDK->11
I wanted to put the PIPELINE file in the Flink environment for execution, but the following error was reported?
ERROR:Class org.apache.beam.model.pipeline.v1.RunnerApi$StandardResourceHints$Enum does not implement the requested interface org.apache.beam.vendor.grpc.v1p43p2.com.google.protobuf.ProtocolMessageEnum
How can I fix it?
### Issue Priority
Priority: 3
### Issue Component
Component: Beam
Contributor guide
Research direction
Reproduce pipeline submission in the stated Apache Hop 2.4, Flink 1.15.3, and JDK 11 environment, using the reported ProtocolMessageEnum error as the starting point. Inspect the Beam/Flink integration and dependency versions involved; done means the pipeline can be submitted to Flink and run without this error.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- data-engineering, distributed-systems
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 30/100