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

ExternalTableSource should add time attributes in the row type

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Critical
    • Resolution: Fixed
    • None
    • 1.3.1, 1.4.0
    • Table SQL / API
    • None

    Description

      We observed that all streaming queries that refer to external tables fail when the Volcano planner converting LogicalTableScan to FlinkLogicalTableSourceScan:

      Type mismatch:
      rowtype of new rel:
      RecordType(<table schema>, TIMESTAMP(3) NOT NULL proctime) NOT NULL
      rowtype of set:
      RecordType(<table schema>, ...) NOT NULL
      

      Tables that are registered through StreamTableEnvironment#registerTableSource() do not suffer from this problem as StreamTableSourceTable adds the processing time / event time attribute automatically.

      Attachments

        Issue Links

          Activity

            People

              wheat9 Haohui Mai
              wheat9 Haohui Mai
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: