Re:Re: flink sql 写 hive分区表失败

2020-05-28 文章 Zhou Zach
回复的好详细!而且引出了相关的测试用例 Thanks very much! 在 2020-05-28 14:23:33,"Leonard Xu" 写道: > >>|INSERT INTO dwdCatalog.dwd.t1_copy partition (`p_year` = p_year, >> `p_month` = p_month) >>|select id,name from dwdCatalog.dwd.t1 where `p_year` = 2020 and >> `p_month` = 4 >

Re:Re: flink sql 写 hive分区表失败

2020-05-28 文章 Zhou Zach
多谢指点,可以了。 但是换成动态插入,有问题: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: SQL parse failed. Encountered "p_year" at line 3, column 58. Was expecting one of: "DATE" ... "FALSE" ... "INTERVAL" ... "NULL" ... "TIME" ... "TIMESTAMP"