Hi folks, has anyone been executing SQL jobs via t...
# troubleshooting
c
Hi folks, has anyone been executing SQL jobs via the flink k8s operator? It looks like there's an example running SQL jobs wrapped within the table API https://github.com/apache/flink-kubernetes-operator/tree/main/examples/flink-sql-runner-example . It also looks like there's a newish SQL gateway and REST API. Pardon my ignorance but would it be difficult to modify the operator to accept SQL jobs via the rest interface in https://issues.apache.org/jira/browse/FLINK-15472 / https://cwiki.apache.org/confluence/display/FLINK/FLIP-91%3A+Support+SQL+Gateway? Perhaps I can "tool" around. If anyone has any experience or advice with the following perhaps they could suggest how this might be implemented for a demonstration we could share under the apache license.
I'm probably describing a train wreck as idk between flink-k8s-deployment and the sql gateway api endpoint. But maybe I can create a hack until i would commit to doing more.
g
We have not tried integrating the operator with the rest gateway but it would be great to try it !
Let me ping you and we can brainstorm a little about this :)
If someone already has some ideas, please don't hold it back! :)