字段写入 PostgreSQL 的 DDL yidun_score 会报异常-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

字段写入 PostgreSQL 的 DDL yidun_score 会报异常

2021-12-02 16:32:05 254 1

我定义的一个表的一个字段(yidun_score)是 numeric(5,2) 类型,写入 PostgreSQL 的 DDL yidun_score  字段也是定义的 numeric(5,2) 类型,结果会报异常。 

org.apache.flink.client.program.ProgramInvocationException: The main method  caused an error: Field types of query result and registered TableSink  [Result] do not match.  Query result schema: [user_new_id: Long, total_credit_score: Integer,  total_order_count: Integer, loss_total_order_count: Integer, yidun_score:  BigDecimal, is_delete: Boolean]  TableSink schema: [user_new_id: Long, total_credit_score: Integer,  total_order_count: Integer, loss_total_order_count: Integer, yidun_score:  BigDecimal, is_delete: Boolean]  at  org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:593)  at  org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:438)  at  org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:83)  at  org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:80)  at  org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:122)  at org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:227)  at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:205)  at  org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1010)  at  org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)  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:1698)  at  org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)  at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083)  Caused by: org.apache.flink.table.api.ValidationException: Field types of  query result and registered TableSink [Result] do not match.  Query result schema: [user_new_id: Long, total_credit_score: Integer,  total_order_count: Integer, loss_total_order_count: Integer, yidun_score:  BigDecimal, is_delete: Boolean]  TableSink schema: [user_new_id: Long, total_credit_score: Integer,  total_order_count: Integer, loss_total_order_count: Integer, yidun_score:  BigDecimal, is_delete: Boolean]  at  org.apache.flink.table.planner.sinks.TableSinkUtils$.validateSink(TableSinkUtils.scala:69)  at  org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$2.apply(PlannerBase.scala:179)  at  org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$2.apply(PlannerBase.scala:178)  at scala.Option.map(Option.scala:146)  at  org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:178)  at  org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$1.apply(PlannerBase.scala:146)  at  org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$1.apply(PlannerBase.scala:146)  at  scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)  at  scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)  at scala.collection.Iterator$class.foreach(Iterator.scala:891) 

我后面把 numeric(5,2) 类型都改成 double,结果发现就不报异常了,可以正常将数据写入 PG,不知道这个 case 是不是一个 bug?*来自志愿者整理的flink邮件归档

取消 提交回答
全部回答(1)
  • 又出bug了--
    2021-12-02 17:24:46

    你用的是1.9吗? 试过 1.10.0 blink planner 么?*来自志愿者整理的FLINK邮件归档

    0 0
相关问答

1

回答

什么是Socrates 的架构中的Page Servers 存储层?

2022-09-12 14:14:03 138浏览量 回答数 1

1

回答

《PolarDB for Postgres SQL 》主要讲了什么?

2022-07-13 14:52:55 534浏览量 回答数 1

1

回答

在数据库管理客户端中,HeidiSQL 是什么呢?它支持哪些系统呢?

2022-04-01 13:51:03 480浏览量 回答数 1

1

回答

PostgreSQL操作系统优化为什么要使用大页?

2021-12-23 10:11:04 299浏览量 回答数 1

1

回答

Hadoop跨集群数据拷贝工具DISTCP内部源码-m <num_maps>的主要备注和内容是什么?

2021-12-06 06:20:41 157浏览量 回答数 1

1

回答

Hadoop跨集群数据拷贝工具DISTCP内部源码-p[rbugp]的主要备注和内容是什么?

2021-12-06 00:20:14 110浏览量 回答数 1

1

回答

mockMvc,在SpringBoot中从json文件获取内容

2019-10-09 19:29:16 705浏览量 回答数 1

1

回答

采用web直传oss,当页面刷新的时候,上传中断了,请问如果存储用户选择的视频文件呢

2019-08-21 15:38:24 469浏览量 回答数 1

1

回答

springboot+socket +centos7,启动方式为jar包启动,socket服务端口10020(防火墙已关),socket调试工具连接不上

2018-01-16 12:48:56 4212浏览量 回答数 1

3

回答

什么样的网站和场景才会用PostgreSQL?MySql搞不定?

2016-02-03 13:09:24 5469浏览量 回答数 3
文章
问答
问答排行榜
最热
最新
相关电子书
更多
PolarDB for PostgreSQL三节点功能介绍
立即下载
为什么PostgreSQL是最适合去O的数据库
立即下载
Oracle 至PostgreSQL案例分享
立即下载