我在使用phoenix插入数据是,使用了upsert ... on duplicate ...结构,但是在运行的时候报错,现在将错误情况同步出来。
报错信息如下:
2021-12-07 14:08:52
com.aliyun.phoenix.shaded.org.apache.calcite.avatica.AvaticaSqlException: Error -1 (00000) : while preparing SQL: upsert into dwb.test(f_test1,f_test2,f_test3,f_test4,f_test5) values(?,?,?,?,?) ON DUPLICATE KEY UPDATE f_test4= TO_CHAr(TO_NUMBER(f_test4,'###0') + ?,'###0')
at com.aliyun.phoenix.shaded.org.apache.calcite.avatica.Helper.createException(Helper.java:54)
at com.aliyun.phoenix.shaded.org.apache.calcite.avatica.Helper.createException(Helper.java:41)
at com.aliyun.phoenix.shaded.org.apache.calcite.avatica.AvaticaConnection.prepareStatement(AvaticaConnection.java:369)
at com.aliyun.phoenix.shaded.org.apache.calcite.avatica.AvaticaConnection.prepareStatement(AvaticaConnection.java:175)
at org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunctio


