Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-33511

flink SqlGateway select bigint type column get cast exception

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.18.0
    • None
    • Table SQL / Gateway
    • None

    Description

      when i open a beeline client connect to flink sqlgateway;

      i create table like

      //代码占位符
      CREATE TABLE Orders (
          order_number BIGINT,
          price        DECIMAL(32,2),
          buyer        ROW<first_name STRING, last_name STRING>,
          order_time   TIMESTAMP(3)
      ) WITH (
        'connector' = 'datagen'
      ) 

      and then select * from Orders;

      i got exception:

      java.lang.Long cannot be cast to org.apache.flink.table.data.StringData

      Attachments

        Activity

          People

            Unassigned Unassigned
            xiaodao xiaodao
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: