What happened?
RAW_BYTES decoding appears broken. sourceSchema() returns AttributeType.ANY instead of a concrete type, and downstream execution fails with: ANY type is not supported in Iceberg. This blocks any workflow that materializes a RAW_BYTES-decoded source into Iceberg storage. Likely a follow-up to recent decoding/schema-inference changes — filing as a separate issue to track.
How to reproduce?
- Configure a source operator using RAW_BYTES decoding.
- Observe that sourceSchema() yields AttributeType.ANY for the decoded column.
- Run the workflow so the result is written to Iceberg.
- Execution fails with ANY type, which is not supported in Iceberg.
Expected: sourceSchema() returns a concrete AttributeType (e.g., BINARY) so Iceberg materialization succeeds.
Branch
main
Commit Hash (Optional)
No response
What browsers are you seeing the problem on?
No response
Relevant log output
What happened?
RAW_BYTES decoding appears broken. sourceSchema() returns AttributeType.ANY instead of a concrete type, and downstream execution fails with:
ANY type is not supported in Iceberg. This blocks any workflow that materializes a RAW_BYTES-decoded source into Iceberg storage. Likely a follow-up to recent decoding/schema-inference changes — filing as a separate issue to track.How to reproduce?
Expected: sourceSchema() returns a concrete AttributeType (e.g., BINARY) so Iceberg materialization succeeds.
Branch
main
Commit Hash (Optional)
No response
What browsers are you seeing the problem on?
No response
Relevant log output