[jira] [Created] (FLINK-30746) Flink Table / SQL Column types of query result and sink for do not match, but should

["Colin Williams (Jira)" <ji...@apache.org>]

Colin Williams created FLINK-30746:
--------------------------------------

             Summary: Flink Table / SQL Column types of query result and sink for do not match, but should
                 Key: FLINK-30746
                 URL: https://issues.apache.org/jira/browse/FLINK-30746
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / API
    Affects Versions: 1.16.0
            Reporter: Colin Williams


For the branch `table-example` in the `table-example` directory [https://github.com/apple-corps/recipes/tree/table-example/table-example] we provide a test job [https://github.com/apple-corps/recipes/blob/table-example/table-example/src/test/java/TableJobTest.java]

When we run the job, for example with `mvn install` we get:

```

org.apache.flink.table.api.ValidationException: 
Column types of query result and sink for 'temporaryCatalog.default.enrichmentOut' do not match.
Cause: Incompatible types for sink column 'enrichment' at position 2.

Query schema: [id: STRING NOT NULL, status: STRING NOT NULL, ts: TIMESTAMP(3) *ROWTIME*, enrichment: STRING NOT NULL]
Sink schema:  [id: STRING, status: STRING, enrichment: STRING, ts: TIMESTAMP(3)]
    at TableJobTest.testExecuteSQL(TableJobTest.java:83)
```

However by the schemas the sink schema should be showing compatible types. [https://github.com/apple-corps/recipes/blob/table-example/table-example/src/main/java/com/immerok/cookbook/schemas/Schemas.java]

One curiousity is the *{*}ROWTIME*{*} which we see in the Query Schema but not in the Sink schema.

This issue has been discussed in https://apache-flink.slack.com/archives/C03G7LJTS2G/p1673979671298779



--
This message was sent by Atlassian Jira
(v8.20.10#820010)