From f49c62f33a99d85a6d425c98e8b49ae31ebe0279 Mon Sep 17 00:00:00 2001 From: Raunaq Morarka Date: Fri, 18 Feb 2022 18:38:19 +0530 Subject: [PATCH] Disable ganglia metrics reporter for rubix Ganglia metrics reporting does not work with the custom hostnames generated by Trino. Disabling it to avoid generating failures in logs. --- .../main/java/io/trino/plugin/hive/rubix/RubixInitializer.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/rubix/RubixInitializer.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/rubix/RubixInitializer.java index 5c48622144fa..b416b6043f07 100644 --- a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/rubix/RubixInitializer.java +++ b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/rubix/RubixInitializer.java @@ -19,6 +19,7 @@ import com.qubole.rubix.bookkeeper.BookKeeper; import com.qubole.rubix.bookkeeper.BookKeeperServer; import com.qubole.rubix.bookkeeper.LocalDataTransferServer; +import com.qubole.rubix.common.metrics.MetricsReporterType; import com.qubole.rubix.core.CachingFileSystem; import com.qubole.rubix.prestosql.CachingPrestoAdlFileSystem; import com.qubole.rubix.prestosql.CachingPrestoAzureBlobFileSystem; @@ -58,6 +59,7 @@ import static com.qubole.rubix.spi.CacheConfig.setDataTransferServerPort; import static com.qubole.rubix.spi.CacheConfig.setEmbeddedMode; import static com.qubole.rubix.spi.CacheConfig.setIsParallelWarmupEnabled; +import static com.qubole.rubix.spi.CacheConfig.setMetricsReporters; import static com.qubole.rubix.spi.CacheConfig.setOnMaster; import static com.qubole.rubix.spi.CacheConfig.setPrestoClusterManager; import static io.trino.plugin.hive.DynamicConfigurationProvider.setCacheKey; @@ -299,6 +301,7 @@ private void updateRubixConfiguration(Configuration config, Owner owner) setCacheDataFullnessPercentage(config, diskUsagePercentage); setBookKeeperServerPort(config, bookKeeperServerPort); setDataTransferServerPort(config, dataTransferServerPort); + setMetricsReporters(config, MetricsReporterType.JMX.name()); setEmbeddedMode(config, true); enableHeartbeat(config, false);