我往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

以下为热心网友提供的参考意见

尝试修改列类型,Hologres不支持这种修改。具体来说,您尝试修改将名为“pay_status”的列修改为,但是Hologres无法完成这种VARCHAR(20) NOT NULL修改VARCHAR(20)。
要解决这个问题,您需要确保在向Hologres插入数据之前,表结构已经正确设置。这可能意味着您需要更改Hologres表结构以匹配您要插入的数据,或者更改您的数据以匹配Hologres表结构。
如果您想了解更多有关此错误的信息,可以查阅 Hologres 的文档以了解有关数据类型和列约束的信息。

https://www.alibabacloud.com/help/zh/hologres/

本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/18625.html

(0)
匿名
上一篇 2023年12月25日
下一篇 2023年12月25日

相关推荐

新手站长从“心”出发,感谢16年您始终不离不弃。