Hi, > |select * from dwdCatalog.dwd.t1 where `p_year` = 2020 and `p_month` = > 5
应该是 select * 会把分区字段一起带出来吧，你字段就不匹配了，select里加上你需要的字段吧 祝好， Leonard Xu > 在 2020年5月28日，12:57，Zhou Zach <[email protected]> 写道： > > org.apache.flink.client.program.ProgramInvocationException: The main method > caused an error: Field types of query result and registered TableSink > dwdCatalog.dwd.t1_copy do not match. > > Query schema: [id: BIGINT, name: STRING, p_year: INT, p_month: INT, EXPR$4: > INT NOT NULL, EXPR$5: INT NOT NULL] > > Sink schema: [id: BIGINT, name: STRING, p_year: INT, p_month: INT] > > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:335) > > at > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:205) > > at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:138) > > at > org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:664) > > at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:213) > > at > org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:895) > > at > org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:968) > > at java.security.AccessController.doPrivileged(Native Method) > > at javax.security.auth.Subject.doAs(Subject.java:422) > > at > org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1875) > > at > org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) > > at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:968) > > > > > hive分区表： > CREATE TABLE `dwd.t1`( > `id` bigint, > `name` string) > PARTITIONED BY ( > `p_year` int, > `p_month` int) > > > CREATE TABLE `dwd.t1_copy`( > `id` bigint, > `name` string) > PARTITIONED BY ( > `p_year` int, > `p_month` int) > > > Flink sql: > tableEnv.sqlUpdate( > """ > | > |INSERT INTO dwdCatalog.dwd.t1_copy partition (`p_year` = 2020, > `p_month` = 5) > |select * from dwdCatalog.dwd.t1 where `p_year` = 2020 and `p_month` = > 5 > | > |""".stripMargin) > > > thanks for your help
