apache / seatunnel

SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.
https://seatunnel.apache.org/
Apache License 2.0
7.81k stars 1.76k forks source link

[Bug] [Seatunnel-api] Unsupported type: Timestamp #7125

Open litiliu opened 2 months ago

litiliu commented 2 months ago

Search before asking

What happened

Timestamp type not supported in the method org.apache.seatunnel.api.table.type.SeaTunnelRow#getBytesForValue(java.lang.Object)

Caused by: java.lang.UnsupportedOperationException: Unsupported type: Timestamp at org.apache.seatunnel.api.table.type.SeaTunnelRow.getBytesForValue(SeaTunnelRow.java:291) at org.apache.seatunnel.api.table.type.SeaTunnelRow.getBytesForValue(SeaTunnelRow.java:287) at org.apache.seatunnel.api.table.type.SeaTunnelRow.getBytesSize(SeaTunnelRow.java:213) at org.apache.seatunnel.translation.flink.sink.FlinkSinkWriter.write(FlinkSinkWriter.java:93) at org.apache.flink.streaming.api.transformations.SinkV1Adapter$SinkWriterV1Adapter.write(SinkV1Adapter.java:136) at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.processElement(SinkWriterOperator.java:160) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)

SeaTunnel Version

2.3.5

SeaTunnel Config

na

Running Command

na

Error Exception

Caused by: java.lang.UnsupportedOperationException: Unsupported type: Timestamp
at org.apache.seatunnel.api.table.type.SeaTunnelRow.getBytesForValue(SeaTunnelRow.java:291)
at org.apache.seatunnel.api.table.type.SeaTunnelRow.getBytesForValue(SeaTunnelRow.java:287)
at org.apache.seatunnel.api.table.type.SeaTunnelRow.getBytesSize(SeaTunnelRow.java:213)
at org.apache.seatunnel.translation.flink.sink.FlinkSinkWriter.write(FlinkSinkWriter.java:93)
at org.apache.flink.streaming.api.transformations.SinkV1Adapter$SinkWriterV1Adapter.write(SinkV1Adapter.java:136)
at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.processElement(SinkWriterOperator.java:160)
at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)

Zeta or Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

No response

Are you willing to submit PR?

Code of Conduct

github-actions[bot] commented 1 month ago

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.