zhoujinsong opened a new issue, #3504:
URL: https://github.com/apache/amoro/issues/3504
### What happened?
When I try to create a Flink catalog with following SQL:
```
CREATE CATALOG local_mixed WITH (
'type'='mixed_iceberg',
'metastore.url'='thrift://127.0.0.1:1260/local_mixed'
);
```
I got the error: `java.lang.ClassNotFoundException:
org.apache.http.client.utils.URLEncodedUtils`
I am using the `amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar`
jar built for 0.8.0-incubating rc1
### Affects Versions
master
### What table formats are you seeing the problem on?
Mixed-Iceberg
### What engines are you seeing the problem on?
Flink
### How to reproduce
- Build mixed format Flink connector for Flink 1.15
- Create a mixed format catalog based on it
### Relevant log output
```shell
org.apache.flink.table.client.gateway.SqlExecutionException: Could not
execute SQL statement.
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:211)
~[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.cli.CliClient.executeOperation(CliClient.java:658)
~[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:476)
[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.cli.CliClient.executeOperation(CliClient.java:373)
[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.cli.CliClient.getAndExecuteStatements(CliClient.java:330)
[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:281)
[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:229)
[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151)
[flink-sql-client-1.15.4.jar:1.15.4]
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95)
[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187)
[flink-sql-client-1.15.4.jar:1.15.4]
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
[flink-sql-client-1.15.4.jar:1.15.4]
Caused by: java.lang.NoClassDefFoundError:
org/apache/http/client/utils/URLEncodedUtils
at org.apache.amoro.client.PoolConfig.forUrl(PoolConfig.java:91)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.client.AmsClientPools.buildClientPool(AmsClientPools.java:47)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.LocalLoadingCache.lambda$newMappingFunction$2(LocalLoadingCache.java:145)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incu
bating]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.UnboundedLocalCache.lambda$computeIfAbsent$2(UnboundedLocalCache.java:239)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-inc
ubating]
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
~[?:1.8.0_401]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.UnboundedLocalCache.computeIfAbsent(UnboundedLocalCache.java:235)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:108)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:56)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.client.AmsClientPools.getClientPool(AmsClientPools.java:37)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.PooledAmsClient.getIface(PooledAmsClient.java:43)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.PooledAmsClient.getCatalog(PooledAmsClient.java:56)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.mixed.CatalogLoader.loadCatalog(CatalogLoader.java:137)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at org.apache.amoro.mixed.CatalogLoader.load(CatalogLoader.java:61)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.flink.InternalCatalogBuilder.createMixedFormatCatalog(InternalCatalogBuilder.java:59)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.flink.InternalCatalogBuilder.build(InternalCatalogBuilder.java:134)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.flink.catalog.MixedCatalog.open(MixedCatalog.java:131)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:211)
~[flink-table-api-java-uber-1.15.4.jar:1.15.4]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.createCatalog(TableEnvironmentImpl.java:1358)
~[flink-table-api-java-uber-1.15.4.jar:1.15.4]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1111)
~[flink-table-api-java-uber-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209)
~[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88)
~[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:209)
~[flink-sql-client-1.15.4.jar:1.15.4]
... 10 more
Caused by: java.lang.ClassNotFoundException:
org.apache.http.client.utils.URLEncodedUtils
at java.net.URLClassLoader.findClass(URLClassLoader.java:387)
~[?:1.8.0_401]
at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
~[?:1.8.0_401]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:359)
~[?:1.8.0_401]
at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
~[?:1.8.0_401]
at org.apache.amoro.client.PoolConfig.forUrl(PoolConfig.java:91)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.client.AmsClientPools.buildClientPool(AmsClientPools.java:47)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.LocalLoadingCache.lambda$newMappingFunction$2(LocalLoadingCache.java:145)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incu
bating]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.UnboundedLocalCache.lambda$computeIfAbsent$2(UnboundedLocalCache.java:239)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-inc
ubating]
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
~[?:1.8.0_401]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.UnboundedLocalCache.computeIfAbsent(UnboundedLocalCache.java:235)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:108)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.shade.com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:56)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.client.AmsClientPools.getClientPool(AmsClientPools.java:37)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.PooledAmsClient.getIface(PooledAmsClient.java:43)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.PooledAmsClient.getCatalog(PooledAmsClient.java:56)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.mixed.CatalogLoader.loadCatalog(CatalogLoader.java:137)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at org.apache.amoro.mixed.CatalogLoader.load(CatalogLoader.java:61)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.flink.InternalCatalogBuilder.createMixedFormatCatalog(InternalCatalogBuilder.java:59)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.flink.InternalCatalogBuilder.build(InternalCatalogBuilder.java:134)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.amoro.flink.catalog.MixedCatalog.open(MixedCatalog.java:131)
~[amoro-format-mixed-flink-runtime-1.15-0.8.0-incubating.jar:0.8.0-incubating]
at
org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:211)
~[flink-table-api-java-uber-1.15.4.jar:1.15.4]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.createCatalog(TableEnvironmentImpl.java:1358)
~[flink-table-api-java-uber-1.15.4.jar:1.15.4]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1111)
~[flink-table-api-java-uber-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209)
~[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88)
~[flink-sql-client-1.15.4.jar:1.15.4]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:209)
~[flink-sql-client-1.15.4.jar:1.15.4]
... 10 more
```
### Anything else
_No response_
### Are you willing to submit a PR?
- [x] Yes I am willing to submit a PR!
### Code of Conduct
- [x] I agree to follow this project's Code of Conduct
--
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]
