diff --git a/presto-hive/src/main/java/com/facebook/presto/hive/HiveClientConfig.java b/presto-hive/src/main/java/com/facebook/presto/hive/HiveClientConfig.java index 08724b14ecc4c..04ca23045a30e 100644 --- a/presto-hive/src/main/java/com/facebook/presto/hive/HiveClientConfig.java +++ b/presto-hive/src/main/java/com/facebook/presto/hive/HiveClientConfig.java @@ -385,13 +385,13 @@ public HiveClientConfig setAllowCorruptWritesForTesting(boolean allowCorruptWrit return this; } + @MinDuration("0ms") @NotNull public Duration getMetastoreCacheTtl() { return metastoreCacheTtl; } - @MinDuration("0ms") @Config("hive.metastore-cache-ttl") public HiveClientConfig setMetastoreCacheTtl(Duration metastoreCacheTtl) { @@ -399,13 +399,13 @@ public HiveClientConfig setMetastoreCacheTtl(Duration metastoreCacheTtl) return this; } + @MinDuration("1ms") @NotNull public Duration getMetastoreRefreshInterval() { return metastoreRefreshInterval; } - @MinDuration("1ms") @Config("hive.metastore-refresh-interval") public HiveClientConfig setMetastoreRefreshInterval(Duration metastoreRefreshInterval) { @@ -413,12 +413,12 @@ public HiveClientConfig setMetastoreRefreshInterval(Duration metastoreRefreshInt return this; } + @Min(1) public long getMetastoreCacheMaximumSize() { return metastoreCacheMaximumSize; } - @Min(1) @Config("hive.metastore-cache-maximum-size") public HiveClientConfig setMetastoreCacheMaximumSize(long metastoreCacheMaximumSize) { @@ -426,12 +426,12 @@ public HiveClientConfig setMetastoreCacheMaximumSize(long metastoreCacheMaximumS return this; } + @Min(1) public long getPerTransactionMetastoreCacheMaximumSize() { return perTransactionMetastoreCacheMaximumSize; } - @Min(1) @Config("hive.per-transaction-metastore-cache-maximum-size") public HiveClientConfig setPerTransactionMetastoreCacheMaximumSize(long perTransactionMetastoreCacheMaximumSize) { diff --git a/presto-main/src/main/java/com/facebook/presto/execution/TaskManagerConfig.java b/presto-main/src/main/java/com/facebook/presto/execution/TaskManagerConfig.java index c1823de7890bb..5706f5e5f7bf4 100644 --- a/presto-main/src/main/java/com/facebook/presto/execution/TaskManagerConfig.java +++ b/presto-main/src/main/java/com/facebook/presto/execution/TaskManagerConfig.java @@ -215,6 +215,7 @@ public TaskManagerConfig setShareIndexLoading(boolean shareIndexLoading) return this; } + @Min(0) public BigDecimal getLevelTimeMultiplier() { return levelTimeMultiplier; @@ -222,7 +223,6 @@ public BigDecimal getLevelTimeMultiplier() @Config("task.level-time-multiplier") @ConfigDescription("Factor that determines the target scheduled time for a level relative to the next") - @Min(0) public TaskManagerConfig setLevelTimeMultiplier(BigDecimal levelTimeMultiplier) { this.levelTimeMultiplier = levelTimeMultiplier; diff --git a/presto-main/src/main/java/com/facebook/presto/sql/analyzer/FeaturesConfig.java b/presto-main/src/main/java/com/facebook/presto/sql/analyzer/FeaturesConfig.java index b53c36d312511..23023ce59738c 100644 --- a/presto-main/src/main/java/com/facebook/presto/sql/analyzer/FeaturesConfig.java +++ b/presto-main/src/main/java/com/facebook/presto/sql/analyzer/FeaturesConfig.java @@ -394,13 +394,13 @@ public FeaturesConfig setMaxFailedTaskPercentage(double maxFailedTaskPercentage) return this; } + @Min(0) public int getConcurrentLifespansPerTask() { return concurrentLifespansPerTask; } @Config("concurrent-lifespans-per-task") - @Min(0) @ConfigDescription("Experimental: Default number of lifespans that run in parallel on each task when grouped execution is enabled") // When set to zero, a limit is not imposed on the number of lifespans that run in parallel public FeaturesConfig setConcurrentLifespansPerTask(int concurrentLifespansPerTask) @@ -1026,7 +1026,6 @@ public boolean isPushLimitThroughOuterJoin() } @Config("max-concurrent-materializations") - @Min(1) @ConfigDescription("The maximum number of materializing plan sections that can run concurrently") public FeaturesConfig setMaxConcurrentMaterializations(int maxConcurrentMaterializations) { @@ -1034,6 +1033,7 @@ public FeaturesConfig setMaxConcurrentMaterializations(int maxConcurrentMaterial return this; } + @Min(1) public int getMaxConcurrentMaterializations() { return maxConcurrentMaterializations;