Add SQL parsing from env var

[piotrpdev]

Description

Resolves #84
Testing: streamshub/streams-e2e#151

Adds ability to parse SQL from environment variable (key is hard-coded) e.g. like this:

# recommendation-app.sql
CREATE TABLE ClickStreamTable
# ... more SQL ...

kubectl create configmap -n flink recommendation-app-sql \
  --from-file=SQL_STATEMENTS=recommendation-app.sql

# flink-deployment.yaml
# Only relevant parts included
apiVersion: flink.apache.org/v1beta1
kind: FlinkDeployment
spec:
  image: quay.io/streamshub/flink-sql-runner:0.2.0
  podTemplate:
    kind: Pod
    spec:
      containers:
        - name: flink-main-container
          envFrom:
            - configMapRef:
                name: recommendation-app-sql
  job:
    jarURI: local:///opt/streamshub/flink-sql-runner.jar
    parallelism: 1
    upgradeMode: stateless

Type of Change

• New feature (non-breaking change which adds functionality)

Testing

Packit test job with smoke subset of tests is triggered by default.
If you want to run full flink test profile please type a following comment

/packit test --labels flink-all

[piotrpdev]

@tomncooper The code is throwing a generic exception like before, but SonarQube is complaining. Should I change it to an IllegalArgumentException or just silence the warning somehow?

[kornys]

IllegalArgumentException would be better

[tomncooper]

I'm glad this didn't turn out to be too complicated.

Can you also update the docs to describe this as an option and how users can use it.

We will also need to add coverage for this to the streams-e2e tests.

[sonarqubecloud]

Quality Gate passed

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud