You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@fluss.apache.org by "leekeiabstraction (via GitHub)" <gi...@apache.org> on 2026/02/06 13:29:26 UTC
[I] Classloader/binary incompatibility when running iceberg quickstart [fluss]
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: issues-unsubscribe@fluss.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Classloader/binary incompatibility when running iceberg quickstart [fluss]
Posted by "luoyuxia (via GitHub)" <gi...@apache.org>.
luoyuxia commented on issue #2589:
URL: https://github.com/apache/fluss/issues/2589#issuecomment-3860559426
@leekeiabstraction Hi, did you build the latest fluss-lake-iceberg?
--
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: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Classloader/binary incompatibility when running iceberg quickstart [fluss]
Posted by "leekeiabstraction (via GitHub)" <gi...@apache.org>.
leekeiabstraction commented on issue #2589:
URL: https://github.com/apache/fluss/issues/2589#issuecomment-3860777584
Feel free to close, binary compatibility issue is no longer occurring using 0.9-release branch compilation / image / guide
--
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: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Classloader/binary incompatibility when running iceberg quickstart [fluss]
Posted by "leekeiabstraction (via GitHub)" <gi...@apache.org>.
leekeiabstraction commented on issue #2589:
URL: https://github.com/apache/fluss/issues/2589#issuecomment-3860580081
Ah, I didn't have your changes from yesterday, let me try again.
--
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: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Classloader/binary incompatibility when running iceberg quickstart [fluss]
Posted by "luoyuxia (via GitHub)" <gi...@apache.org>.
luoyuxia closed issue #2589: Classloader/binary incompatibility when running iceberg quickstart
URL: https://github.com/apache/fluss/issues/2589
--
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: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org