diff --git a/fe/fe-core/pom.xml b/fe/fe-core/pom.xml index 34260b07bf40fd..e0fed410573370 100644 --- a/fe/fe-core/pom.xml +++ b/fe/fe-core/pom.xml @@ -38,7 +38,7 @@ under the License. ${basedir}/../../ ${env.FE_UT_PARALLEL} 0.8.5 - 0.12.1 + 0.14.1 python @@ -236,9 +236,37 @@ under the License. test + org.apache.iceberg - iceberg-mr + iceberg-core + ${iceberg.version} + + + org.apache.avro + avro + + + + + + + org.apache.iceberg + iceberg-hive-metastore + ${iceberg.version} + + + + + org.apache.iceberg + iceberg-bundled-guava + ${iceberg.version} + + + + + org.apache.iceberg + iceberg-common ${iceberg.version} diff --git a/fe/fe-core/src/main/java/com/starrocks/external/iceberg/hive/CachedClientPool.java b/fe/fe-core/src/main/java/com/starrocks/external/iceberg/hive/CachedClientPool.java index 6999dec0eac6aa..5985fb2e5df3bf 100644 --- a/fe/fe-core/src/main/java/com/starrocks/external/iceberg/hive/CachedClientPool.java +++ b/fe/fe-core/src/main/java/com/starrocks/external/iceberg/hive/CachedClientPool.java @@ -53,4 +53,9 @@ private synchronized void init() { public R run(Action action) throws TException, InterruptedException { return clientPool().run(action); } + + @Override + public R run(Action action, boolean retry) throws TException, InterruptedException { + return clientPool().run(action, retry); + } } diff --git a/fe/fe-core/src/main/java/com/starrocks/external/iceberg/hive/HiveClientPool.java b/fe/fe-core/src/main/java/com/starrocks/external/iceberg/hive/HiveClientPool.java index 4cfdc761f342ff..e403906320e635 100644 --- a/fe/fe-core/src/main/java/com/starrocks/external/iceberg/hive/HiveClientPool.java +++ b/fe/fe-core/src/main/java/com/starrocks/external/iceberg/hive/HiveClientPool.java @@ -26,7 +26,7 @@ public class HiveClientPool extends ClientPoolImpl private final HiveConf hiveConf; public HiveClientPool(int poolSize, Configuration conf) { - super(poolSize, TTransportException.class); + super(poolSize, TTransportException.class, true); this.hiveConf = new HiveConf(conf, HiveClientPool.class); this.hiveConf.addResource(conf); } diff --git a/fe/fe-core/src/test/java/com/starrocks/external/iceberg/IcebergCustomCatalogTest.java b/fe/fe-core/src/test/java/com/starrocks/external/iceberg/IcebergCustomCatalogTest.java index 73f12a5f9b60f3..0924c8ab0d926e 100644 --- a/fe/fe-core/src/test/java/com/starrocks/external/iceberg/IcebergCustomCatalogTest.java +++ b/fe/fe-core/src/test/java/com/starrocks/external/iceberg/IcebergCustomCatalogTest.java @@ -125,7 +125,7 @@ public static class IcebergCustomTestingCatalog extends BaseMetastoreCatalog imp private ClientPool clients; @VisibleForTesting - private IcebergCustomTestingCatalog() { + public IcebergCustomTestingCatalog() { } @Override