Skip to content

Commit

Permalink
Format the SQL query for FlinkDeployment example into multiline (#58)
Browse files Browse the repository at this point in the history
  • Loading branch information
tinaselenge authored Nov 15, 2024
1 parent ca6402c commit 3c9cf47
Showing 1 changed file with 23 additions and 3 deletions.
26 changes: 23 additions & 3 deletions examples/FlinkDeployment.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@ kind: FlinkDeployment
metadata:
name: flink-deployment-example
spec:
image: quay.io/streamshub/flink-sql-runner:latest
imagePullPolicy: Never
image: quay.io/streamshub/flink-sql-runner:v0.0.1
imagePullPolicy: Always
flinkVersion: v1_20
flinkConfiguration:
taskmanager.numberOfTaskSlots: "1"
Expand All @@ -20,6 +20,26 @@ spec:
job:
jarURI: local:///opt/streamshub/flink-sql-runner.jar
#Replace the value for "args" with your own SQL statements
args: ["CREATE TABLE orders (order_number BIGINT, price DECIMAL(32,2), buyer ROW<first_name STRING, last_name STRING>, last_name STRING, order_time TIMESTAMP(3)) WITH ('connector' = 'datagen'); CREATE TABLE print_table WITH ('connector' = 'print') LIKE orders; INSERT INTO print_table SELECT * FROM orders;"]
args: ["
CREATE TABLE orders (
order_number BIGINT,
price DECIMAL(32,2),
buyer ROW<first_name STRING,
last_name STRING>,
last_name STRING,
order_time TIMESTAMP(3)
) WITH (
'connector' = 'datagen'
);
CREATE TABLE print_table
WITH (
'connector' = 'print'
)
LIKE orders
;
INSERT INTO print_table
SELECT *
FROM orders;
"]
parallelism: 1
upgradeMode: stateless

0 comments on commit 3c9cf47

Please sign in to comment.