Skip to content

Commit 3d9cc84

Browse files
committed
Add Hive catalog to DefaultIcebergQueryRunnerMain
1 parent 081877b commit 3d9cc84

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/IcebergQueryRunner.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import io.airlift.log.Logger;
2222
import io.airlift.log.Logging;
2323
import io.trino.plugin.exchange.filesystem.FileSystemExchangePlugin;
24+
import io.trino.plugin.hive.TestingHivePlugin;
2425
import io.trino.plugin.hive.containers.Hive3MinioDataLake;
2526
import io.trino.plugin.hive.containers.HiveHadoop;
2627
import io.trino.plugin.iceberg.catalog.jdbc.TestingIcebergJdbcServer;
@@ -549,6 +550,10 @@ public static void main(String[] args)
549550
.addIcebergProperty("hive.metastore.catalog.dir", metastoreDir.toURI().toString())
550551
.setInitialTables(TpchTable.getTables())
551552
.build();
553+
queryRunner.installPlugin(new TestingHivePlugin(metastoreDir.toPath()));
554+
queryRunner.createCatalog("hive", "hive", ImmutableMap.<String, String>builder()
555+
.put("hive.security", "allow-all")
556+
.buildOrThrow());
552557
log.info("======== SERVER STARTED ========");
553558
log.info("\n====\n%s\n====", queryRunner.getCoordinator().getBaseUrl());
554559
}

0 commit comments

Comments
 (0)