You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "HideOnBush (Jira)" <ji...@apache.org> on 2021/02/20 09:26:00 UTC

[jira] [Created] (FLINK-21424) Flink view cannot use hive temporal

HideOnBush created FLINK-21424:
----------------------------------

             Summary: Flink view cannot use hive temporal
                 Key: FLINK-21424
                 URL: https://issues.apache.org/jira/browse/FLINK-21424
             Project: Flink
          Issue Type: Wish
          Components: Table SQL / API
    Affects Versions: 1.12.0
            Reporter: HideOnBush


{code:java}
Flink view cannot use hive temporal{code}
The kafka table can temporal join Hive Table.

CREATE TABLE kfk_fact_bill_master_pup (

   payLst ROW(groupID int, shopID int, shopName String, isJoinReceived int),

    proctime as PROCTIME()

) WITH (

 'connector' = 'kafka',

 'topic' = 'topic_name',

 'format' = 'json',

);

 

But the next operation will report an error。e.g..

create view test_view as 

  select * from kfk_fact_bill_master_pup;

 

use test_view  temporal join Hive Table will  report error.  and view have proctime field.

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)