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

Support TIMESTAMP WITH LOCAL TIME ZONE type for datagen source

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.11.1, 1.11.2
    • Fix Version/s: None
    • Component/s: Table SQL / Ecosystem
    • Labels:

      Description

      TABLE DDL:

      // code placeholder
      CREATE TABLE sourceTable (
       userid int,
       f_random_str STRING,
       order_time TIMESTAMP(3) WITH LOCAL TIME ZONE
      ) WITH (
       'connector' = 'datagen',
       'rows-per-second'='100',
       'fields.userid.kind'='random',
       'fields.userid.min'='1',
       'fields.userid.max'='100',
      'fields.f_random_str.length'='10'
      );
      
      CREATE TABLE print_table (
       userid int,
       f_random_str STRING,
       order_time TIMESTAMP(3) WITH LOCAL TIME ZONE
      ) WITH (
       'connector' = 'print'
      );

      The DML SQL:

      // code placeholder
      insert into default_catalog.default_database.print_table select * from default_catalog.default_database.sourceTable;

      Exception:

      // code placeholder
      Flink SQL> insert into default_catalog.default_database.print_table select * from default_catalog.default_database.sourceTable;
      [ERROR] Could not execute SQL statement. Reason:
      org.apache.flink.table.api.ValidationException: Unsupported type: TIMESTAMP(3) WITH LOCAL TIME ZONE
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              x1q1j1 Forward Xu
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated: