search

dyrnq / cdc-vagrant

CDC(Change Data Capture) is made up of two components, the CDD and the CDT. CDD is stand for Change Data Detection and CDT is stand for Change Data Transfer.
https://nightlies.apache.org/flink/flink-cdc-docs-stable/
0 stars 0 forks source link

org.apache.doris.shaded.com.fasterxml.jackson.databind.exc.InvalidFormatException: Cannot deserialize value of type `int` from String " #17

Closed dyrnq closed 1 year ago

dyrnq commented 1 year ago 
Flink SQL>  INSERT INTO enriched_orders_doris
>  SELECT o.*, p.name, p.description, s.shipment_id, s.origin, s.destination, s.is_arrived
>  FROM orders AS o
>  LEFT JOIN products AS p ON o.product_id = p.id
>  LEFT JOIN shipments AS s ON o.order_id = s.order_id;
[INFO] Submitting SQL update statement to the cluster...
[ERROR] Could not execute SQL statement. Reason:
org.apache.doris.shaded.com.fasterxml.jackson.databind.exc.InvalidFormatException: Cannot deserialize value of type `int` from String "errCode = 7, detailMessage = unknown databases, dbName=default_cluster:db": not a valid `int` value
 at [Source: (String)""errCode = 7, detailMessage = unknown databases, dbName=default_cluster:db""; line: 1, column: 1]
dyrnq commented 1 year ago

xref https://github.com/apache/doris/issues/100

dyrnq commented 1 year ago 
[INFO] Submitting SQL update statement to the cluster...
[ERROR] Could not execute SQL statement. Reason:
org.apache.doris.shaded.com.fasterxml.jackson.databind.exc.InvalidFormatException: Cannot deserialize value of type `int` from String "errCode = 7, detailMessage = unknown table, tableName=table": not a valid `int` value
 at [Source: (String)""errCode = 7, detailMessage = unknown table, tableName=table""; line: 1, column: 1]
dyrnq commented 1 year ago

must creae database and table in doris before exec flink sql DDL.