[Bug] Flink Kafka-to-Doris sync: Type conversion exception

[Jack-Qin-King]

Search before asking

• I had searched in the issues and found no similar issues.

Version

4.0.1

What's Wrong?

Type conversion exception during real-time Kafka to Doris import using Flink

Why does Doris recognize Flink's type as LARGEINT?
error msg :
For example:
1:

2: Bad cast from type:doris::vectorized::ColumnVector<(doris::PrimitiveType)3>* to doris::vectorized::ColumnVector<(doris::PrimitiveType)6>*

3:Bad cast from type:doris::vectorized::ColumnVector<(doris::PrimitiveType)6> to doris::vectorized::ColumnStr const

What You Expected?

fix the bug

How to Reproduce?

No response

Anything Else?

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[plchy2]

I’d like to investigate this issue.
From the stack trace, it appears that Doris accepts an incompatible type mapping during Kafka–Flink ingestion and later fails with a Bad cast in the vectorized column conversion.
I plan to trace where external types are mapped to Doris PrimitiveType and check whether additional validation or safer conversion should be added to fail earlier with a clearer error. I’ll update here once I have more findings.