mirror of https://github.com/apache/druid.git
Merge pull request #824 from metamx/compress-defaults
prefer druid.curator.compress to druid.indexer.runner.compressZnodes
This commit is contained in:
commit
6c77f66ecd
|
@ -68,7 +68,7 @@ public class RemoteTaskRunnerFactory implements TaskRunnerFactory
|
|||
curator,
|
||||
new SimplePathChildrenCacheFactory
|
||||
.Builder()
|
||||
.withCompressed(remoteTaskRunnerConfig.isCompressZnodes())
|
||||
.withCompressed(true)
|
||||
.build(),
|
||||
httpClient,
|
||||
strategy
|
||||
|
|
|
@ -33,9 +33,6 @@ public class RemoteTaskRunnerConfig
|
|||
@NotNull
|
||||
private Period taskAssignmentTimeout = new Period("PT5M");
|
||||
|
||||
@JsonProperty
|
||||
private boolean compressZnodes = false;
|
||||
|
||||
@JsonProperty
|
||||
private String minWorkerVersion = "0";
|
||||
|
||||
|
@ -48,11 +45,6 @@ public class RemoteTaskRunnerConfig
|
|||
return taskAssignmentTimeout;
|
||||
}
|
||||
|
||||
public boolean isCompressZnodes()
|
||||
{
|
||||
return compressZnodes;
|
||||
}
|
||||
|
||||
public String getMinWorkerVersion()
|
||||
{
|
||||
return minWorkerVersion;
|
||||
|
|
|
@ -26,12 +26,6 @@ import org.joda.time.Period;
|
|||
*/
|
||||
public class TestRemoteTaskRunnerConfig extends RemoteTaskRunnerConfig
|
||||
{
|
||||
@Override
|
||||
public boolean isCompressZnodes()
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Period getTaskAssignmentTimeout()
|
||||
{
|
||||
|
|
Loading…
Reference in New Issue