我往Hologres里面插入数据。为什么老是报错？
我往Hologres里面插入数据。为什么老是报错？ Caused by: org.apache.flink.table.api.TableException: Could not modify column pay_status from DataType VARCHAR(20) NOT NULL (normalized to STRING NOT NULL) to VARCHAR(20) (normalized to STRING)
at com.alibaba.ververica.connectors.hologres.sink.listener.HologresSchemaChangeListener.lambda$checkModifyColumnTypes$3(HologresSchemaChangeListener.java:204)
at java.util.ArrayList.forEach(ArrayList.java:1249)
at com.alibaba.ververica.connectors.hologres.sink.listener.HologresSchemaChangeListener.checkModifyColumnTypes(HologresSchemaChangeListener.java:190)
at com.alibaba.ververica.connectors.hologres.sink.listener.HologresSchemaChangeListener.onTableChanged(HologresSchemaChangeListener.java:71)
at org.apache.flink.table.runtime.operators.evolution.SchemaEvolutionOperator.lambda$notifySchemaChange$1(SchemaEvolutionOperator.java:191)
at java.util.ArrayList.forEach(ArrayList.java:1249)
at org.apache.flink.table.runtime.operators.evolution.SchemaEvolutionOperator.notifySchemaChange(SchemaEvolutionOperator.java:191)
at org.apache.flink.table.runtime.operators.evolution.SchemaEvolutionOperator.processElement(SchemaEvolutionOperator.java:163)
at org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:94)
... 33 more
写回答
-
北京阿里云ACE会长尝试修改列类型，Hologres不支持这种修改。具体来说，您尝试修改将名为“pay_status”的列修改为，但是Hologres无法完成这种VARCHAR(20) NOT NULL修改VARCHAR(20)。
要解决这个问题，您需要确保在向Hologres插入数据之前，表结构已经正确设置。这可能意味着您需要更改Hologres表结构以匹配您要插入的数据，或者更改您的数据以匹配Hologres表结构。
如果您想了解更多有关此错误的信息，可以查阅 Hologres 的文档以了解有关数据类型和列约束的信息。2023-12-25 08:57:32赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本技术圈将为大家分析有关阿里云产品Hologres的最新产品动态、技术解读等，也欢迎大家加入钉钉群--实时数仓Hologres交流群32314975
