Using our current statement example to insert data into Flink SQL database table will result in:
Query schema: [order_id: STRING NOT NULL, customer_id: INT NOT NULL, product_id: STRING NOT NULL, price: DOUBLE NOT NULL]
│ Sink schema: [key: BYTES, order_id: STRING, customer_id: INT, product_id: STRING, price: DOUBLE]
Reason being that the Sink schema has additional intrinsic key: BYTES, select everything from the sink schema will cause table mismatch and Flink statement creation failure.
Change
Update the SQL statement explicitly select fields for insert operation between query and sink schema.
:tada: All Contributor License Agreements have been signed. Ready to merge. Please push an empty commit if you would like to re-run the checks to verify CLA status for all contributors.
Summary
Using our current statement example to insert data into Flink SQL database table will result in:
Reason being that the Sink schema has additional intrinsic key: BYTES, select everything from the sink schema will cause table mismatch and Flink statement creation failure.
Change
Update the SQL statement explicitly select fields for insert operation between query and sink schema.
JIRA reference
https://confluentinc.atlassian.net/browse/APIT-2658