开发者社区> 问答> 正文

Flink eventTIme问题怎么处理?

Hi all     When I use SQL with UDTF, when I call the tableEnv.sqlQuery () method, I throw the following error: Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before. I used the to_timestamp function in eventTIme and it doesn't work, How to solve the problem? 

sql: select  

                  tmp.metric_id as metric_id,  

                  tmp.metric_config as metric_config,  

                  startLat,  

                  destName,  

                  bizType,  

                  orderId,  

                  completedTime,  

                  orderStatus,  

                  startHexList,  

                  cityId,  

                  type,  

                  destLat,  

                  endHexList,  

                  destLng,  

                  createTime,  

                  passengerId,  

                  finishedTime,  

                  vehicleId,  

                  startLng,  

                  startName,  

                  eventTime  

                from  

                  htw_order_dwd_htw_order_geo_Infos,  

                  lateral table( 

                    metricUdtf('aa') 

                  ) as tmp(metric_id, metric_config)*来自志愿者整理的flink邮件归档

展开
收起
又出bug了-- 2021-12-02 11:39:42 608 0
1 条回答
写回答
取消 提交回答
  • Could you share table definitions and both queries?*来自志愿者整理的FLINK邮件归档

    2021-12-02 14:23:10
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载