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

Disable check for single rowtime attribute for sinks

    XMLWordPrintableJSON

Details

    Description

      A common error that users face is the following:

      The query contains more than one rowtime attribute column [%s] for writing into table '%s'.
      Please select the column that should be used as the event-time timestamp for the 
      table sink by casting all other columns to regular TIMESTAMP or TIMESTAMP_LTZ.
      

      However, not every sink requires the rowtime set on the stream record. For example, the Kafka sink does not use it because it exposes metadata columns. The user can define which column is the rowtime column by projection.

      Either we introduce a config option for disabling this check. Or we come up with an interface that a connector can implement. I would vote for the config option as an easy solution to get rid of this error message.

      Attachments

        Issue Links

          Activity

            People

              twalthr Timo Walther
              twalthr Timo Walther
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: