You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I've been trying to use the operator for a while now, but something that I don't fully understand is what versions of Flink are supported? When you deploy a cluster, in the spec you specify a Flink Version and the image. It's been a while since I looked at the code I wrote, but for now I've configured it like this:
However, when I deploy the config now, I get the following error:
RuntimeError: Unable to fetch remote job server jar at https://repo.maven.apache.org/maven2/org/apache/beam/beam-runners-flink-1.10-job-server/2.38.0/beam-runners-flink-1.10-job-server-2.38.0.jar: HTTP Error 404: Not Found
That makes sense, the JAR file doesn't exist. I think I solved this back in the days, but I can't remember how to be honest. When I look at the examples, they still point to Flink 1.8 and 1.9, which seems like quite old versions of Flink.
So, is there a way to know what versions are supported? I also don't know where the URL is configured of that job server jar, unless that's done in the image itself.
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
I've been trying to use the operator for a while now, but something that I don't fully understand is what versions of Flink are supported? When you deploy a cluster, in the spec you specify a Flink Version and the image. It's been a while since I looked at the code I wrote, but for now I've configured it like this:
However, when I deploy the config now, I get the following error:
That makes sense, the JAR file doesn't exist. I think I solved this back in the days, but I can't remember how to be honest. When I look at the examples, they still point to Flink 1.8 and 1.9, which seems like quite old versions of Flink.
So, is there a way to know what versions are supported? I also don't know where the URL is configured of that job server jar, unless that's done in the image itself.
Beta Was this translation helpful? Give feedback.
All reactions