Flink 1.20.0 launched in EMR 7.10.0. I have a Flink application using multiple HybridSource classes to derive historical data from Iceberg and then keep updating online from kafka source, so there are ...
The iceberg specification don't say explicitly what symbols are allowed to be used within Namespaces, Tables and Column names. From our tests only # symbols is causing errors within the Java Iceberg ...