Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-15950 Remove registration of TableSource/TableSink in ConnectTableDescriptor
  3. FLINK-16160

Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

    XMLWordPrintableJSON

    Details

      Description

      In ConnectTableDescriptor#createTemporaryTable, the proctime/rowtime properties are ignored so the generated catalog table is not correct. We should fix this to let TableEnvironment#connect() support watermark.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                docete Zhenghua Gao
                Reporter:
                docete Zhenghua Gao
              • Votes:
                0 Vote for this issue
                Watchers:
                10 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 10m
                  10m