diff --git a/apps/emqx_resource/include/emqx_resource.hrl b/apps/emqx_resource/include/emqx_resource.hrl index b640d17e5..32d1e94d0 100644 --- a/apps/emqx_resource/include/emqx_resource.hrl +++ b/apps/emqx_resource/include/emqx_resource.hrl @@ -86,7 +86,8 @@ -define(DEFAULT_BUFFER_BYTES, 256 * 1024 * 1024). -define(DEFAULT_BUFFER_BYTES_RAW, <<"256MB">>). --define(DEFAULT_REQUEST_TIMEOUT, timer:seconds(15)). +-define(DEFAULT_REQUEST_TIMEOUT, timer:seconds(45)). +-define(DEFAULT_REQUEST_TIMEOUT_RAW, <<"45s">>). %% count -define(DEFAULT_BATCH_SIZE, 1). diff --git a/apps/emqx_resource/src/schema/emqx_resource_schema.erl b/apps/emqx_resource/src/schema/emqx_resource_schema.erl index 5c7572ebf..713af5bc9 100644 --- a/apps/emqx_resource/src/schema/emqx_resource_schema.erl +++ b/apps/emqx_resource/src/schema/emqx_resource_schema.erl @@ -135,7 +135,7 @@ query_mode(_) -> undefined. request_timeout(type) -> hoconsc:union([infinity, emqx_schema:duration_ms()]); request_timeout(desc) -> ?DESC("request_timeout"); -request_timeout(default) -> <<"15s">>; +request_timeout(default) -> ?DEFAULT_REQUEST_TIMEOUT_RAW; request_timeout(_) -> undefined. enable_batch(type) -> boolean();