thswlsqls opened a new issue, #17088: URL: https://github.com/apache/iceberg/issues/17088
**Apache Iceberg version** main @ 49b89a8c5 **Query engine** Flink **Please describe the bug** The "Flink to Iceberg" type mapping table in `docs/docs/flink.md` (lines 352-353) lists `binary -> binary` and `varbinary -> fixed`. This is reversed: `FlinkTypeToType.visit(BinaryType)` (`flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/FlinkTypeToType.java` line 85-87) actually converts Flink `BinaryType` to Iceberg `FixedType`, and `visit(VarBinaryType)` (line 89-91) converts `VarBinaryType` to Iceberg `BinaryType`. The reverse "Iceberg to Flink" table further down the same page already documents this pairing correctly (`fixed(N) -> binary(N)`, `binary -> varbinary`), so the two tables self-contradict. **Steps to reproduce** Read `docs/docs/flink.md` "Flink to Iceberg" table and compare `binary`/`varbinary` rows against `FlinkTypeToType.java` line 85-91, or against the "Iceberg to Flink" table on the same page. **Additional context** A user designing a table schema from a Flink `binary`/`varbinary` column would expect the opposite Iceberg type from what actually gets created. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
