leekeiabstraction opened a new issue, #2589: URL: https://github.com/apache/fluss/issues/2589
### Search before asking - [x] I searched in the [issues](https://github.com/apache/fluss/issues) and found nothing similar. ### Fluss version main (development) ### Please describe the bug 🐞 When following Iceberg stream house Quickstart example, running the following ```sql -- query snapshots in iceberg SELECT snapshot_id, operation FROM datalake_enriched_orders$lake$snapshots; ``` Results in ``` [ERROR] Could not execute SQL statement. Reason: java.lang.AbstractMethodError: Receiver class org.apache.iceberg.flink.FlinkCreateTableOptions$$Lambda$1054/0x000000880185be28 does not define or inherit an implementation of the resolved method 'abstract void generate(com.fasterxml.jackson.core.JsonGenerator)' of interface org.apache.iceberg.util.JsonUtil$ToJson. ``` Stack trace on sql client side ``` 2026-02-06 13:14:05,830 ERROR org.apache.flink.table.gateway.service.SqlGatewayServiceImpl [] - Failed to fetchResults. org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed to execute the operation 568d1867-6519-4e19-96c4-e0fc57eea976. at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414) ~[flink-sql-gateway-1.20.0.jar:1.20.0] at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267) ~[flink-sql-gateway-1.20.0.jar:1.20.0] at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) ~[?:?] at java.util.concurrent.FutureTask.run(Unknown Source) ~[?:?] at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) ~[?:?] at java.util.concurrent.FutureTask.run(Unknown Source) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?] at java.lang.Thread.run(Unknown Source) [?:?] Caused by: java.lang.AbstractMethodError: Receiver class org.apache.iceberg.flink.FlinkCreateTableOptions$$Lambda$1054/0x000000880185be28 does not define or inherit an implementation of the resolved method 'abstract void generate(com.fasterxml.jackson.core.JsonGenerator)' of interface org.apache.iceberg.util.JsonUtil$ToJson. at org.apache.iceberg.util.JsonUtil.generate(JsonUtil.java:80) ~[fluss-lake-iceberg-0.9-SNAPSHOT.jar:0.9-SNAPSHOT] at org.apache.iceberg.flink.FlinkCreateTableOptions.toJson(FlinkCreateTableOptions.java:76) ~[iceberg-flink-runtime-1.20-1.10.0.jar:?] at org.apache.iceberg.flink.FlinkCatalog.getTable(FlinkCatalog.java:346) ~[iceberg-flink-runtime-1.20-1.10.0.jar:?] at org.apache.iceberg.flink.FlinkCatalog.getTable(FlinkCatalog.java:94) ~[iceberg-flink-runtime-1.20-1.10.0.jar:?] at org.apache.fluss.flink.catalog.FlinkCatalog.getLakeTable(FlinkCatalog.java:411) ~[fluss-flink-1.20-0.9-SNAPSHOT.jar:0.9-SNAPSHOT] at org.apache.fluss.flink.catalog.FlinkCatalog.getTable(FlinkCatalog.java:345) ~[fluss-flink-1.20-0.9-SNAPSHOT.jar:0.9-SNAPSHOT] at org.apache.flink.table.catalog.CatalogManager.getPermanentTable(CatalogManager.java:718) ~[flink-table-api-java-uber-1.20.0.jar:1.20.0] at org.apache.flink.table.catalog.CatalogManager.getTable(CatalogManager.java:612) ~[flink-table-api-java-uber-1.20.0.jar:1.20.0] at org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getTable(DatabaseCalciteSchema.java:88) ~[?:?] at org.apache.calcite.jdbc.SimpleCalciteSchema.getImplicitTable(SimpleCalciteSchema.java:126) ~[?:?] at org.apache.calcite.jdbc.CalciteSchema.getTable(CalciteSchema.java:295) ~[?:?] at org.apache.calcite.sql.validate.EmptyScope.resolve_(EmptyScope.java:145) ~[?:?] at org.apache.calcite.sql.validate.EmptyScope.resolveTable(EmptyScope.java:101) ~[?:?] at org.apache.calcite.sql.validate.DelegatingScope.resolveTable(DelegatingScope.java:214) ~[?:?] at org.apache.calcite.sql.validate.IdentifierNamespace.resolveImpl(IdentifierNamespace.java:116) ~[?:?] at org.apache.calcite.sql.validate.IdentifierNamespace.validateImpl(IdentifierNamespace.java:188) ~[?:?] at org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:89) ~[?:?] at org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:1062) ~[?:?] at org.apache.calcite.sql.validate.SqlValidatorImpl.validateQuery(SqlValidatorImpl.java:1037) ~[?:?] at org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3322) ~[?:?] at org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3304) ~[?:?] at org.apache.calcite.sql.validate.SqlValidatorImpl.validateSelect(SqlValidatorImpl.java:3631) ~[?:?] at org.apache.calcite.sql.validate.SelectNamespace.validateImpl(SelectNamespace.java:64) ~[?:?] at org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:89) ~[?:?] at org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:1062) ~[?:?] at org.apache.calcite.sql.validate.SqlValidatorImpl.validateQuery(SqlValidatorImpl.java:1037) ~[?:?] at org.apache.calcite.sql.SqlSelect.validate(SqlSelect.java:248) ~[?:?] at org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:1012) ~[?:?] at org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:761) ~[?:?] at org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$$validate(FlinkPlannerImpl.scala:199) ~[?:?] at org.apache.flink.table.planner.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:117) ~[?:?] at org.apache.flink.table.planner.operations.SqlNodeToOperationConversion.convert(SqlNodeToOperationConversion.java:260) ~[?:?] at org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:106) ~[?:?] at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:219) ~[flink-sql-gateway-1.20.0.jar:1.20.0] at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:199) ~[flink-sql-gateway-1.20.0.jar:1.20.0] at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:214) ~[flink-sql-gateway-1.20.0.jar:1.20.0] at org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119) ~[flink-sql-gateway-1.20.0.jar:1.20.0] at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258) ~[flink-sql-gateway-1.20.0.jar:1.20.0] ... 7 more ``` ### Solution _No response_ ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! -- 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]
