mirror of https://github.com/apache/druid.git
Fix spelling of "propagate" in various places. (#5896)
One of these is a configuration parameter (introduced in #5429), but it's never been in a release, so I think it's ok to rename it.
This commit is contained in:
parent
4b111929ec
commit
a28314349c
|
@ -69,7 +69,7 @@ public class CompressionUtils
|
||||||
* @param pulledFile The source file
|
* @param pulledFile The source file
|
||||||
* @param outDir The destination directory to put the resulting file
|
* @param outDir The destination directory to put the resulting file
|
||||||
*
|
*
|
||||||
* @throws IOException on propogated IO exception, IAE if it cannot determine the proper new name for `pulledFile`
|
* @throws IOException on propagated IO exception, IAE if it cannot determine the proper new name for `pulledFile`
|
||||||
*/
|
*/
|
||||||
@Deprecated // See description for alternative
|
@Deprecated // See description for alternative
|
||||||
public static void gunzip(File pulledFile, File outDir)
|
public static void gunzip(File pulledFile, File outDir)
|
||||||
|
|
|
@ -42,7 +42,7 @@ Druid uses Jetty to serve HTTP requests.
|
||||||
|`druid.server.http.defaultQueryTimeout`|Query timeout in millis, beyond which unfinished queries will be cancelled|300000|
|
|`druid.server.http.defaultQueryTimeout`|Query timeout in millis, beyond which unfinished queries will be cancelled|300000|
|
||||||
|`druid.server.http.maxScatterGatherBytes`|Maximum number of bytes gathered from data nodes such as historicals and realtime processes to execute a query. This is an advance configuration that allows to protect in case broker is under heavy load and not utilizing the data gathered in memory fast enough and leading to OOMs. This limit can be further reduced at query time using `maxScatterGatherBytes` in the context. Note that having large limit is not necessarily bad if broker is never under heavy concurrent load in which case data gathered is processed quickly and freeing up the memory used.|Long.MAX_VALUE|
|
|`druid.server.http.maxScatterGatherBytes`|Maximum number of bytes gathered from data nodes such as historicals and realtime processes to execute a query. This is an advance configuration that allows to protect in case broker is under heavy load and not utilizing the data gathered in memory fast enough and leading to OOMs. This limit can be further reduced at query time using `maxScatterGatherBytes` in the context. Note that having large limit is not necessarily bad if broker is never under heavy concurrent load in which case data gathered is processed quickly and freeing up the memory used.|Long.MAX_VALUE|
|
||||||
|`druid.server.http.gracefulShutdownTimeout`|The maximum amount of time Jetty waits after receiving shutdown signal. After this timeout the threads will be forcefully shutdown. This allows any queries that are executing to complete.|`PT0s` (do not wait)|
|
|`druid.server.http.gracefulShutdownTimeout`|The maximum amount of time Jetty waits after receiving shutdown signal. After this timeout the threads will be forcefully shutdown. This allows any queries that are executing to complete.|`PT0s` (do not wait)|
|
||||||
|`druid.server.http.unannouncePropogationDelay`|How long to wait for zookeeper unannouncements to propgate before shutting down Jetty. This is a minimum and `druid.server.http.gracefulShutdownTimeout` does not start counting down until after this period elapses.|`PT0s` (do not wait)|
|
|`druid.server.http.unannouncePropagationDelay`|How long to wait for zookeeper unannouncements to propagate before shutting down Jetty. This is a minimum and `druid.server.http.gracefulShutdownTimeout` does not start counting down until after this period elapses.|`PT0s` (do not wait)|
|
||||||
|`druid.broker.http.numConnections`|Size of connection pool for the Broker to connect to historical and real-time processes. If there are more queries than this number that all need to speak to the same node, then they will queue up.|20|
|
|`druid.broker.http.numConnections`|Size of connection pool for the Broker to connect to historical and real-time processes. If there are more queries than this number that all need to speak to the same node, then they will queue up.|20|
|
||||||
|`druid.broker.http.compressionCodec`|Compression codec the Broker uses to communicate with historical and real-time processes. May be "gzip" or "identity".|gzip|
|
|`druid.broker.http.compressionCodec`|Compression codec the Broker uses to communicate with historical and real-time processes. May be "gzip" or "identity".|gzip|
|
||||||
|`druid.broker.http.readTimeout`|The timeout for data reads from historical and real-time processes.|PT15M|
|
|`druid.broker.http.readTimeout`|The timeout for data reads from historical and real-time processes.|PT15M|
|
||||||
|
|
|
@ -55,7 +55,7 @@ Druid uses Jetty to serve HTTP requests.
|
||||||
|`druid.server.http.enableRequestLimit`|If enabled, no requests would be queued in jetty queue and "HTTP 429 Too Many Requests" error response would be sent. |false|
|
|`druid.server.http.enableRequestLimit`|If enabled, no requests would be queued in jetty queue and "HTTP 429 Too Many Requests" error response would be sent. |false|
|
||||||
|`druid.server.http.defaultQueryTimeout`|Query timeout in millis, beyond which unfinished queries will be cancelled|300000|
|
|`druid.server.http.defaultQueryTimeout`|Query timeout in millis, beyond which unfinished queries will be cancelled|300000|
|
||||||
|`druid.server.http.gracefulShutdownTimeout`|The maximum amount of time Jetty waits after receiving shutdown signal. After this timeout the threads will be forcefully shutdown. This allows any queries that are executing to complete.|`PT0s` (do not wait)|
|
|`druid.server.http.gracefulShutdownTimeout`|The maximum amount of time Jetty waits after receiving shutdown signal. After this timeout the threads will be forcefully shutdown. This allows any queries that are executing to complete.|`PT0s` (do not wait)|
|
||||||
|`druid.server.http.unannouncePropogationDelay`|How long to wait for zookeeper unannouncements to propgate before shutting down Jetty. This is a minimum and `druid.server.http.gracefulShutdownTimeout` does not start counting down until after this period elapses.|`PT0s` (do not wait)|
|
|`druid.server.http.unannouncePropagationDelay`|How long to wait for zookeeper unannouncements to propagate before shutting down Jetty. This is a minimum and `druid.server.http.gracefulShutdownTimeout` does not start counting down until after this period elapses.|`PT0s` (do not wait)|
|
||||||
|`druid.server.http.maxQueryTimeout`|Maximum allowed value (in milliseconds) for `timeout` parameter. See [query-context](query-context.html) to know more about `timeout`. Query is rejected if the query context `timeout` is greater than this value. |Long.MAX_VALUE|
|
|`druid.server.http.maxQueryTimeout`|Maximum allowed value (in milliseconds) for `timeout` parameter. See [query-context](query-context.html) to know more about `timeout`. Query is rejected if the query context `timeout` is greater than this value. |Long.MAX_VALUE|
|
||||||
|`druid.server.http.maxRequestHeaderSize`|Maximum size of a request header in bytes. Larger headers consume more memory and can make a server more vulnerable to denial of service attacks.|8 * 1024|
|
|`druid.server.http.maxRequestHeaderSize`|Maximum size of a request header in bytes. Larger headers consume more memory and can make a server more vulnerable to denial of service attacks.|8 * 1024|
|
||||||
|
|
||||||
|
|
|
@ -71,7 +71,7 @@ public class ServerConfig
|
||||||
|
|
||||||
@JsonProperty
|
@JsonProperty
|
||||||
@NotNull
|
@NotNull
|
||||||
private Period unannouncePropogationDelay = Period.ZERO;
|
private Period unannouncePropagationDelay = Period.ZERO;
|
||||||
|
|
||||||
@JsonProperty
|
@JsonProperty
|
||||||
@Min(0)
|
@Min(0)
|
||||||
|
@ -127,9 +127,9 @@ public class ServerConfig
|
||||||
return gracefulShutdownTimeout;
|
return gracefulShutdownTimeout;
|
||||||
}
|
}
|
||||||
|
|
||||||
public Period getUnannouncePropogationDelay()
|
public Period getUnannouncePropagationDelay()
|
||||||
{
|
{
|
||||||
return unannouncePropogationDelay;
|
return unannouncePropagationDelay;
|
||||||
}
|
}
|
||||||
|
|
||||||
public int getInflateBufferSize()
|
public int getInflateBufferSize()
|
||||||
|
@ -164,7 +164,7 @@ public class ServerConfig
|
||||||
compressionLevel == that.compressionLevel &&
|
compressionLevel == that.compressionLevel &&
|
||||||
Objects.equals(maxIdleTime, that.maxIdleTime) &&
|
Objects.equals(maxIdleTime, that.maxIdleTime) &&
|
||||||
Objects.equals(gracefulShutdownTimeout, that.gracefulShutdownTimeout) &&
|
Objects.equals(gracefulShutdownTimeout, that.gracefulShutdownTimeout) &&
|
||||||
Objects.equals(unannouncePropogationDelay, that.unannouncePropogationDelay);
|
Objects.equals(unannouncePropagationDelay, that.unannouncePropagationDelay);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -181,7 +181,7 @@ public class ServerConfig
|
||||||
maxQueryTimeout,
|
maxQueryTimeout,
|
||||||
maxRequestHeaderSize,
|
maxRequestHeaderSize,
|
||||||
gracefulShutdownTimeout,
|
gracefulShutdownTimeout,
|
||||||
unannouncePropogationDelay,
|
unannouncePropagationDelay,
|
||||||
inflateBufferSize,
|
inflateBufferSize,
|
||||||
compressionLevel
|
compressionLevel
|
||||||
);
|
);
|
||||||
|
@ -200,7 +200,7 @@ public class ServerConfig
|
||||||
", maxQueryTimeout=" + maxQueryTimeout +
|
", maxQueryTimeout=" + maxQueryTimeout +
|
||||||
", maxRequestHeaderSize=" + maxRequestHeaderSize +
|
", maxRequestHeaderSize=" + maxRequestHeaderSize +
|
||||||
", gracefulShutdownTimeout=" + gracefulShutdownTimeout +
|
", gracefulShutdownTimeout=" + gracefulShutdownTimeout +
|
||||||
", unannouncePropogationDelay=" + unannouncePropogationDelay +
|
", unannouncePropagationDelay=" + unannouncePropagationDelay +
|
||||||
", inflateBufferSize=" + inflateBufferSize +
|
", inflateBufferSize=" + inflateBufferSize +
|
||||||
", compressionLevel=" + compressionLevel +
|
", compressionLevel=" + compressionLevel +
|
||||||
'}';
|
'}';
|
||||||
|
|
|
@ -376,9 +376,9 @@ public class JettyServerModule extends JerseyServletModule
|
||||||
public void stop()
|
public void stop()
|
||||||
{
|
{
|
||||||
try {
|
try {
|
||||||
final long unannounceDelay = config.getUnannouncePropogationDelay().toStandardDuration().getMillis();
|
final long unannounceDelay = config.getUnannouncePropagationDelay().toStandardDuration().getMillis();
|
||||||
if (unannounceDelay > 0) {
|
if (unannounceDelay > 0) {
|
||||||
log.info("Waiting %s ms for unannouncement to propogate.", unannounceDelay);
|
log.info("Waiting %s ms for unannouncement to propagate.", unannounceDelay);
|
||||||
Thread.sleep(unannounceDelay);
|
Thread.sleep(unannounceDelay);
|
||||||
} else {
|
} else {
|
||||||
log.debug("Skipping unannounce wait.");
|
log.debug("Skipping unannounce wait.");
|
||||||
|
|
Loading…
Reference in New Issue