You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
rw-streaming risingwave_stream::task::stream_manager: actor exit with error actor_id=21 error=Executor error: Sink error: DeltaLake error: convert record batch error: Convert from arrow error: Cast error: Casting from LargeBinary to Decimal128(10, 0) not supported
in spark:
createtabledelta.`s3a://deltalake/decimal`(id int, d ARRAY<decimal>) using delta;
rw:
CREATETABLEdecimal_test (
id int,
d decimal[]
);
INSERT INTO decimal_test VALUES (1, array[]::decimal[]);
create sink decimal_sink from decimal_test
with (
connector ='deltalake',
type ='append-only',
force_append_only='true',
location ='s3a://deltalake/decimal',
s3.access.key ='hummockadmin',
s3.secret.key ='hummockadmin',
s3.endpoint='http://minio-0:9301'
);
The text was updated successfully, but these errors were encountered:
in spark:
rw:
The text was updated successfully, but these errors were encountered: