Skip to content

Commit 29f41f6

Browse files
cosmo0920edsiper
authored andcommitted
engine: Tweak conditions for enabling DLQ
Signed-off-by: Hiroshi Hatake <hiroshi@chronosphere.io>
1 parent 615ef59 commit 29f41f6

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/flb_engine.c

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -245,7 +245,10 @@ static void handle_dlq_if_available(struct flb_config *config,
245245
struct flb_input_chunk *ic;
246246
struct cio_chunk *cio_ch;
247247

248-
if (!config || !config->storage_keep_rejected || !task || !task->ic || !ins) {
248+
if (!config ||
249+
!config->storage_keep_rejected ||
250+
!config->storage_path ||
251+
!task || !task->ic || !ins) {
249252
return;
250253
}
251254

0 commit comments

Comments
 (0)